summaryrefslogtreecommitdiff
path: root/src/mongo/s
diff options
context:
space:
mode:
authorTess Avitabile <tess.avitabile@mongodb.com>2019-12-20 18:43:14 +0000
committerevergreen <evergreen@mongodb.com>2019-12-20 18:43:14 +0000
commit3fea6b339770dcdead06803b0c794553c25b94fb (patch)
tree09f84db37faa08da48957d967ba597fb7207ebaa /src/mongo/s
parentc5bd0178db8f5ea16f7df4e78a52fda56926d0b9 (diff)
downloadmongo-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.cpp9
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();