Lines Matching refs:cq_
152 context_->cq_ = call_cq_; in FinalizeResult()
277 void TakeCQ(CompletionQueue* cq) { cq_ = cq; } in TakeCQ()
283 delete callback->cq_; in Run()
288 CompletionQueue* cq_ = nullptr; member in grpc::__anon5aa6847e0411::ShutdownCallback
348 cq_(nullptr) { in SyncRequest()
359 void SetupRequest() { cq_ = grpc_completion_queue_create_for_pluck(nullptr); } in SetupRequest()
362 grpc_completion_queue_destroy(cq_); in TeardownRequest()
363 cq_ = nullptr; in TeardownRequest()
367 GPR_ASSERT(cq_ && !in_flight_); in Request()
372 has_request_payload_ ? &request_payload_ : nullptr, cq_, in Request()
383 &request_metadata_, cq_, notify_cq, in Request()
396 if (cq_) { in PostShutdownCleanup()
397 grpc_completion_queue_destroy(cq_); in PostShutdownCleanup()
398 cq_ = nullptr; in PostShutdownCleanup()
404 grpc_completion_queue_destroy(cq_); in FinalizeResult()
405 cq_ = nullptr; in FinalizeResult()
421 : cq_(mrd->cq_), in CallData()
429 mrd->call_, server, &cq_, server->max_receive_message_size(), in CallData()
436 ctx_.cq_ = &cq_; in CallData()
494 cq_.Shutdown(); in ContinueRunAfterInterception()
497 cq_.TryPluck(op_tag, gpr_inf_future(GPR_CLOCK_REALTIME)); in ContinueRunAfterInterception()
501 GPR_ASSERT(cq_.Pluck(&ignored_tag) == false); in ContinueRunAfterInterception()
507 grpc::CompletionQueue cq_; member in grpc::Server::SyncRequest::CallData
531 grpc_completion_queue* cq_; member in grpc::Server::SyncRequest
554 cq_(cq), in CallbackRequest()
572 cq_(cq), in CallbackRequest()
645 req_->ctx_->cq_ = req_->cq_; in Run()
654 req_->call_, req_->server_, req_->cq_, in Run()
727 grpc::CompletionQueue* const cq_; member in grpc::Server::CallbackRequest