|
|
|
@ -137,13 +137,7 @@ class AsyncUnaryClient GRPC_FINAL : public Client { |
|
|
|
|
cli_cqs_.emplace_back(new CompletionQueue); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
auto payload_size = config.payload_size(); |
|
|
|
|
auto check_done = [payload_size](grpc::Status s, SimpleResponse* response) { |
|
|
|
|
GPR_ASSERT(s.IsOk() && (response->payload().type() == |
|
|
|
|
grpc::testing::PayloadType::COMPRESSABLE) && |
|
|
|
|
(response->payload().body().length() == |
|
|
|
|
static_cast<size_t>(payload_size))); |
|
|
|
|
}; |
|
|
|
|
auto check_done = [](grpc::Status s, SimpleResponse* response) {}; |
|
|
|
|
|
|
|
|
|
int t = 0; |
|
|
|
|
for (int i = 0; i < config.outstanding_rpcs_per_channel(); i++) { |
|
|
|
@ -270,13 +264,7 @@ class AsyncStreamingClient GRPC_FINAL : public Client { |
|
|
|
|
cli_cqs_.emplace_back(new CompletionQueue); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
auto payload_size = config.payload_size(); |
|
|
|
|
auto check_done = [payload_size](grpc::Status s, SimpleResponse *response) { |
|
|
|
|
GPR_ASSERT(s.IsOk() && (response->payload().type() == |
|
|
|
|
grpc::testing::PayloadType::COMPRESSABLE) && |
|
|
|
|
(response->payload().body().length() == |
|
|
|
|
static_cast<size_t>(payload_size))); |
|
|
|
|
}; |
|
|
|
|
auto check_done = [](grpc::Status s, SimpleResponse* response) {}; |
|
|
|
|
|
|
|
|
|
int t = 0; |
|
|
|
|
for (int i = 0; i < config.outstanding_rpcs_per_channel(); i++) { |
|
|
|
|