diff options
author | Mark Benvenuto <mark.benvenuto@mongodb.com> | 2015-06-20 00:22:50 -0400 |
---|---|---|
committer | Mark Benvenuto <mark.benvenuto@mongodb.com> | 2015-06-20 10:56:02 -0400 |
commit | 9c2ed42daa8fbbef4a919c21ec564e2db55e8d60 (patch) | |
tree | 3814f79c10d7b490948d8cb7b112ac1dd41ceff1 /src/mongo/db/background.cpp | |
parent | 01965cf52bce6976637ecb8f4a622aeb05ab256a (diff) | |
download | mongo-9c2ed42daa8fbbef4a919c21ec564e2db55e8d60.tar.gz |
SERVER-18579: Clang-Format - reformat code, no comment reflow
Diffstat (limited to 'src/mongo/db/background.cpp')
-rw-r--r-- | src/mongo/db/background.cpp | 227 |
1 files changed, 113 insertions, 114 deletions
diff --git a/src/mongo/db/background.cpp b/src/mongo/db/background.cpp index fbf46736f98..0eb45815723 100644 --- a/src/mongo/db/background.cpp +++ b/src/mongo/db/background.cpp @@ -45,137 +45,136 @@ namespace mongo { - using std::shared_ptr; +using std::shared_ptr; namespace { - class BgInfo { - MONGO_DISALLOW_COPYING(BgInfo); - public: - BgInfo() : _opsInProgCount(0) {} +class BgInfo { + MONGO_DISALLOW_COPYING(BgInfo); - void recordBegin(); - int recordEnd(); - void awaitNoBgOps(stdx::unique_lock<stdx::mutex>& lk); +public: + BgInfo() : _opsInProgCount(0) {} - int getOpsInProgCount() const { return _opsInProgCount; } + void recordBegin(); + int recordEnd(); + void awaitNoBgOps(stdx::unique_lock<stdx::mutex>& lk); - private: - int _opsInProgCount; - stdx::condition_variable _noOpsInProg; - }; - - typedef StringMap<std::shared_ptr<BgInfo> > BgInfoMap; - typedef BgInfoMap::const_iterator BgInfoMapIterator; - - stdx::mutex m; - BgInfoMap dbsInProg; - BgInfoMap nsInProg; - - void BgInfo::recordBegin() { - ++_opsInProgCount; - } - - int BgInfo::recordEnd() { - dassert(_opsInProgCount > 0); - --_opsInProgCount; - if (0 == _opsInProgCount) { - _noOpsInProg.notify_all(); - } + int getOpsInProgCount() const { return _opsInProgCount; } - void BgInfo::awaitNoBgOps(stdx::unique_lock<stdx::mutex>& lk) { - while (_opsInProgCount > 0) - _noOpsInProg.wait(lk); - } - - void recordBeginAndInsert(BgInfoMap* bgiMap, StringData key) { - std::shared_ptr<BgInfo>& bgInfo = bgiMap->get(key); - if (!bgInfo) - bgInfo.reset(new BgInfo); - bgInfo->recordBegin(); - } - - void recordEndAndRemove(BgInfoMap* bgiMap, StringData key) { - BgInfoMapIterator iter = bgiMap->find(key); - fassert(17431, iter != bgiMap->end()); - if (0 == iter->second->recordEnd()) { - bgiMap->erase(iter); - } - } - - void awaitNoBgOps( - stdx::unique_lock<stdx::mutex>& lk, - BgInfoMap* bgiMap, - StringData key) { - - std::shared_ptr<BgInfo> bgInfo = mapFindWithDefault( - *bgiMap, key, std::shared_ptr<BgInfo>()); - if (!bgInfo) - return; - bgInfo->awaitNoBgOps(lk); - } - -} // namespace - bool BackgroundOperation::inProgForDb(StringData db) { - stdx::lock_guard<stdx::mutex> lk(m); - return dbsInProg.find(db) != dbsInProg.end(); - } +private: + int _opsInProgCount; + stdx::condition_variable _noOpsInProg; +}; - bool BackgroundOperation::inProgForNs(StringData ns) { - stdx::lock_guard<stdx::mutex> lk(m); - return nsInProg.find(ns) != nsInProg.end(); - } +typedef StringMap<std::shared_ptr<BgInfo>> BgInfoMap; +typedef BgInfoMap::const_iterator BgInfoMapIterator; - void BackgroundOperation::assertNoBgOpInProgForDb(StringData db) { - uassert(ErrorCodes::BackgroundOperationInProgressForDatabase, mongoutils::str::stream() << - "cannot perform operation: a background operation is currently running for " - "database " << db, - !inProgForDb(db)); - } +stdx::mutex m; +BgInfoMap dbsInProg; +BgInfoMap nsInProg; - void BackgroundOperation::assertNoBgOpInProgForNs(StringData ns) { - uassert(ErrorCodes::BackgroundOperationInProgressForNamespace, mongoutils::str::stream() << - "cannot perform operation: a background operation is currently running for " - "collection " << ns, - !inProgForNs(ns)); - } +void BgInfo::recordBegin() { + ++_opsInProgCount; +} - void BackgroundOperation::awaitNoBgOpInProgForDb(StringData db) { - stdx::unique_lock<stdx::mutex> lk(m); - awaitNoBgOps(lk, &dbsInProg, db); +int BgInfo::recordEnd() { + dassert(_opsInProgCount > 0); + --_opsInProgCount; + if (0 == _opsInProgCount) { + _noOpsInProg.notify_all(); } - - void BackgroundOperation::awaitNoBgOpInProgForNs(StringData ns) { - stdx::unique_lock<stdx::mutex> lk(m); - awaitNoBgOps(lk, &nsInProg, ns); + return _opsInProgCount; +} + +void BgInfo::awaitNoBgOps(stdx::unique_lock<stdx::mutex>& lk) { + while (_opsInProgCount > 0) + _noOpsInProg.wait(lk); +} + +void recordBeginAndInsert(BgInfoMap* bgiMap, StringData key) { + std::shared_ptr<BgInfo>& bgInfo = bgiMap->get(key); + if (!bgInfo) + bgInfo.reset(new BgInfo); + bgInfo->recordBegin(); +} + +void recordEndAndRemove(BgInfoMap* bgiMap, StringData key) { + BgInfoMapIterator iter = bgiMap->find(key); + fassert(17431, iter != bgiMap->end()); + if (0 == iter->second->recordEnd()) { + bgiMap->erase(iter); } +} - BackgroundOperation::BackgroundOperation(StringData ns) : _ns(ns) { - stdx::lock_guard<stdx::mutex> lk(m); - recordBeginAndInsert(&dbsInProg, _ns.db()); - recordBeginAndInsert(&nsInProg, _ns.ns()); - } +void awaitNoBgOps(stdx::unique_lock<stdx::mutex>& lk, BgInfoMap* bgiMap, StringData key) { + std::shared_ptr<BgInfo> bgInfo = mapFindWithDefault(*bgiMap, key, std::shared_ptr<BgInfo>()); + if (!bgInfo) + return; + bgInfo->awaitNoBgOps(lk); +} - BackgroundOperation::~BackgroundOperation() { - stdx::lock_guard<stdx::mutex> lk(m); - recordEndAndRemove(&dbsInProg, _ns.db()); - recordEndAndRemove(&nsInProg, _ns.ns()); +} // namespace +bool BackgroundOperation::inProgForDb(StringData db) { + stdx::lock_guard<stdx::mutex> lk(m); + return dbsInProg.find(db) != dbsInProg.end(); +} + +bool BackgroundOperation::inProgForNs(StringData ns) { + stdx::lock_guard<stdx::mutex> lk(m); + return nsInProg.find(ns) != nsInProg.end(); +} + +void BackgroundOperation::assertNoBgOpInProgForDb(StringData db) { + uassert(ErrorCodes::BackgroundOperationInProgressForDatabase, + mongoutils::str::stream() + << "cannot perform operation: a background operation is currently running for " + "database " << db, + !inProgForDb(db)); +} + +void BackgroundOperation::assertNoBgOpInProgForNs(StringData ns) { + uassert(ErrorCodes::BackgroundOperationInProgressForNamespace, + mongoutils::str::stream() + << "cannot perform operation: a background operation is currently running for " + "collection " << ns, + !inProgForNs(ns)); +} + +void BackgroundOperation::awaitNoBgOpInProgForDb(StringData db) { + stdx::unique_lock<stdx::mutex> lk(m); + awaitNoBgOps(lk, &dbsInProg, db); +} + +void BackgroundOperation::awaitNoBgOpInProgForNs(StringData ns) { + stdx::unique_lock<stdx::mutex> lk(m); + awaitNoBgOps(lk, &nsInProg, ns); +} + +BackgroundOperation::BackgroundOperation(StringData ns) : _ns(ns) { + stdx::lock_guard<stdx::mutex> lk(m); + recordBeginAndInsert(&dbsInProg, _ns.db()); + recordBeginAndInsert(&nsInProg, _ns.ns()); +} + +BackgroundOperation::~BackgroundOperation() { + stdx::lock_guard<stdx::mutex> lk(m); + recordEndAndRemove(&dbsInProg, _ns.db()); + recordEndAndRemove(&nsInProg, _ns.ns()); +} + +void BackgroundOperation::dump(std::ostream& ss) { + 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) + ss << " " << i->first << '\n'; } - - void BackgroundOperation::dump(std::ostream& ss) { - 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 ) - ss << " " << i->first << '\n'; - } - for( BgInfoMapIterator i = dbsInProg.begin(); i != dbsInProg.end(); ++i ) { - if( i->second->getOpsInProgCount() ) - ss << "database " << i->first << ": " << i->second->getOpsInProgCount() << '\n'; - } + for (BgInfoMapIterator i = dbsInProg.begin(); i != dbsInProg.end(); ++i) { + if (i->second->getOpsInProgCount()) + ss << "database " << i->first << ": " << i->second->getOpsInProgCount() << '\n'; } +} -} // namespace mongo - +} // namespace mongo |