diff options
author | Alya Berciu <alya.berciu@mongodb.com> | 2019-05-31 14:40:01 -0400 |
---|---|---|
committer | Alya Berciu <alya.berciu@mongodb.com> | 2019-06-04 10:21:55 -0400 |
commit | 5ae37d7f9a3a61a8f2357d2eed855853e3bcac2a (patch) | |
tree | 8bf1610952ad8e1cfd0dbee94222be706bae24aa /src/mongo/db | |
parent | 4156b6a9a75131e7d038712279cc7aacdd7c5403 (diff) | |
download | mongo-5ae37d7f9a3a61a8f2357d2eed855853e3bcac2a.tar.gz |
SERVER-29481 Remove anonymous namespace in repl/replication_coordinator_external_state_impl.h
Diffstat (limited to 'src/mongo/db')
-rw-r--r-- | src/mongo/db/repl/replication_coordinator_external_state_impl.cpp | 12 | ||||
-rw-r--r-- | src/mongo/db/repl/replication_coordinator_external_state_impl.h | 5 |
2 files changed, 7 insertions, 10 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_external_state_impl.cpp b/src/mongo/db/repl/replication_coordinator_external_state_impl.cpp index b331991dd89..fe934c8edaf 100644 --- a/src/mongo/db/repl/replication_coordinator_external_state_impl.cpp +++ b/src/mongo/db/repl/replication_coordinator_external_state_impl.cpp @@ -262,20 +262,20 @@ void ReplicationCoordinatorExternalStateImpl::startSteadyStateReplication( void ReplicationCoordinatorExternalStateImpl::stopDataReplication(OperationContext* opCtx) { UniqueLock lk(_threadMutex); - _stopDataReplication_inlock(opCtx, &lk); + _stopDataReplication_inlock(opCtx, lk); } void ReplicationCoordinatorExternalStateImpl::_stopDataReplication_inlock(OperationContext* opCtx, - UniqueLock* lock) { + UniqueLock& lock) { // Make sue no other _stopDataReplication calls are in progress. - _dataReplicationStopped.wait(*lock, [this]() { return !_stoppingDataReplication; }); + _dataReplicationStopped.wait(lock, [this]() { return !_stoppingDataReplication; }); _stoppingDataReplication = true; auto oldSSF = std::move(_syncSourceFeedbackThread); auto oldOplogBuffer = std::move(_oplogBuffer); auto oldBgSync = std::move(_bgSync); auto oldApplier = std::move(_oplogApplier); - lock->unlock(); + lock.unlock(); // _syncSourceFeedbackThread should be joined before _bgSync's shutdown because it has // a pointer of _bgSync. @@ -314,7 +314,7 @@ void ReplicationCoordinatorExternalStateImpl::_stopDataReplication_inlock(Operat oldOplogBuffer->shutdown(opCtx); } - lock->lock(); + lock.lock(); _stoppingDataReplication = false; _dataReplicationStopped.notify_all(); } @@ -347,7 +347,7 @@ void ReplicationCoordinatorExternalStateImpl::shutdown(OperationContext* opCtx) } _inShutdown = true; - _stopDataReplication_inlock(opCtx, &lk); + _stopDataReplication_inlock(opCtx, lk); if (_noopWriter) { LOG(1) << "Stopping noop writer"; diff --git a/src/mongo/db/repl/replication_coordinator_external_state_impl.h b/src/mongo/db/repl/replication_coordinator_external_state_impl.h index 0cdef723c00..718dc396a43 100644 --- a/src/mongo/db/repl/replication_coordinator_external_state_impl.h +++ b/src/mongo/db/repl/replication_coordinator_external_state_impl.h @@ -46,9 +46,6 @@ namespace mongo { class ServiceContext; namespace repl { -namespace { -using UniqueLock = stdx::unique_lock<stdx::mutex>; -} // namespace class DropPendingCollectionReaper; class ReplicationProcess; @@ -122,7 +119,7 @@ private: /** * Stops data replication and returns with 'lock' locked. */ - void _stopDataReplication_inlock(OperationContext* opCtx, UniqueLock* lock); + void _stopDataReplication_inlock(OperationContext* opCtx, stdx::unique_lock<stdx::mutex>& lock); /** * Called when the instance transitions to primary in order to notify a potentially sharded host |