From b3605c9ab19331d18bab146ee892966c30280d02 Mon Sep 17 00:00:00 2001 From: Tyler Neely Date: Tue, 29 Nov 2022 15:11:35 +0000 Subject: [PATCH] Fix typo in new simplified RequestRouter::CreateExpand method --- src/query/v2/request_router.hpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/query/v2/request_router.hpp b/src/query/v2/request_router.hpp index 7a0fb9d8d..ffb075da0 100644 --- a/src/query/v2/request_router.hpp +++ b/src/query/v2/request_router.hpp @@ -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 responses; + std::vector responses; do { - DriveReadResponses(state, responses); + DriveWriteResponses(state, responses); } while (!state.requests.empty()); return responses;