summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authormatt dannenberg <matt.dannenberg@10gen.com>2015-09-15 04:27:14 -0400
committermatt dannenberg <matt.dannenberg@10gen.com>2015-09-15 04:27:14 -0400
commitbb20f83281d25e566b4eb2c9984660d089204317 (patch)
treec9a78f98d4a44f3e3bc149ba3b7ba33ca01b976e /src
parent06f9b374227f38c63d5073f7e0aee6071bdfb213 (diff)
downloadmongo-bb20f83281d25e566b4eb2c9984660d089204317.tar.gz
SERVER-20412 allow for rescheduling of _priorityTakeover after cancelling the its callback
Diffstat (limited to 'src')
-rw-r--r--src/mongo/db/repl/replication_coordinator_impl.cpp2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl.cpp b/src/mongo/db/repl/replication_coordinator_impl.cpp
index eb03b42098a..1d04a3ed227 100644
--- a/src/mongo/db/repl/replication_coordinator_impl.cpp
+++ b/src/mongo/db/repl/replication_coordinator_impl.cpp
@@ -2328,6 +2328,7 @@ ReplicationCoordinatorImpl::_setCurrentRSConfig_inlock(
if (_priorityTakeoverCbh.isValid()) {
_replExecutor.cancel(_priorityTakeoverCbh);
+ _priorityTakeoverCbh = CallbackHandle();
}
const PostMemberStateUpdateAction action = _updateMemberStateFromTopologyCoordinator_inlock();
_updateSlaveInfoFromConfig_inlock();
@@ -2969,6 +2970,7 @@ bool ReplicationCoordinatorImpl::_updateTerm_incallback(long long term) {
if (updated && _priorityTakeoverCbh.isValid()) {
_replExecutor.cancel(_priorityTakeoverCbh);
+ _priorityTakeoverCbh = CallbackHandle();
}
}