summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp
diff options
context:
space:
mode:
authorSiyuan Zhou <siyuan.zhou@mongodb.com>2016-04-18 19:10:40 -0400
committerSiyuan Zhou <siyuan.zhou@mongodb.com>2016-04-19 15:43:46 -0400
commitcf6b197b57a039b78e3353efa509a987287a1043 (patch)
tree8c105e4cbf2226c4be7f6dddbceea4002b5b4229 /src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp
parent6d7be60bbbf5a6be21c57398ab8616c4241b50a7 (diff)
downloadmongo-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.cpp7
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);