diff options
author | Jason Rassi <rassi@10gen.com> | 2015-10-12 17:06:05 -0400 |
---|---|---|
committer | Jason Rassi <rassi@10gen.com> | 2015-10-15 09:50:31 -0400 |
commit | 45db8cee0483f7481994a157aacdbcbfc314ccee (patch) | |
tree | b9142bd10191ac55c0501b4d669ba67f4a6026da /src/mongo/s/query/store_possible_cursor.cpp | |
parent | 12b91fc9249b23691b826dc8e7c1fc3cbfe215b9 (diff) | |
download | mongo-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.cpp | 12 |
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); } |