Searched refs:requests_per_cq (Results 1 – 1 of 1) sorted by relevance
165 gpr_locked_mpscq* requests_per_cq; member315 rm->requests_per_cq = static_cast<gpr_locked_mpscq*>( in request_matcher_init()316 gpr_malloc(sizeof(*rm->requests_per_cq) * server->cq_count)); in request_matcher_init()318 gpr_locked_mpscq_init(&rm->requests_per_cq[i]); in request_matcher_init()324 GPR_ASSERT(gpr_locked_mpscq_pop(&rm->requests_per_cq[i]) == nullptr); in request_matcher_destroy()325 gpr_locked_mpscq_destroy(&rm->requests_per_cq[i]); in request_matcher_destroy()327 gpr_free(rm->requests_per_cq); in request_matcher_destroy()354 gpr_locked_mpscq_pop(&rm->requests_per_cq[i]))) != nullptr) { in request_matcher_kill_requests()501 gpr_locked_mpscq_try_pop(&rm->requests_per_cq[cq_idx])); in publish_new_rpc()523 gpr_locked_mpscq_pop(&rm->requests_per_cq[cq_idx])); in publish_new_rpc()[all …]