|
|
@ -59,6 +59,8 @@ ABSL_FLAG(std::string, rpc, "UnaryCall", |
|
|
|
ABSL_FLAG(std::string, metadata, "", "metadata to send with the RPC."); |
|
|
|
ABSL_FLAG(std::string, metadata, "", "metadata to send with the RPC."); |
|
|
|
ABSL_FLAG(std::string, expect_status, "OK", |
|
|
|
ABSL_FLAG(std::string, expect_status, "OK", |
|
|
|
"RPC status for the test RPC to be considered successful"); |
|
|
|
"RPC status for the test RPC to be considered successful"); |
|
|
|
|
|
|
|
ABSL_FLAG(std::string, security, "none", |
|
|
|
|
|
|
|
"If set to \"secure\", XdsCredentials are used"); |
|
|
|
|
|
|
|
|
|
|
|
using grpc::Channel; |
|
|
|
using grpc::Channel; |
|
|
|
using grpc::ClientAsyncResponseReader; |
|
|
|
using grpc::ClientAsyncResponseReader; |
|
|
@ -460,9 +462,13 @@ class XdsUpdateClientConfigureServiceImpl |
|
|
|
void RunTestLoop(std::chrono::duration<double> duration_per_query, |
|
|
|
void RunTestLoop(std::chrono::duration<double> duration_per_query, |
|
|
|
StatsWatchers* stats_watchers, |
|
|
|
StatsWatchers* stats_watchers, |
|
|
|
RpcConfigurationsQueue* rpc_configs_queue) { |
|
|
|
RpcConfigurationsQueue* rpc_configs_queue) { |
|
|
|
TestClient client(grpc::CreateChannel(absl::GetFlag(FLAGS_server), |
|
|
|
TestClient client( |
|
|
|
grpc::InsecureChannelCredentials()), |
|
|
|
grpc::CreateChannel(absl::GetFlag(FLAGS_server), |
|
|
|
stats_watchers); |
|
|
|
absl::GetFlag(FLAGS_security) == "secure" |
|
|
|
|
|
|
|
? grpc::experimental::XdsCredentials( |
|
|
|
|
|
|
|
grpc::InsecureChannelCredentials()) |
|
|
|
|
|
|
|
: grpc::InsecureChannelCredentials()), |
|
|
|
|
|
|
|
stats_watchers); |
|
|
|
std::chrono::time_point<std::chrono::system_clock> start = |
|
|
|
std::chrono::time_point<std::chrono::system_clock> start = |
|
|
|
std::chrono::system_clock::now(); |
|
|
|
std::chrono::system_clock::now(); |
|
|
|
std::chrono::duration<double> elapsed; |
|
|
|
std::chrono::duration<double> elapsed; |
|
|
|