Searched refs:messages_per_stream_ (Results 1 – 2 of 2) sorted by relevance
153 messages_per_stream_(config.messages_per_stream()), in SynchronousStreamingClient()175 const int messages_per_stream_; member in grpc::testing::SynchronousStreamingClient253 if ((messages_per_stream_ != 0) && in ThreadFuncImpl()254 (++messages_issued_[thread_idx] < messages_per_stream_)) { in ThreadFuncImpl()256 } else if (messages_per_stream_ == 0) { in ThreadFuncImpl()
381 if (coalesce_ && messages_issued_ == messages_per_stream_ - 1) { in RunNextState()399 if ((messages_per_stream_ != 0) && in RunNextState()400 (++messages_issued_ >= messages_per_stream_)) { in RunNextState()429 clone->StartInternal(cq, messages_per_stream_, coalesce_); in StartNewClone()463 int messages_per_stream_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl471 messages_per_stream_ = messages_per_stream; in StartInternal()475 GPR_ASSERT(messages_per_stream_ != 0); in StartInternal()824 if ((messages_per_stream_ != 0) && in RunNextState()825 (++messages_issued_ >= messages_per_stream_)) { in RunNextState()849 clone->StartInternal(cq, messages_per_stream_); in StartNewClone()[all …]