Lines Matching defs:cq
85 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
111 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
138 void StartInternal(CompletionQueue* cq) { in StartInternal()
186 auto* cq = cli_cqs_[t].get(); in AsyncClient() local
195 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in ~AsyncClient() local
206 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in GetPollCount() local
235 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in DestroyMultithreading() local
323 const SimpleRequest& request, CompletionQueue* cq) { in PrepareReq()
357 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
426 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
468 void StartInternal(CompletionQueue* cq, int messages_per_stream, in StartInternal()
505 CompletionQueue* cq) { in PrepareReq()
541 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
581 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
613 void StartInternal(CompletionQueue* cq) { in StartInternal()
636 SimpleResponse* resp, CompletionQueue* cq) { in PrepareReq()
672 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
701 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
727 void StartInternal(CompletionQueue* cq) { in StartInternal()
751 const SimpleRequest& req, CompletionQueue* cq) { in PrepareReq()
786 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
846 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
885 void StartInternal(CompletionQueue* cq, int messages_per_stream) { in StartInternal()
917 const grpc::string& method_name, CompletionQueue* cq) { in PrepareReq()