diff options
Diffstat (limited to 'src/mongo/db/s/active_shard_collection_registry.cpp')
-rw-r--r-- | src/mongo/db/s/active_shard_collection_registry.cpp | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/src/mongo/db/s/active_shard_collection_registry.cpp b/src/mongo/db/s/active_shard_collection_registry.cpp index 9b667370808..d2bda7ece20 100644 --- a/src/mongo/db/s/active_shard_collection_registry.cpp +++ b/src/mongo/db/s/active_shard_collection_registry.cpp @@ -139,23 +139,6 @@ Status ActiveShardCollectionRegistry::ActiveShardCollectionState::constructError << "collection with arguments: " << activeRequest.toBSON()}; } -void ActiveShardCollectionRegistry::waitForActiveShardCollectionsToComplete( - OperationContext* opCtx) { - // Take a snapshot of the currently active shard collections. - std::vector<SharedSemiFuture<boost::optional<UUID>>> shardCollectionFutures; - { - stdx::lock_guard<Latch> lk(_mutex); - for (const auto& it : _activeShardCollectionMap) { - shardCollectionFutures.emplace_back(it.second->_uuidPromise.getFuture()); - } - } - - // Synchronously wait for all futures to resolve. - for (const auto& fut : shardCollectionFutures) { - fut.wait(opCtx); - } -} - ScopedShardCollection::ScopedShardCollection(std::string nss, ActiveShardCollectionRegistry* registry, bool shouldExecute, |