diff options
author | Moiz Haidry <mhaidry@google.com> | 2018-10-10 16:15:51 -0700 |
---|---|---|
committer | Moiz Haidry <mhaidry@google.com> | 2018-10-10 16:15:51 -0700 |
commit | 145a3bf91fe1e7d0aa40f6e1f80f621d26473b1f (patch) | |
tree | 204c00effcef4536a41254c4815e0bdadc5f7a03 /test/cpp/qps | |
parent | 14acde64cca60789e29d6ac2d32261c4c18a74b3 (diff) |
Code sanitization
Diffstat (limited to 'test/cpp/qps')
-rw-r--r-- | test/cpp/qps/client_callback.cc | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/test/cpp/qps/client_callback.cc b/test/cpp/qps/client_callback.cc index 2cf5960fe7..87889e36dc 100644 --- a/test/cpp/qps/client_callback.cc +++ b/test/cpp/qps/client_callback.cc @@ -135,8 +135,8 @@ class CallbackClient class CallbackUnaryClient final : public CallbackClient { public: CallbackUnaryClient(const ClientConfig& config) : CallbackClient(config) { - for (size_t ch = 0; ch < config.client_channels(); ch++) { - for (size_t i = 0; i < config.outstanding_rpcs_per_channel(); i++) { + for (int ch = 0; ch < config.client_channels(); ch++) { + for (int i = 0; i < config.outstanding_rpcs_per_channel(); i++) { ctx_.emplace_back( new CallbackClientRpcContext(channels_[ch].get_stub())); } @@ -147,7 +147,7 @@ class CallbackUnaryClient final : public CallbackClient { protected: bool ThreadFuncImpl(Thread* t, size_t thread_idx) override { - for (int vector_idx = thread_idx; vector_idx < total_outstanding_rpcs_; + for (size_t vector_idx = thread_idx; vector_idx < total_outstanding_rpcs_; vector_idx += num_threads_) { ScheduleRpc(t, thread_idx, vector_idx); } |