diff options
| author | Benety Goh <benety@mongodb.com> | 2019-01-08 18:54:38 -0500 |
|---|---|---|
| committer | Benety Goh <benety@mongodb.com> | 2019-01-08 18:54:54 -0500 |
| commit | ecf269ff6494930ae4dfa98f66c4cbd6335cede2 (patch) | |
| tree | f4b8d60e6a09812b06c6d65ff7645d70efded954 /src/mongo/db/op_observer_registry_test.cpp | |
| parent | e2b8d928d796b4b6a6144bc4aa27db6fe95bfdd8 (diff) | |
| download | mongo-ecf269ff6494930ae4dfa98f66c4cbd6335cede2.tar.gz | |
SERVER-38800 OpObserver accepts numRecords for drop and rename operations
Diffstat (limited to 'src/mongo/db/op_observer_registry_test.cpp')
| -rw-r--r-- | src/mongo/db/op_observer_registry_test.cpp | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/src/mongo/db/op_observer_registry_test.cpp b/src/mongo/db/op_observer_registry_test.cpp index e7281598601..118b8682ea0 100644 --- a/src/mongo/db/op_observer_registry_test.cpp +++ b/src/mongo/db/op_observer_registry_test.cpp @@ -57,6 +57,7 @@ struct TestObserver : public OpObserverNoop { repl::OpTime onDropCollection(OperationContext* opCtx, const NamespaceString& collectionName, OptionalCollectionUUID uuid, + std::uint64_t numRecords, const CollectionDropType dropType) { drops++; OpObserver::Times::get(opCtx).reservedOpTimes.push_back(opTime); @@ -67,8 +68,10 @@ struct TestObserver : public OpObserverNoop { const NamespaceString& toCollection, OptionalCollectionUUID uuid, OptionalCollectionUUID dropTargetUUID, + std::uint64_t numRecords, bool stayTemp) { - preRenameCollection(opCtx, fromCollection, toCollection, uuid, dropTargetUUID, stayTemp); + preRenameCollection( + opCtx, fromCollection, toCollection, uuid, dropTargetUUID, numRecords, stayTemp); postRenameCollection(opCtx, fromCollection, toCollection, uuid, dropTargetUUID, stayTemp); } repl::OpTime preRenameCollection(OperationContext* opCtx, @@ -76,6 +79,7 @@ struct TestObserver : public OpObserverNoop { const NamespaceString& toCollection, OptionalCollectionUUID uuid, OptionalCollectionUUID dropTargetUUID, + std::uint64_t numRecords, bool stayTemp) { OpObserver::Times::get(opCtx).reservedOpTimes.push_back(opTime); return {}; @@ -172,7 +176,7 @@ TEST_F(OpObserverRegistryTest, OnDropCollectionObserverResultReturnsRightTime) { registry.addObserver(std::make_unique<OpObserverNoop>()); auto op = [&]() -> repl::OpTime { return registry.onDropCollection( - &opCtx, testNss, {}, OpObserver::CollectionDropType::kOnePhase); + &opCtx, testNss, {}, 0U, OpObserver::CollectionDropType::kOnePhase); }; checkConsistentOpTime(op); } @@ -182,7 +186,7 @@ TEST_F(OpObserverRegistryTest, PreRenameCollectionObserverResultReturnsRightTime registry.addObserver(std::move(unique1)); registry.addObserver(std::make_unique<OpObserverNoop>()); auto op = [&]() -> repl::OpTime { - auto opTime = registry.preRenameCollection(&opCtx, testNss, testNss, {}, {}, false); + auto opTime = registry.preRenameCollection(&opCtx, testNss, testNss, {}, {}, 0U, false); registry.postRenameCollection(&opCtx, testNss, testNss, {}, {}, false); return opTime; }; @@ -195,7 +199,7 @@ DEATH_TEST_F(OpObserverRegistryTest, OnDropCollectionReturnsInconsistentTime, "i registry.addObserver(std::move(unique2)); auto op = [&]() -> repl::OpTime { return registry.onDropCollection( - &opCtx, testNss, {}, OpObserver::CollectionDropType::kOnePhase); + &opCtx, testNss, {}, 0U, OpObserver::CollectionDropType::kOnePhase); }; checkInconsistentOpTime(op); } @@ -205,7 +209,7 @@ DEATH_TEST_F(OpObserverRegistryTest, PreRenameCollectionReturnsInconsistentTime, registry.addObserver(std::move(unique1)); registry.addObserver(std::move(unique2)); auto op = [&]() -> repl::OpTime { - auto opTime = registry.preRenameCollection(&opCtx, testNss, testNss, {}, {}, false); + auto opTime = registry.preRenameCollection(&opCtx, testNss, testNss, {}, {}, 0U, false); registry.postRenameCollection(&opCtx, testNss, testNss, {}, {}, false); return opTime; }; |