summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog_fetcher.cpp
diff options
context:
space:
mode:
authorSpencer T Brody <spencer@mongodb.com>2017-01-17 17:06:52 -0500
committerSpencer T Brody <spencer@mongodb.com>2017-01-18 18:05:33 -0500
commit21948042b6da5fb5bf15897f9808a70551f5af09 (patch)
treefbbf09efa69efefc8b14cdb4d4ff9a7260f29e74 /src/mongo/db/repl/oplog_fetcher.cpp
parentfd6971a17400c37ea6bf6c54ef2c04c25201416d (diff)
downloadmongo-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.cpp10
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;
}