summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/metadata_manager.cpp
diff options
context:
space:
mode:
authorGregory Noma <gregory.noma@gmail.com>2020-04-21 13:51:04 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-04-21 18:05:40 +0000
commitfa945325938ada67a088e7dbe951404d092e8771 (patch)
treebcf81a765d3f565d3cfc425f2c576136c03e42f4 /src/mongo/db/s/metadata_manager.cpp
parent3ebb641b1c0fb63243e801b966ccde1167fdada9 (diff)
downloadmongo-fa945325938ada67a088e7dbe951404d092e8771.tar.gz
SERVER-47641 Report total number of range deletion tasks in serverStatus rather than per collection
Diffstat (limited to 'src/mongo/db/s/metadata_manager.cpp')
-rw-r--r--src/mongo/db/s/metadata_manager.cpp18
1 files changed, 5 insertions, 13 deletions
diff --git a/src/mongo/db/s/metadata_manager.cpp b/src/mongo/db/s/metadata_manager.cpp
index 7aefef96292..edb793005e0 100644
--- a/src/mongo/db/s/metadata_manager.cpp
+++ b/src/mongo/db/s/metadata_manager.cpp
@@ -340,19 +340,6 @@ void MetadataManager::append(BSONObjBuilder* builder) const {
amrArr.done();
}
-void MetadataManager::appendForServerStatus(BSONArrayBuilder* builder) const {
- auto numRangeDeletes = ([this] {
- stdx::lock_guard<Latch> lg(_managerLock);
- return _rangesScheduledForDeletion.size();
- })();
-
- if (numRangeDeletes > 0) {
- BSONObjBuilder statBuilder;
- statBuilder.appendNumber(_nss.ns(), numRangeDeletes);
- builder->append(statBuilder.obj());
- }
-}
-
SharedSemiFuture<void> MetadataManager::beginReceive(ChunkRange const& range) {
stdx::lock_guard<Latch> lg(_managerLock);
invariant(!_metadata.empty());
@@ -479,6 +466,11 @@ size_t MetadataManager::numberOfRangesToClean() const {
return _rangesScheduledForDeletion.size() - rangesToCleanInUse;
}
+size_t MetadataManager::numberOfRangesScheduledForDeletion() const {
+ stdx::lock_guard<Latch> lg(_managerLock);
+ return _rangesScheduledForDeletion.size();
+}
+
boost::optional<SharedSemiFuture<void>> MetadataManager::trackOrphanedDataCleanup(
ChunkRange const& range) const {
stdx::lock_guard<Latch> lg(_managerLock);