diff options
Diffstat (limited to 'src/mongo/s/query/cluster_find.cpp')
| -rw-r--r-- | src/mongo/s/query/cluster_find.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/mongo/s/query/cluster_find.cpp b/src/mongo/s/query/cluster_find.cpp index 51a29efc195..6a8a6e22033 100644 --- a/src/mongo/s/query/cluster_find.cpp +++ b/src/mongo/s/query/cluster_find.cpp @@ -411,7 +411,12 @@ StatusWith<CursorResponse> ClusterFind::runGetMore(OperationContext* opCtx, invariant(request.cursorid == pinnedCursor.getValue().getCursorId()); // If the fail point is enabled, busy wait until it is disabled. - while (MONGO_FAIL_POINT(keepCursorPinnedDuringGetMore)) { + if (MONGO_FAIL_POINT(keepCursorPinnedDuringGetMore)) { + log() << "getMore - keepCursorPinnedDuringGetMore fail point " + "enabled. Blocking until fail point is disabled."; + while (MONGO_FAIL_POINT(keepCursorPinnedDuringGetMore)) { + sleepFor(Milliseconds(2)); + } } // A user can only call getMore on their own cursor. If there were multiple users authenticated |