diff options
author | Siyuan Zhou <siyuan.zhou@mongodb.com> | 2016-04-18 19:10:40 -0400 |
---|---|---|
committer | Siyuan Zhou <siyuan.zhou@mongodb.com> | 2016-04-19 15:43:46 -0400 |
commit | cf6b197b57a039b78e3353efa509a987287a1043 (patch) | |
tree | 8c105e4cbf2226c4be7f6dddbceea4002b5b4229 /src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp | |
parent | 6d7be60bbbf5a6be21c57398ab8616c4241b50a7 (diff) | |
download | mongo-cf6b197b57a039b78e3353efa509a987287a1043.tar.gz |
SERVER-19423 Remove election winner declarer.
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp')
-rw-r--r-- | src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp b/src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp index b0ac53d9491..b759a2daa80 100644 --- a/src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp +++ b/src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp @@ -35,7 +35,6 @@ #include "mongo/base/disallow_copying.h" #include "mongo/db/repl/replication_coordinator_impl.h" #include "mongo/db/repl/topology_coordinator_impl.h" -#include "mongo/db/repl/election_winner_declarer.h" #include "mongo/db/repl/vote_requester.h" #include "mongo/platform/unordered_set.h" #include "mongo/util/log.h" @@ -55,7 +54,6 @@ public: return; } _replCoord->_topCoord->processLoseElection(); - _replCoord->_electionWinnerDeclarer.reset(nullptr); _replCoord->_voteRequester.reset(nullptr); if (_isDryRun && _replCoord->_electionDryRunFinishedEvent.isValid()) { _replCoord->_replExecutor.signalEvent(_replCoord->_electionDryRunFinishedEvent); @@ -87,7 +85,6 @@ public: void ReplicationCoordinatorImpl::_startElectSelfV1() { - invariant(!_electionWinnerDeclarer); invariant(!_voteRequester); invariant(!_freshnessChecker); @@ -161,7 +158,6 @@ void ReplicationCoordinatorImpl::_startElectSelfV1() { void ReplicationCoordinatorImpl::_onDryRunComplete(long long originalTerm) { invariant(_voteRequester); - invariant(!_electionWinnerDeclarer); LoseElectionDryRunGuardV1 lossGuard(this); LockGuard lk(_topoMutex); @@ -211,7 +207,6 @@ void ReplicationCoordinatorImpl::_onDryRunComplete(long long originalTerm) { void ReplicationCoordinatorImpl::_writeLastVoteForMyElection( LastVote lastVote, const ReplicationExecutor::CallbackArgs& cbData) { invariant(_voteRequester); - invariant(!_electionWinnerDeclarer); LoseElectionDryRunGuardV1 lossGuard(this); if (cbData.status == ErrorCodes::CallbackCanceled) { @@ -233,7 +228,6 @@ void ReplicationCoordinatorImpl::_writeLastVoteForMyElection( void ReplicationCoordinatorImpl::_startVoteRequester(long long newTerm) { invariant(_voteRequester); - invariant(!_electionWinnerDeclarer); LoseElectionGuardV1 lossGuard(this); LockGuard lk(_topoMutex); @@ -257,7 +251,6 @@ void ReplicationCoordinatorImpl::_startVoteRequester(long long newTerm) { void ReplicationCoordinatorImpl::_onVoteRequestComplete(long long originalTerm) { invariant(_voteRequester); - invariant(!_electionWinnerDeclarer); LoseElectionGuardV1 lossGuard(this); LockGuard lk(_topoMutex); |