Home
last modified time | relevance | path

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

/external/grpc-grpc/test/cpp/qps/
Dserver_async.cc157 shutdown_state_.emplace_back(new PerThreadShutdownState()); in AsyncQpsServerTest()
162 for (auto ss = shutdown_state_.begin(); ss != shutdown_state_.end(); ++ss) { in ~AsyncQpsServerTest()
210 std::mutex* mu_ptr = &shutdown_state_[thread_idx]->mutex; in ThreadFunc()
217 if (shutdown_state_[thread_idx]->shutdown) { in ThreadFunc()
532 std::vector<std::unique_ptr<PerThreadShutdownState>> shutdown_state_; member in grpc::testing::AsyncQpsServerTest
Dclient_async.cc180 shutdown_state_.emplace_back(new PerThreadShutdownState()); in AsyncClient()
231 for (auto ss = shutdown_state_.begin(); ss != shutdown_state_.end(); ++ss) { in DestroyMultithreading()
243 if (shutdown_state_[thread_idx]->shutdown) { in ProcessTag()
266 std::mutex* shutdown_mu = &shutdown_state_[thread_idx]->mutex; in ThreadFunc()
298 std::vector<std::unique_ptr<PerThreadShutdownState>> shutdown_state_; member in grpc::testing::AsyncClient