53   virtual void StartNewClone(CompletionQueue* cq) = 0;
59   virtual void Start(CompletionQueue* cq, const ClientConfig& config) = 0;
85   void Start(CompletionQueue* cq, const ClientConfig& config) override {  in Start()  argument
87     StartInternal(cq);  in Start()
111   void StartNewClone(CompletionQueue* cq) override {  in StartNewClone()  argument
114     clone->StartInternal(cq);  in StartNewClone()
138   void StartInternal(CompletionQueue* cq) {  in StartInternal()  argument
139     cq_ = cq;  in StartInternal()
186         auto* cq = cli_cqs_[t].get();  in AsyncClient()  local
189         ctx->Start(cq, config);  in AsyncClient()
195     for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) {  in ~AsyncClient()  local
198       while ((*cq)->Next(&got_tag, &ok)) {  in ~AsyncClient()
206     for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) {  in GetPollCount()  local
207       count += grpc_get_cq_poll_num((*cq)->cq());  in GetPollCount()
235     for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) {  in DestroyMultithreading()  local
236       (*cq)->Shutdown();  in DestroyMultithreading()
323              const SimpleRequest& request, CompletionQueue* cq) {  in PrepareReq()  argument
324     return stub->PrepareAsyncUnaryCall(ctx, request, cq);  in PrepareReq()
357   void Start(CompletionQueue* cq, const ClientConfig& config) override {  in Start()  argument
358     StartInternal(cq, config.messages_per_stream(), config.use_coalesce_api());  in Start()
426   void StartNewClone(CompletionQueue* cq) override {  in StartNewClone()  argument
429     clone->StartInternal(cq, messages_per_stream_, coalesce_);  in StartNewClone()
468   void StartInternal(CompletionQueue* cq, int messages_per_stream,  in StartInternal()  argument
470     cq_ = cq;  in StartInternal()
478     stream_ = prepare_req_(stub_, &context_, cq);  in StartInternal()
506              CompletionQueue* cq) {  in PrepareReq()  argument
507     auto stream = stub->PrepareAsyncStreamingCall(ctx, cq);  in PrepareReq()
542   void Start(CompletionQueue* cq, const ClientConfig& config) override {  in Start()  argument
544     StartInternal(cq);  in Start()
582   void StartNewClone(CompletionQueue* cq) override {  in StartNewClone()  argument
585     clone->StartInternal(cq);  in StartNewClone()
614   void StartInternal(CompletionQueue* cq) {  in StartInternal()  argument
615     cq_ = cq;  in StartInternal()
616     stream_ = prepare_req_(stub_, &context_, &response_, cq);  in StartInternal()
638       SimpleResponse* resp, CompletionQueue* cq) {  in PrepareReq()  argument
639     auto stream = stub->PrepareAsyncStreamingFromClient(ctx, resp, cq);  in PrepareReq()
674   void Start(CompletionQueue* cq, const ClientConfig& config) override {  in Start()  argument
676     StartInternal(cq);  in Start()
703   void StartNewClone(CompletionQueue* cq) override {  in StartNewClone()  argument
706     clone->StartInternal(cq);  in StartNewClone()
729   void StartInternal(CompletionQueue* cq) {  in StartInternal()  argument
731     cq_ = cq;  in StartInternal()
732     stream_ = prepare_req_(stub_, &context_, req_, cq);  in StartInternal()
754       const SimpleRequest& req, CompletionQueue* cq) {  in PrepareReq()  argument
755     auto stream = stub->PrepareAsyncStreamingFromServer(ctx, req, cq);  in PrepareReq()
789   void Start(CompletionQueue* cq, const ClientConfig& config) override {  in Start()  argument
791     StartInternal(cq, config.messages_per_stream());  in Start()
849   void StartNewClone(CompletionQueue* cq) override {  in StartNewClone()  argument
852     clone->StartInternal(cq, messages_per_stream_);  in StartNewClone()
888   void StartInternal(CompletionQueue* cq, int messages_per_stream) {  in StartInternal()  argument
889     cq_ = cq;  in StartInternal()
894     stream_ = prepare_req_(stub_, &context_, kMethodName, cq);  in StartInternal()
920       const std::string& method_name, CompletionQueue* cq) {  in PrepareReq()  argument
921     auto stream = stub->PrepareCall(ctx, method_name, cq);  in PrepareReq()