diff options
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_impl_test.cpp')
-rw-r--r-- | src/mongo/db/repl/replication_coordinator_impl_test.cpp | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl_test.cpp b/src/mongo/db/repl/replication_coordinator_impl_test.cpp index fdde13dbc71..0757f671552 100644 --- a/src/mongo/db/repl/replication_coordinator_impl_test.cpp +++ b/src/mongo/db/repl/replication_coordinator_impl_test.cpp @@ -857,7 +857,8 @@ namespace { TEST_F(ReplCoordTest, AwaitReplicationInterrupt) { // Tests that a thread blocked in awaitReplication can be killed by a killOp operation - OperationContextReplMock txn; + const unsigned int opID = 100; + OperationContextReplMock txn{opID}; assertStartSuccess( BSON("_id" << "mySet" << "version" << 2 << @@ -878,8 +879,6 @@ namespace { writeConcern.wTimeout = WriteConcernOptions::kNoTimeout; writeConcern.wNumNodes = 2; - unsigned int opID = 100; - txn.setOpID(opID); // 2 nodes waiting for time2 awaiter.setOpTime(time2); @@ -1176,7 +1175,8 @@ namespace { } TEST_F(StepDownTest, InterruptStepDown) { - OperationContextReplMock txn; + const unsigned int opID = 100; + OperationContextReplMock txn{opID}; OpTimeWithTermZero optime1(100, 1); OpTimeWithTermZero optime2(100, 2); // No secondary is caught up @@ -1195,8 +1195,6 @@ namespace { runner.start(&txn); - unsigned int opID = 100; - txn.setOpID(opID); txn.setCheckForInterruptStatus(kInterruptedStatus); getReplCoord()->interrupt(opID); |