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()
533         cq_(nullptr),  in ClientRpcContextStreamingFromClientImpl()
557           alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in RunNextState()
591   CompletionQueue* cq_;  member in grpc::testing::ClientRpcContextStreamingFromClientImpl
614     cq_ = cq;  in StartInternal()
664         cq_(nullptr),  in ClientRpcContextStreamingFromServerImpl()
711   CompletionQueue* cq_;  member in grpc::testing::ClientRpcContextStreamingFromServerImpl
729     cq_ = cq;  in StartInternal()
778         cq_(nullptr),  in ClientRpcContextGenericStreamingImpl()
803           alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in RunNextState()
856   CompletionQueue* cq_;  member in grpc::testing::ClientRpcContextGenericStreamingImpl
886     cq_ = cq;  in StartInternal()