diff options
author | Tess Avitabile <tess.avitabile@mongodb.com> | 2019-12-20 18:43:14 +0000 |
---|---|---|
committer | evergreen <evergreen@mongodb.com> | 2019-12-20 18:43:14 +0000 |
commit | 3fea6b339770dcdead06803b0c794553c25b94fb (patch) | |
tree | 09f84db37faa08da48957d967ba597fb7207ebaa /src/mongo/s | |
parent | c5bd0178db8f5ea16f7df4e78a52fda56926d0b9 (diff) | |
download | mongo-3fea6b339770dcdead06803b0c794553c25b94fb.tar.gz |
SERVER-44517 Refactor exhaust cursors on top of isMaster code changes
Diffstat (limited to 'src/mongo/s')
-rw-r--r-- | src/mongo/s/commands/strategy.cpp | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/mongo/s/commands/strategy.cpp b/src/mongo/s/commands/strategy.cpp index c80ed6e0956..61f692f315a 100644 --- a/src/mongo/s/commands/strategy.cpp +++ b/src/mongo/s/commands/strategy.cpp @@ -873,14 +873,11 @@ DbResponse Strategy::clientCommand(OperationContext* opCtx, const Message& m) { } DbResponse dbResponse; - dbResponse.shouldRunAgainForExhaust = reply->shouldRunAgainForExhaust(); - dbResponse.nextInvocation = reply->getNextInvocation(); if (OpMsg::isFlagSet(m, OpMsg::kExhaustSupported)) { auto responseObj = reply->getBodyBuilder().asTempObj(); - auto cursorObj = responseObj.getObjectField("cursor"); - if (responseObj.getField("ok").trueValue() && !cursorObj.isEmpty()) { - dbResponse.exhaustNS = cursorObj.getField("ns").String(); - dbResponse.exhaustCursorId = cursorObj.getField("id").numberLong(); + if (responseObj.getField("ok").trueValue()) { + dbResponse.shouldRunAgainForExhaust = reply->shouldRunAgainForExhaust(); + dbResponse.nextInvocation = reply->getNextInvocation(); } } dbResponse.response = reply->done(); |