Searched refs:stream_mu_ (Results 1 – 3 of 3) sorted by relevance
151 stream_mu_(num_threads_), in SynchronousStreamingClient()168 std::vector<std::mutex> stream_mu_; member in grpc::testing::SynchronousStreamingClient183 std::lock_guard<std::mutex> l(stream_mu_[thread_idx]); in FinishStream()190 std::lock_guard<std::mutex> l(stream_mu_[thread_idx]); in FinishStream()199 std::lock_guard<std::mutex> l(stream_mu_[i]); in CleanupAllStreams()233 std::lock_guard<std::mutex> l(stream_mu_[thread_idx]); in InitThreadFuncImpl()265 std::lock_guard<std::mutex> l(stream_mu_[thread_idx]); in ThreadFuncImpl()292 std::lock_guard<std::mutex> l(stream_mu_[thread_idx]); in InitThreadFuncImpl()318 std::lock_guard<std::mutex> l(stream_mu_[thread_idx]); in ThreadFuncImpl()342 std::lock_guard<std::mutex> l(stream_mu_[thread_idx]); in InitThreadFuncImpl()[all …]
280 grpc::internal::MutexLock l(&stream_mu_); in StartSendInitialMetadata()298 grpc::internal::MutexLock l(&stream_mu_); in StartRead()327 grpc::internal::MutexLock l(&stream_mu_); in StartWrite()356 grpc::internal::MutexLock l(&stream_mu_); in StartWriteAndFinish()391 grpc::internal::MutexLock l(&stream_mu_); in Finish()439 grpc::internal::MutexLock l(&stream_mu_); in InternalBindStream()464 grpc::internal::Mutex stream_mu_; variable