diff options
author | Randolph Tan <randolph@10gen.com> | 2014-04-28 16:34:43 -0400 |
---|---|---|
committer | Dan Pasette <dan@mongodb.com> | 2014-04-30 10:35:23 -0400 |
commit | fce2652dca83bce5fcb823fccbd282c5815a899b (patch) | |
tree | d42405aad297f989e526888aaafc7f86172a12fb | |
parent | 83460112e794277ef4aee3612773bf237144ee84 (diff) | |
download | mongo-fce2652dca83bce5fcb823fccbd282c5815a899b.tar.gz |
SERVER-13777 migrated ranges waiting for deletion do not report cursors still open
(cherry picked from commit b36527b1863ed40e527bc80264075c8a09ad4a67)
-rw-r--r-- | src/mongo/db/range_deleter.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/mongo/db/range_deleter.cpp b/src/mongo/db/range_deleter.cpp index 82d5fcc0504..0ea7e44e4ec 100644 --- a/src/mongo/db/range_deleter.cpp +++ b/src/mongo/db/range_deleter.cpp @@ -237,6 +237,9 @@ namespace mongo { _taskQueueNotEmptyCV.notify_one(); } else { + log() << "rangeDeleter waiting for " << toDelete->cursorsToWait.size() + << " cursors in " << ns << " to finish" << endl; + _notReadyQueue.push_back(toDelete.release()); } } @@ -279,6 +282,11 @@ namespace mongo { long long checkIntervalMillis = 5; + if (!cursorsToWait.empty()) { + log() << "rangeDeleter waiting for " << cursorsToWait.size() + << " cursors in " << ns << " to finish" << endl; + } + while (!cursorsToWait.empty()) { set<CursorId> cursorsNow; _env->getCursorIds(ns, &cursorsNow); |