Home
last modified time | relevance | path

Searched refs:messages_issued_ (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc/test/cpp/qps/
Dclient_sync.cc154 messages_issued_(num_threads_) { in SynchronousStreamingClient()
176 std::vector<int> messages_issued_; member in grpc::testing::SynchronousStreamingClient
239 messages_issued_[thread_idx] = 0; in InitThreadFuncImpl()
254 (++messages_issued_[thread_idx] < messages_per_stream_)) { in ThreadFuncImpl()
272 messages_issued_[thread_idx] = 0; in ThreadFuncImpl()
Dclient_async.cc381 if (coalesce_ && messages_issued_ == messages_per_stream_ - 1) { in RunNextState()
400 (++messages_issued_ >= messages_per_stream_)) { in RunNextState()
464 int messages_issued_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl
472 messages_issued_ = 0; in StartInternal()
825 (++messages_issued_ >= messages_per_stream_)) { in RunNextState()
883 int messages_issued_; member in grpc::testing::ClientRpcContextGenericStreamingImpl
890 messages_issued_ = 0; in StartInternal()