tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix typo in new simplified RequestRouter::CreateExpand method

Browse Source
This commit is contained in:
Tyler Neely 2022-11-29 15:11:35 +00:00
parent 7df3a743b9
commit b3605c9ab1
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/query/v2/request_router.hpp
View File

@ -309,14 +309,14 @@ class RequestRouter : public RequestRouterInterface {
// begin all requests in parallel
for (auto &request : state.requests) {
auto &storage_client = GetStorageClientForShard(request.shard);
msgs::ReadRequests req = request.request;
request.async_request_token = storage_client.SendAsyncReadRequest(req);
msgs::WriteRequests req = request.request;
request.async_request_token = storage_client.SendAsyncWriteRequest(req);
}
// drive requests to completion
std::vector<msgs::ExpandOneResponse> responses;
std::vector<msgs::CreateExpandResponse> responses;
do {
DriveReadResponses(state, responses);
DriveWriteResponses(state, responses);
} while (!state.requests.empty());
return responses;