summaryrefslogtreecommitdiff
path: root/src/mongo/db
diff options
context:
space:
mode:
authorAlya Berciu <alya.berciu@mongodb.com>2019-05-31 14:40:01 -0400
committerAlya Berciu <alya.berciu@mongodb.com>2019-06-04 10:21:55 -0400
commit5ae37d7f9a3a61a8f2357d2eed855853e3bcac2a (patch)
tree8bf1610952ad8e1cfd0dbee94222be706bae24aa /src/mongo/db
parent4156b6a9a75131e7d038712279cc7aacdd7c5403 (diff)
downloadmongo-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.cpp12
-rw-r--r--src/mongo/db/repl/replication_coordinator_external_state_impl.h5
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