diff options
author | Spencer T Brody <spencer@mongodb.com> | 2017-01-17 17:06:52 -0500 |
---|---|---|
committer | Spencer T Brody <spencer@mongodb.com> | 2017-01-18 18:05:33 -0500 |
commit | 21948042b6da5fb5bf15897f9808a70551f5af09 (patch) | |
tree | fbbf09efa69efefc8b14cdb4d4ff9a7260f29e74 /src/mongo/db/repl/oplog_fetcher.cpp | |
parent | fd6971a17400c37ea6bf6c54ef2c04c25201416d (diff) | |
download | mongo-21948042b6da5fb5bf15897f9808a70551f5af09.tar.gz |
SERVER-27680 Merge stopOplogFetcher and pauseRsBgSyncProducer failpoint into single stopReplProducer failpoint
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; } |