Lines Matching refs:cq
106 ::grpc::CompletionQueue* cq, size_t interceptor_pos) { in CreateCallInternal() argument
112 context->propagation_options_.c_bitmask(), cq->cq(), in CreateCallInternal()
129 context->propagation_options_.c_bitmask(), cq->cq(), method_slice, in CreateCallInternal()
147 return ::grpc::internal::Call(c_call, this, cq, info); in CreateCallInternal()
152 CompletionQueue* cq) { in CreateCall() argument
153 return CreateCallInternal(method, context, cq, 0); in CreateCall()
191 ::grpc::CompletionQueue* cq, void* tag) { in NotifyOnStateChangeImpl() argument
194 cq->cq(), tag_saver); in NotifyOnStateChangeImpl()
199 ::grpc::CompletionQueue cq; in WaitForStateChangeImpl()
202 NotifyOnStateChangeImpl(last_observed, deadline, &cq, nullptr); in WaitForStateChangeImpl()
203 cq.Next(&tag, &ok); in WaitForStateChangeImpl()
221 void TakeCQ(::grpc::CompletionQueue* cq) { cq_ = cq; } in TakeCQ() argument