From 88876b194c5bf30583a5f23997d893784a1adf5f Mon Sep 17 00:00:00 2001 From: Donna Dionne Date: Tue, 22 Dec 2020 10:15:48 -0800 Subject: [PATCH] Fixing interop client to send all RPC types for each duration_per_query. --- test/cpp/interop/xds_interop_client.cc | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/test/cpp/interop/xds_interop_client.cc b/test/cpp/interop/xds_interop_client.cc index 1621d0f24bf..748e9e7378c 100644 --- a/test/cpp/interop/xds_interop_client.cc +++ b/test/cpp/interop/xds_interop_client.cc @@ -462,10 +462,11 @@ void RunTestLoop(std::chrono::duration duration_per_query, rpc_configs_queue->rpc_configs_queue.pop_front(); } } - for (const auto& config : configs) { - elapsed = std::chrono::system_clock::now() - start; - if (elapsed > duration_per_query) { - start = std::chrono::system_clock::now(); + + elapsed = std::chrono::system_clock::now() - start; + if (elapsed > duration_per_query) { + start = std::chrono::system_clock::now(); + for (const auto& config : configs) { if (config.type == ClientConfigureRequest::EMPTY_CALL) { client.AsyncEmptyCall(config.metadata); } else if (config.type == ClientConfigureRequest::UNARY_CALL) {