diff options
author | Benety Goh <benety@mongodb.com> | 2020-05-15 11:18:28 -0400 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-05-15 15:41:45 +0000 |
commit | e9d23f4045e9a79bf6caa325da4190da2deb3cc1 (patch) | |
tree | a6d651f297bc3c466faac787caeb9ea22c564950 /src/mongo/util/fail_point_test.cpp | |
parent | 2787a803ac9a79b3bd55f73d400680e3ba975497 (diff) | |
download | mongo-e9d23f4045e9a79bf6caa325da4190da2deb3cc1.tar.gz |
SERVER-48171 FailPoint wait functions accept Interruptible
Diffstat (limited to 'src/mongo/util/fail_point_test.cpp')
-rw-r--r-- | src/mongo/util/fail_point_test.cpp | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/mongo/util/fail_point_test.cpp b/src/mongo/util/fail_point_test.cpp index eaa521d7d72..26b051fb7dc 100644 --- a/src/mongo/util/fail_point_test.cpp +++ b/src/mongo/util/fail_point_test.cpp @@ -441,9 +441,9 @@ namespace mongo { /** * Runs the given function with an operation context that has a deadline and asserts that - * the function is interruptable. + * the function is interruptible. */ -void assertFunctionInterruptable(std::function<void(OperationContext* opCtx)> f) { +void assertFunctionInterruptable(std::function<void(Interruptible* interruptible)> f) { const auto service = ServiceContext::make(); const std::shared_ptr<ClockSourceMock> mockClock = std::make_shared<ClockSourceMock>(); service->setFastClockSource(std::make_unique<SharedClockSourceAdapter>(mockClock)); @@ -467,7 +467,7 @@ TEST(FailPoint, PauseWhileSetInterruptibility) { failPoint.setMode(FailPoint::alwaysOn); assertFunctionInterruptable( - [&failPoint](OperationContext* opCtx) { failPoint.pauseWhileSet(opCtx); }); + [&failPoint](Interruptible* interruptible) { failPoint.pauseWhileSet(interruptible); }); failPoint.setMode(FailPoint::off); } @@ -476,8 +476,9 @@ TEST(FailPoint, WaitForFailPointTimeout) { FailPoint failPoint; failPoint.setMode(FailPoint::alwaysOn); - assertFunctionInterruptable( - [&failPoint](OperationContext* opCtx) { failPoint.waitForTimesEntered(opCtx, 1); }); + assertFunctionInterruptable([&failPoint](Interruptible* interruptible) { + failPoint.waitForTimesEntered(interruptible, 1); + }); failPoint.setMode(FailPoint::off); } |