diff options
Diffstat (limited to 'src/mongo/db/s/vector_clock_shard_server_test.cpp')
| -rw-r--r-- | src/mongo/db/s/vector_clock_shard_server_test.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/s/vector_clock_shard_server_test.cpp b/src/mongo/db/s/vector_clock_shard_server_test.cpp index cfe7e6bd87e..166d0802a55 100644 --- a/src/mongo/db/s/vector_clock_shard_server_test.cpp +++ b/src/mongo/db/s/vector_clock_shard_server_test.cpp @@ -326,7 +326,7 @@ TEST_F(VectorClockPersistenceTest, PrimaryRecoverWithoutExistingVectorClockDocum PersistentTaskStore<VectorClockDocument> store(NamespaceString::kVectorClockNamespace); ASSERT_EQ(store.count(opCtx, kVectorClockQuery), 0); - vc->recover().get(); + vc->recoverDirect(opCtx); auto time = vc->getTime(); ASSERT_EQ(Timestamp(0), time.configTime().asTimestamp()); @@ -343,7 +343,7 @@ TEST_F(VectorClockPersistenceTest, PrimaryRecoverWithExistingVectorClockDocument ASSERT_EQ(store.count(opCtx, kVectorClockQuery), 0); store.add(opCtx, VectorClockDocument(Timestamp(100), Timestamp(50))); - vc->recover().get(); + vc->recoverDirect(opCtx); auto time = vc->getTime(); ASSERT_EQ(Timestamp(100), time.configTime().asTimestamp()); @@ -366,7 +366,7 @@ TEST_F(VectorClockPersistenceTest, PrimaryRecoverWithIllegalVectorClockDocument) << "IllegalValue")); const int kParseErrorCode = 40414; - ASSERT_THROWS_CODE(vc->recover().get(), DBException, ErrorCodes::Error(kParseErrorCode)); + ASSERT_THROWS_CODE(vc->recoverDirect(opCtx), DBException, ErrorCodes::Error(kParseErrorCode)); } } // namespace |