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_service.cpp | |
parent | ff31e4391df93b9186bee6366e194c08173fd1c7 (diff) | |
download | mongo-failpoint_sync.tar.gz |
wrap condition variable waitForConditionOrInterruptNoAssertUntilfailpoint_sync
Diffstat (limited to 'src/mongo/util/fail_point_service.cpp')
-rw-r--r-- | src/mongo/util/fail_point_service.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/util/fail_point_service.cpp b/src/mongo/util/fail_point_service.cpp index f2ceb8bc42f..eb0f5df6cb7 100644 --- a/src/mongo/util/fail_point_service.cpp +++ b/src/mongo/util/fail_point_service.cpp @@ -62,7 +62,7 @@ FailPointRegistry* getGlobalFailPointRegistry() { return _fpRegistry.get(); } -void syncNow(const BSONObj& cmdObj) { +void syncNow(OperationContext* opCtx, const BSONObj& cmdObj) { FailPoint fp; FailPoint::Mode mode; @@ -74,7 +74,7 @@ void syncNow(const BSONObj& cmdObj) { fp.setMode(mode, val, data, syncConfig); warning() << "failpoint: 'now' set to: " << fp.toBSON(); - MONGO_FAIL_POINT_SYNC(fp); + MONGO_FAIL_POINT_SYNC(opCtx, fp); warning() << "failpoint: 'now' synced"; } |