diff options
author | matt dannenberg <matt.dannenberg@10gen.com> | 2015-09-15 04:27:14 -0400 |
---|---|---|
committer | matt dannenberg <matt.dannenberg@10gen.com> | 2015-09-15 04:27:14 -0400 |
commit | bb20f83281d25e566b4eb2c9984660d089204317 (patch) | |
tree | c9a78f98d4a44f3e3bc149ba3b7ba33ca01b976e /src | |
parent | 06f9b374227f38c63d5073f7e0aee6071bdfb213 (diff) | |
download | mongo-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.cpp | 2 |
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(); } } |