diff options
| author | Eric Milkie <milkie@10gen.com> | 2015-07-20 11:44:00 -0400 |
|---|---|---|
| committer | Eric Milkie <milkie@10gen.com> | 2015-07-20 11:47:39 -0400 |
| commit | fe6b392d1b0549eaf67f0279dbb884eb510ff205 (patch) | |
| tree | 590236d61290561820a12f8aa22e7926fd2dfbe3 | |
| parent | 990eed33eb268aa50d866aba50d5eb97cbabdb37 (diff) | |
| download | mongo-fe6b392d1b0549eaf67f0279dbb884eb510ff205.tar.gz | |
SERVER-18195 remove unneeded deferred readAfterOpTime tests
| -rw-r--r-- | src/mongo/db/repl/replication_coordinator_impl_test.cpp | 54 |
1 files changed, 0 insertions, 54 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl_test.cpp b/src/mongo/db/repl/replication_coordinator_impl_test.cpp index aaa7a50fc64..acf7452d070 100644 --- a/src/mongo/db/repl/replication_coordinator_impl_test.cpp +++ b/src/mongo/db/repl/replication_coordinator_impl_test.cpp @@ -2170,60 +2170,6 @@ TEST_F(ReplCoordTest, ReadAfterEqualOpTime) { ASSERT_OK(result.getStatus()); } -TEST_F(ReplCoordTest, ReadAfterDeferredGreaterOpTime) { - OperationContextNoop txn; - assertStartSuccess(BSON("_id" - << "mySet" - << "version" << 2 << "members" << BSON_ARRAY(BSON("host" - << "node1:12345" - << "_id" << 0))), - HostAndPort("node1", 12345)); - - getReplCoord()->setMyLastOptime(OpTimeWithTermZero(0, 0)); - - auto pseudoLogOp = stdx::async(stdx::launch::async, - [this]() { - // Not guaranteed to be scheduled after waitUntil blocks... - getReplCoord()->setMyLastOptime(OpTimeWithTermZero(200, 0)); - }); - - auto result = getReplCoord()->waitUntilOpTime( - &txn, - ReadConcernArgs(OpTimeWithTermZero(100, 0), - ReadConcernArgs::ReadConcernLevel::kLocalReadConcern)); - pseudoLogOp.get(); - - ASSERT_TRUE(result.didWait()); - ASSERT_OK(result.getStatus()); -} - -TEST_F(ReplCoordTest, ReadAfterDeferredEqualOpTime) { - OperationContextNoop txn; - assertStartSuccess(BSON("_id" - << "mySet" - << "version" << 2 << "members" << BSON_ARRAY(BSON("host" - << "node1:12345" - << "_id" << 0))), - HostAndPort("node1", 12345)); - - getReplCoord()->setMyLastOptime(OpTimeWithTermZero(0, 0)); - - OpTimeWithTermZero opTimeToWait(100, 0); - - auto pseudoLogOp = stdx::async(stdx::launch::async, - [this, &opTimeToWait]() { - // Not guaranteed to be scheduled after waitUntil blocks... - getReplCoord()->setMyLastOptime(opTimeToWait); - }); - - auto result = getReplCoord()->waitUntilOpTime( - &txn, ReadConcernArgs(opTimeToWait, ReadConcernArgs::ReadConcernLevel::kLocalReadConcern)); - pseudoLogOp.get(); - - ASSERT_TRUE(result.didWait()); - ASSERT_OK(result.getStatus()); -} - TEST_F(ReplCoordTest, CantUseReadAfterCommittedIfNotReplSet) { init(ReplSettings()); OperationContextNoop txn; |