diff options
| author | Siyuan Zhou <siyuan.zhou@mongodb.com> | 2016-09-20 15:13:07 -0400 |
|---|---|---|
| committer | Siyuan Zhou <siyuan.zhou@mongodb.com> | 2016-09-21 17:30:23 -0400 |
| commit | 715d30ff455e61fd9a729e6f25f578caf4970e97 (patch) | |
| tree | 93ce4fa6ab38998b4b75fcff201e01477d56c0f2 /src/mongo/db/repl/multiapplier_test.cpp | |
| parent | 7dd2b1a22ca7ca11a697c54e682ea68383ad8138 (diff) | |
| download | mongo-715d30ff455e61fd9a729e6f25f578caf4970e97.tar.gz | |
SERVER-25403 DataReplicator initial sync should be resilient to applier failures.
Diffstat (limited to 'src/mongo/db/repl/multiapplier_test.cpp')
| -rw-r--r-- | src/mongo/db/repl/multiapplier_test.cpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/mongo/db/repl/multiapplier_test.cpp b/src/mongo/db/repl/multiapplier_test.cpp index 549d6fcb80a..cd445be0c6d 100644 --- a/src/mongo/db/repl/multiapplier_test.cpp +++ b/src/mongo/db/repl/multiapplier_test.cpp @@ -69,9 +69,12 @@ void MultiApplierTest::tearDown() { executor::ThreadPoolExecutorTest::tearDown(); } +Status applyOperation(MultiApplier::OperationPtrs*) { + return Status::OK(); +}; + TEST_F(MultiApplierTest, InvalidConstruction) { const MultiApplier::Operations operations{OplogEntry(BSON("ts" << Timestamp(Seconds(123), 0)))}; - auto applyOperation = [](MultiApplier::OperationPtrs*) {}; auto multiApply = [](OperationContext*, MultiApplier::Operations, MultiApplier::ApplyOperationFn) -> StatusWith<OpTime> { @@ -136,7 +139,6 @@ TEST_F(MultiApplierTest, InvalidConstruction) { TEST_F(MultiApplierTest, MultiApplierInvokesCallbackWithCallbackCanceledStatusUponCancellation) { const MultiApplier::Operations operations{OplogEntry(BSON("ts" << Timestamp(Seconds(123), 0)))}; - auto applyOperation = [](MultiApplier::OperationPtrs*) {}; bool multiApplyInvoked = false; auto multiApply = [&](OperationContext* txn, @@ -169,7 +171,6 @@ TEST_F(MultiApplierTest, MultiApplierInvokesCallbackWithCallbackCanceledStatusUp TEST_F(MultiApplierTest, MultiApplierPassesMultiApplyErrorToCallback) { const MultiApplier::Operations operations{OplogEntry(BSON("ts" << Timestamp(Seconds(123), 0)))}; - auto applyOperation = [](MultiApplier::OperationPtrs*) {}; bool multiApplyInvoked = false; Status multiApplyError(ErrorCodes::OperationFailed, "multi apply failed"); @@ -199,7 +200,6 @@ TEST_F(MultiApplierTest, MultiApplierPassesMultiApplyErrorToCallback) { TEST_F(MultiApplierTest, MultiApplierCatchesMultiApplyExceptionAndConvertsToCallbackStatus) { const MultiApplier::Operations operations{OplogEntry(BSON("ts" << Timestamp(Seconds(123), 0)))}; - auto applyOperation = [](MultiApplier::OperationPtrs*) {}; bool multiApplyInvoked = false; Status multiApplyError(ErrorCodes::OperationFailed, "multi apply failed"); @@ -232,7 +232,6 @@ TEST_F( MultiApplierTest, MultiApplierProvidesOperationContextToMultiApplyFunctionButDisposesBeforeInvokingFinishCallback) { const MultiApplier::Operations operations{OplogEntry(BSON("ts" << Timestamp(Seconds(123), 0)))}; - auto applyOperation = [](MultiApplier::OperationPtrs*) {}; OperationContext* multiApplyTxn = nullptr; MultiApplier::Operations operationsToApply; |