• Home
  • Raw
  • Download

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()
506 CompletionQueue* cq) { in PrepareReq()
529 CompletionQueue*)> in ClientRpcContextStreamingFromClientImpl()
542 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
582 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
592 CompletionQueue* cq_;
608 CompletionQueue*)>
614 void StartInternal(CompletionQueue* cq) { in StartInternal()
638 SimpleResponse* resp, CompletionQueue* cq) { in PrepareReq()
661 CompletionQueue*)> in ClientRpcContextStreamingFromServerImpl()
674 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
703 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
713 CompletionQueue* cq_;
723 CompletionQueue*)>
729 void StartInternal(CompletionQueue* cq) { in StartInternal()
754 const SimpleRequest& req, CompletionQueue* cq) { in PrepareReq()
776 const std::string& method_name, CompletionQueue*)> in ClientRpcContextGenericStreamingImpl()
789 void Start(CompletionQueue* cq, const ClientConfig& config) override { in Start()
849 void StartNewClone(CompletionQueue* cq) override { in StartNewClone()
859 CompletionQueue* cq_;
878 CompletionQueue*)>
888 void StartInternal(CompletionQueue* cq, int messages_per_stream) { in StartInternal()
920 const std::string& method_name, CompletionQueue* cq) { in PrepareReq()