summaryrefslogtreecommitdiff
path: root/src/mongo/util/fail_point_test.cpp
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2020-05-15 11:18:28 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-05-15 15:41:45 +0000
commite9d23f4045e9a79bf6caa325da4190da2deb3cc1 (patch)
treea6d651f297bc3c466faac787caeb9ea22c564950 /src/mongo/util/fail_point_test.cpp
parent2787a803ac9a79b3bd55f73d400680e3ba975497 (diff)
downloadmongo-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.cpp11
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);
}