diff options
author | Jason Chan <jason.chan@10gen.com> | 2019-07-17 17:35:05 -0400 |
---|---|---|
committer | Jason Chan <jason.chan@10gen.com> | 2019-07-17 17:35:05 -0400 |
commit | 53e25a0c588a4256a73589ca777cfc4b436d544c (patch) | |
tree | 828e6fc4e7a19b026c6b97ae85eb576df39fc510 /src/mongo/util/fail_point.h | |
parent | ff31e4391df93b9186bee6366e194c08173fd1c7 (diff) | |
download | mongo-53e25a0c588a4256a73589ca777cfc4b436d544c.tar.gz |
wrap condition variable waitForConditionOrInterruptNoAssertUntilfailpoint_sync
Diffstat (limited to 'src/mongo/util/fail_point.h')
-rw-r--r-- | src/mongo/util/fail_point.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/util/fail_point.h b/src/mongo/util/fail_point.h index 7c00827fc73..7b8b51d21e3 100644 --- a/src/mongo/util/fail_point.h +++ b/src/mongo/util/fail_point.h @@ -149,7 +149,7 @@ public: */ void shouldFailCloseBlock(); - void sync() const; + void sync(OperationContext* opCtx) const; bool syncEnabled() const; @@ -305,10 +305,10 @@ inline void MONGO_FAIL_POINT_PAUSE_WHILE_SET_OR_INTERRUPTED(OperationContext* op } } -inline void MONGO_FAIL_POINT_SYNC(FailPoint& failPoint) { +inline void MONGO_FAIL_POINT_SYNC(OperationContext* opCtx, FailPoint& failPoint) { if (MONGO_FAIL_POINT(failPoint)) { if (failPoint.syncEnabled()) { - failPoint.sync(); + failPoint.sync(opCtx); } else { while (MONGO_FAIL_POINT(failPoint)) { sleepmillis(100); |