diff options
Diffstat (limited to 'src/mongo/db/repl/oplog_fetcher.cpp')
-rw-r--r-- | src/mongo/db/repl/oplog_fetcher.cpp | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/src/mongo/db/repl/oplog_fetcher.cpp b/src/mongo/db/repl/oplog_fetcher.cpp index 0bba80369cd..f976b9ac18d 100644 --- a/src/mongo/db/repl/oplog_fetcher.cpp +++ b/src/mongo/db/repl/oplog_fetcher.cpp @@ -51,7 +51,7 @@ namespace repl { Seconds OplogFetcher::kDefaultProtocolZeroAwaitDataTimeout(2); -MONGO_FP_DECLARE(stopOplogFetcher); +MONGO_FP_DECLARE(stopReplProducer); namespace { @@ -423,12 +423,10 @@ void OplogFetcher::_callback(const Fetcher::QueryResponseStatus& result, } // Stop fetching and return on fail point. - // This fail point is intended to make the oplog fetcher ignore the downloaded batch of - // operations and not error out. - if (MONGO_FAIL_POINT(stopOplogFetcher)) { + // This fail point makes the oplog fetcher ignore the downloaded batch of operations and not + // error out. + if (MONGO_FAIL_POINT(stopReplProducer)) { _finishCallback(Status::OK()); - // Wait for a while, otherwise, it will keep busy waiting. - sleepmillis(100); return; } |