Searched refs:shutdown_mu (Results 1 – 3 of 3) sorted by relevance
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 161 static gpr_mu shutdown_mu, mu; variable
193 gpr_mu_lock(&shutdown_mu); in Run()
196 gpr_mu_unlock(&shutdown_mu); in Run()
209 gpr_mu_init(&shutdown_mu); in BM_Callback_CQ_Pass1Core()
240 gpr_mu_lock(&shutdown_mu); in BM_Callback_CQ_Pass1Core()
243 gpr_cv_wait(&shutdown_cv, &shutdown_mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_Callback_CQ_Pass1Core()
245 gpr_mu_unlock(&shutdown_mu); in BM_Callback_CQ_Pass1Core()
253 gpr_mu_destroy(&shutdown_mu); in BM_Callback_CQ_Pass1Core()
261 gpr_mu_init(&shutdown_mu); in BM_Callback_CQ_Pass1CoreHeapCompletion()
285 gpr_mu_lock(&shutdown_mu); in BM_Callback_CQ_Pass1CoreHeapCompletion()
[all …]
|
| /third_party/grpc/test/core/surface/ |
| D | completion_queue_test.cc | 370 static gpr_mu mu, shutdown_mu; in test_callback() local
374 gpr_mu_init(&shutdown_mu); in test_callback()
389 gpr_mu_lock(&shutdown_mu); in test_callback()
393 gpr_mu_unlock(&shutdown_mu); in test_callback()
463 gpr_mu_lock(&shutdown_mu); in test_callback()
466 gpr_cv_wait(&shutdown_cv, &shutdown_mu, in test_callback()
469 gpr_mu_unlock(&shutdown_mu); in test_callback()
481 gpr_mu_destroy(&shutdown_mu); in test_callback()
|
| /third_party/grpc/test/cpp/qps/ |
| D | client_async.cc | 266 std::mutex* shutdown_mu = &shutdown_state_[thread_idx]->mutex; in ThreadFunc() local
267 shutdown_mu->lock(); in ThreadFunc()
270 shutdown_mu->unlock(); in ThreadFunc()
274 [&, ctx, ok, entry_ptr, shutdown_mu]() { in ThreadFunc()
281 shutdown_mu->unlock(); in ThreadFunc()
286 shutdown_mu->lock(); in ThreadFunc()
289 shutdown_mu->unlock(); in ThreadFunc()
|