SERVER-23750: wait outside of the DataReplicator mutex

1 files changed, 12 insertions, 0 deletions

diff --git a/src/mongo/client/fetcher.cpp b/src/mongo/client/fetcher.cpp
index b042a6dc0e9..4f6e831a501 100644
--- a/src/mongo/client/fetcher.cpp
+++ b/src/mongo/client/fetcher.cpp
@@ -255,6 +255,7 @@ void Fetcher::cancel() {
         }
 
         handle = _getMoreCallbackHandle;
+        _inShutdown = true;
     }
 
     _executor->cancel(handle);
@@ -288,6 +289,17 @@ void Fetcher::_callback(const RemoteCommandCallbackArgs& rcbd, const char* batch
         return;
     }
 
+    bool inShutdown = false;
+    {
+        stdx::lock_guard<stdx::mutex> lk(_mutex);
+        inShutdown = _inShutdown;
+    }
+    if (inShutdown) {
+        _work(Status(ErrorCodes::ShutdownInProgress, "fetcher shutting down"), nullptr, nullptr);
+        _finishCallback();
+        return;
+    }
+
     const BSONObj& queryResponseObj = rcbd.response.getValue().data;
     Status status = getStatusFromCommandResult(queryResponseObj);
     if (!status.isOK()) {