diff options
author | Adam Midvidy <amidvidy@gmail.com> | 2015-06-17 10:27:13 -0400 |
---|---|---|
committer | Adam Midvidy <amidvidy@gmail.com> | 2015-06-17 13:32:39 -0400 |
commit | 449e0f2b47e32060433cb6f68d967ea53c8573d1 (patch) | |
tree | 6e857f03a636b34ad8710e0b3e35a9115523483b /src/mongo/db/background.cpp | |
parent | cbc69e7dcb875b35e161875317bca701b48c770c (diff) | |
download | mongo-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.cpp | 22 |
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 ) |