summaryrefslogtreecommitdiff
path: root/src/mongo/s/query/store_possible_cursor.cpp
diff options
context:
space:
mode:
authorJason Rassi <rassi@10gen.com>2015-10-12 17:06:05 -0400
committerJason Rassi <rassi@10gen.com>2015-10-15 09:50:31 -0400
commit45db8cee0483f7481994a157aacdbcbfc314ccee (patch)
treeb9142bd10191ac55c0501b4d669ba67f4a6026da /src/mongo/s/query/store_possible_cursor.cpp
parent12b91fc9249b23691b826dc8e7c1fc3cbfe215b9 (diff)
downloadmongo-45db8cee0483f7481994a157aacdbcbfc314ccee.tar.gz
SERVER-20880 Add move support to CursorResponse class
Diffstat (limited to 'src/mongo/s/query/store_possible_cursor.cpp')
-rw-r--r--src/mongo/s/query/store_possible_cursor.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/s/query/store_possible_cursor.cpp b/src/mongo/s/query/store_possible_cursor.cpp
index 6b8d405f47b..dd029616936 100644
--- a/src/mongo/s/query/store_possible_cursor.cpp
+++ b/src/mongo/s/query/store_possible_cursor.cpp
@@ -91,25 +91,25 @@ StatusWith<BSONObj> storePossibleCursor(const HostAndPort& server,
return incomingCursorResponse.getStatus();
}
- if (incomingCursorResponse.getValue().cursorId == CursorId(0)) {
+ if (incomingCursorResponse.getValue().getCursorId() == CursorId(0)) {
return cmdResult;
}
- ClusterClientCursorParams params(incomingCursorResponse.getValue().nss);
- params.remotes.emplace_back(server, incomingCursorResponse.getValue().cursorId);
+ ClusterClientCursorParams params(incomingCursorResponse.getValue().getNSS());
+ params.remotes.emplace_back(server, incomingCursorResponse.getValue().getCursorId());
auto ccc = stdx::make_unique<ClusterClientCursorImpl>(executor, std::move(params));
auto pinnedCursor =
cursorManager->registerCursor(std::move(ccc),
- incomingCursorResponse.getValue().nss,
+ incomingCursorResponse.getValue().getNSS(),
ClusterCursorManager::CursorType::NamespaceNotSharded,
ClusterCursorManager::CursorLifetime::Mortal);
CursorId clusterCursorId = pinnedCursor.getCursorId();
pinnedCursor.returnCursor(ClusterCursorManager::CursorState::NotExhausted);
- CursorResponse outgoingCursorResponse(incomingCursorResponse.getValue().nss,
+ CursorResponse outgoingCursorResponse(incomingCursorResponse.getValue().getNSS(),
clusterCursorId,
- incomingCursorResponse.getValue().batch);
+ incomingCursorResponse.getValue().getBatch());
return outgoingCursorResponse.toBSON(CursorResponse::ResponseType::InitialResponse);
}