summaryrefslogtreecommitdiff
path: root/src/mongo/db/background.cpp
diff options
context:
space:
mode:
authorBilly Donahue <billy.donahue@mongodb.com>2020-04-21 00:38:10 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-05-02 02:12:49 +0000
commitf002800003e9ddf21d8511a0835be0526bc9b614 (patch)
tree1ea5a2f57f0715b1c6dda7bf9916cc19d0e210d8 /src/mongo/db/background.cpp
parent4d8bc5a24d08a7db945a000d569557fc1f04d539 (diff)
downloadmongo-f002800003e9ddf21d8511a0835be0526bc9b614.tar.gz
SERVER-41068 remove map_util.h
Diffstat (limited to 'src/mongo/db/background.cpp')
-rw-r--r--src/mongo/db/background.cpp21
1 files changed, 6 insertions, 15 deletions
diff --git a/src/mongo/db/background.cpp b/src/mongo/db/background.cpp
index 14da56c02ec..e77eff20cd5 100644
--- a/src/mongo/db/background.cpp
+++ b/src/mongo/db/background.cpp
@@ -39,7 +39,6 @@
#include "mongo/stdx/condition_variable.h"
#include "mongo/stdx/thread.h"
#include "mongo/util/assert_util.h"
-#include "mongo/util/map_util.h"
#include "mongo/util/str.h"
#include "mongo/util/string_map.h"
@@ -123,22 +122,16 @@ void recordEndAndRemove(BgInfoMap& bgiMap, StringData key) {
}
void awaitNoBgOps(stdx::unique_lock<Latch>& lk, BgInfoMap* bgiMap, StringData key) {
- std::shared_ptr<BgInfo> bgInfo = mapFindWithDefault(*bgiMap, key, std::shared_ptr<BgInfo>());
- if (!bgInfo)
- return;
- bgInfo->awaitNoBgOps(lk);
+ if (auto iter = bgiMap->find(key); iter != bgiMap->end())
+ iter->second->awaitNoBgOps(lk);
}
} // namespace
void BackgroundOperation::waitUntilAnIndexBuildFinishes(OperationContext* opCtx, StringData ns) {
stdx::unique_lock<Latch> lk(m);
- std::shared_ptr<BgInfo> bgInfo = mapFindWithDefault(nsInProg, ns, std::shared_ptr<BgInfo>());
- if (!bgInfo) {
- // There are no index builds in progress on the collection, so no need to wait.
- return;
- }
- bgInfo->waitForAnOpRemoval(lk, opCtx);
+ if (auto iter = nsInProg.find(ns); iter != nsInProg.end())
+ iter->second->waitForAnOpRemoval(lk, opCtx);
}
bool BackgroundOperation::inProgForDb(StringData db) {
@@ -148,10 +141,8 @@ bool BackgroundOperation::inProgForDb(StringData db) {
int BackgroundOperation::numInProgForDb(StringData db) {
stdx::lock_guard<Latch> lk(m);
- std::shared_ptr<BgInfo> bgInfo = mapFindWithDefault(dbsInProg, db, std::shared_ptr<BgInfo>());
- if (!bgInfo)
- return 0;
- return bgInfo->getOpsInProgCount();
+ auto iter = dbsInProg.find(db);
+ return iter == dbsInProg.end() ? 0 : iter->second->getOpsInProgCount();
}
bool BackgroundOperation::inProgForNs(StringData ns) {