summaryrefslogtreecommitdiff
path: root/src/mongo/db/background.cpp
diff options
context:
space:
mode:
authorAdam Midvidy <amidvidy@gmail.com>2015-06-17 10:27:13 -0400
committerAdam Midvidy <amidvidy@gmail.com>2015-06-17 13:32:39 -0400
commit449e0f2b47e32060433cb6f68d967ea53c8573d1 (patch)
tree6e857f03a636b34ad8710e0b3e35a9115523483b /src/mongo/db/background.cpp
parentcbc69e7dcb875b35e161875317bca701b48c770c (diff)
downloadmongo-449e0f2b47e32060433cb6f68d967ea53c8573d1.tar.gz
SERVER-18723 boost -> stdx for mutex, unique_lock, and lock_guard
Diffstat (limited to 'src/mongo/db/background.cpp')
-rw-r--r--src/mongo/db/background.cpp22
1 files changed, 11 insertions, 11 deletions
diff --git a/src/mongo/db/background.cpp b/src/mongo/db/background.cpp
index 94969dba15d..ffa053bc7e6 100644
--- a/src/mongo/db/background.cpp
+++ b/src/mongo/db/background.cpp
@@ -55,7 +55,7 @@ namespace {
void recordBegin();
int recordEnd();
- void awaitNoBgOps(boost::unique_lock<boost::mutex>& lk);
+ void awaitNoBgOps(stdx::unique_lock<stdx::mutex>& lk);
int getOpsInProgCount() const { return _opsInProgCount; }
@@ -67,7 +67,7 @@ namespace {
typedef StringMap<std::shared_ptr<BgInfo> > BgInfoMap;
typedef BgInfoMap::const_iterator BgInfoMapIterator;
- boost::mutex m;
+ stdx::mutex m;
BgInfoMap dbsInProg;
BgInfoMap nsInProg;
@@ -84,7 +84,7 @@ namespace {
return _opsInProgCount;
}
- void BgInfo::awaitNoBgOps(boost::unique_lock<boost::mutex>& lk) {
+ void BgInfo::awaitNoBgOps(stdx::unique_lock<stdx::mutex>& lk) {
while (_opsInProgCount > 0)
_noOpsInProg.wait(lk);
}
@@ -105,7 +105,7 @@ namespace {
}
void awaitNoBgOps(
- boost::unique_lock<boost::mutex>& lk,
+ stdx::unique_lock<stdx::mutex>& lk,
BgInfoMap* bgiMap,
StringData key) {
@@ -118,12 +118,12 @@ namespace {
} // namespace
bool BackgroundOperation::inProgForDb(StringData db) {
- boost::lock_guard<boost::mutex> lk(m);
+ stdx::lock_guard<stdx::mutex> lk(m);
return dbsInProg.find(db) != dbsInProg.end();
}
bool BackgroundOperation::inProgForNs(StringData ns) {
- boost::lock_guard<boost::mutex> lk(m);
+ stdx::lock_guard<stdx::mutex> lk(m);
return nsInProg.find(ns) != nsInProg.end();
}
@@ -142,29 +142,29 @@ namespace {
}
void BackgroundOperation::awaitNoBgOpInProgForDb(StringData db) {
- boost::unique_lock<boost::mutex> lk(m);
+ stdx::unique_lock<stdx::mutex> lk(m);
awaitNoBgOps(lk, &dbsInProg, db);
}
void BackgroundOperation::awaitNoBgOpInProgForNs(StringData ns) {
- boost::unique_lock<boost::mutex> lk(m);
+ stdx::unique_lock<stdx::mutex> lk(m);
awaitNoBgOps(lk, &nsInProg, ns);
}
BackgroundOperation::BackgroundOperation(StringData ns) : _ns(ns) {
- boost::lock_guard<boost::mutex> lk(m);
+ stdx::lock_guard<stdx::mutex> lk(m);
recordBeginAndInsert(&dbsInProg, _ns.db());
recordBeginAndInsert(&nsInProg, _ns.ns());
}
BackgroundOperation::~BackgroundOperation() {
- boost::lock_guard<boost::mutex> lk(m);
+ stdx::lock_guard<stdx::mutex> lk(m);
recordEndAndRemove(&dbsInProg, _ns.db());
recordEndAndRemove(&nsInProg, _ns.ns());
}
void BackgroundOperation::dump(std::ostream& ss) {
- boost::lock_guard<boost::mutex> lk(m);
+ stdx::lock_guard<stdx::mutex> lk(m);
if( nsInProg.size() ) {
ss << "\n<b>Background Jobs in Progress</b>\n";
for( BgInfoMapIterator i = nsInProg.begin(); i != nsInProg.end(); ++i )