summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2015-10-16 15:40:39 -0400
committerBenety Goh <benety@mongodb.com>2015-10-22 15:27:17 -0400
commitfd6d4f03054ccc1f6df634d7a9d5060186070e98 (patch)
treec2441c3ecdfc3c1822ba5d535f9dc3138a6da1d8 /src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp
parent38f16626e9f161672ebad8ad4a18e23b7e57de87 (diff)
downloadmongo-fd6d4f03054ccc1f6df634d7a9d5060186070e98.tar.gz
SERVER-20977 added test for processing metadata in heartbeat
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.cpp14
1 files changed, 6 insertions, 8 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 337a9ce3ff6..a1b53badd44 100644
--- a/src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp
+++ b/src/mongo/db/repl/replication_coordinator_impl_elect_v1.cpp
@@ -108,19 +108,17 @@ void ReplicationCoordinatorImpl::_startElectSelfV1() {
fassertFailed(28641);
}
- const StatusWith<ReplicationExecutor::EventHandle> finishEvh = _replExecutor.makeEvent();
- if (finishEvh.getStatus() == ErrorCodes::ShutdownInProgress) {
+ auto finishedEvent = _makeEvent();
+ if (!finishedEvent) {
return;
}
- fassert(28642, finishEvh.getStatus());
- _electionFinishedEvent = finishEvh.getValue();
+ _electionFinishedEvent = finishedEvent;
- const StatusWith<ReplicationExecutor::EventHandle> dryRunFinishEvh = _replExecutor.makeEvent();
- if (dryRunFinishEvh.getStatus() == ErrorCodes::ShutdownInProgress) {
+ auto dryRunFinishedEvent = _makeEvent();
+ if (!dryRunFinishedEvent) {
return;
}
- fassert(28767, dryRunFinishEvh.getStatus());
- _electionDryRunFinishedEvent = dryRunFinishEvh.getValue();
+ _electionDryRunFinishedEvent = dryRunFinishedEvent;
LoseElectionDryRunGuardV1 lossGuard(this);