Lines Matching refs:CompletionQueue
53 virtual void StartNewClone(CompletionQueue* cq) = 0;
59 virtual void Start(CompletionQueue* cq, const ClientConfig& config) = 0;
72 CompletionQueue*)> in ClientRpcContextUnaryImpl()
85 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
111 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
121 CompletionQueue* cq_;
131 CompletionQueue*)>
138 void StartInternal(CompletionQueue* cq) { in StartInternal()
174 cli_cqs_.emplace_back(new CompletionQueue); in AsyncClient()
295 std::vector<std::unique_ptr<CompletionQueue>> cli_cqs_;
323 const SimpleRequest& request, CompletionQueue* cq) { in PrepareReq()
343 BenchmarkService::Stub*, grpc::ClientContext*, CompletionQueue*)> in ClientRpcContextStreamingPingPongImpl()
357 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
426 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
436 CompletionQueue* cq_;
455 BenchmarkService::Stub*, grpc::ClientContext*, CompletionQueue*)>
468 void StartInternal(CompletionQueue* cq, int messages_per_stream, in StartInternal()
505 CompletionQueue* cq) { in PrepareReq()
528 CompletionQueue*)> in ClientRpcContextStreamingFromClientImpl()
541 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
581 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
591 CompletionQueue* cq_;
607 CompletionQueue*)>
613 void StartInternal(CompletionQueue* cq) { in StartInternal()
636 SimpleResponse* resp, CompletionQueue* cq) { in PrepareReq()
659 CompletionQueue*)> in ClientRpcContextStreamingFromServerImpl()
672 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
701 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
711 CompletionQueue* cq_;
721 CompletionQueue*)>
727 void StartInternal(CompletionQueue* cq) { in StartInternal()
751 const SimpleRequest& req, CompletionQueue* cq) { in PrepareReq()
773 const grpc::string& method_name, CompletionQueue*)> in ClientRpcContextGenericStreamingImpl()
786 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
846 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
856 CompletionQueue* cq_;
875 CompletionQueue*)>
885 void StartInternal(CompletionQueue* cq, int messages_per_stream) { in StartInternal()
917 const grpc::string& method_name, CompletionQueue* cq) { in PrepareReq()