Lines Matching refs:cq_
108 cq_(cq) {} in UnimplementedAsyncRequest()
117 ServerCompletionQueue* const cq_; member in grpc::Server::UnimplementedAsyncRequest
151 cq_(nullptr) { in SyncRequest()
162 void SetupRequest() { cq_ = grpc_completion_queue_create_for_pluck(nullptr); } in SetupRequest()
165 grpc_completion_queue_destroy(cq_); in TeardownRequest()
166 cq_ = nullptr; in TeardownRequest()
170 GPR_ASSERT(cq_ && !in_flight_); in Request()
176 has_request_payload_ ? &request_payload_ : nullptr, cq_, in Request()
187 &request_metadata_, cq_, notify_cq, in Request()
197 grpc_completion_queue_destroy(cq_); in FinalizeResult()
210 : cq_(mrd->cq_), in CallData()
211 call_(mrd->call_, server, &cq_, server->max_receive_message_size()), in CallData()
219 ctx_.cq_ = &cq_; in CallData()
242 cq_.Shutdown(); in Run()
245 cq_.TryPluck(op_tag, gpr_inf_future(GPR_CLOCK_REALTIME)); in Run()
249 GPR_ASSERT(cq_.Pluck(&ignored_tag) == false); in Run()
253 CompletionQueue cq_; member in grpc::Server::SyncRequest::CallData
272 grpc_completion_queue* cq_; member in grpc::Server::SyncRequest
691 context_->cq_ = call_cq_; in FinalizeResult()
755 new UnimplementedAsyncRequest(server_, cq_); in FinalizeResult()