77         cq_(nullptr),  in ClientRpcContextUnaryImpl()
93         response_reader_ = prepare_req_(stub_, &context_, req_, cq_);  in RunNextState()
121   CompletionQueue* cq_;  member in grpc::testing::ClientRpcContextUnaryImpl
139     cq_ = cq;  in StartInternal()
144       alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in StartInternal()
178       cq_.emplace_back(i % cli_cqs_.size());  in AsyncClient()
247       while (cli_cqs_[cq_[thread_idx]]->Next(&tag, &ok)) {  in ProcessTag()
263     if (!cli_cqs_[cq_[thread_idx]]->Next(&got_tag, &ok)) {  in ThreadFunc()
273     while (cli_cqs_[cq_[thread_idx]]->DoThenAsyncNext(  in ThreadFunc()
278             ctx->StartNewClone(cli_cqs_[cq_[thread_idx]].get());  in ThreadFunc()
296   std::vector<int> cq_;  member in grpc::testing::AsyncClient
348         cq_(nullptr),  in ClientRpcContextStreamingPingPongImpl()
373           alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in RunNextState()
436   CompletionQueue* cq_;  member in grpc::testing::ClientRpcContextStreamingPingPongImpl
470     cq_ = cq;  in StartInternal()
534         cq_(nullptr),  in ClientRpcContextStreamingFromClientImpl()
558           alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in RunNextState()
592   CompletionQueue* cq_;  member in grpc::testing::ClientRpcContextStreamingFromClientImpl
615     cq_ = cq;  in StartInternal()
666         cq_(nullptr),  in ClientRpcContextStreamingFromServerImpl()
713   CompletionQueue* cq_;  member in grpc::testing::ClientRpcContextStreamingFromServerImpl
731     cq_ = cq;  in StartInternal()
781         cq_(nullptr),  in ClientRpcContextGenericStreamingImpl()
806           alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in RunNextState()
859   CompletionQueue* cq_;  member in grpc::testing::ClientRpcContextGenericStreamingImpl
889     cq_ = cq;  in StartInternal()