Lines Matching refs:grpc

38         ::grpc::ClientAsyncResponseReader<RpcType>* rpc, ::grpc::CompletionQueue* cq,  in FinishRpcAndGetResult()
41 ::grpc::Status grpcStatus; in FinishRpcAndGetResult()
89 std::shared_ptr<::grpc::ChannelCredentials> creds = ::grpc::InsecureChannelCredentials(); in initialize()
90 std::shared_ptr<::grpc::Channel> channel = ::grpc::CreateChannel(address, creds); in initialize()
94 ::grpc::ClientContext context; in initialize()
97 ::grpc::CompletionQueue cq; in initialize()
100 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::GraphOptionsResponse>> rpc( in initialize()
140 ::grpc::ClientContext context; in handleConfigPhase()
143 ::grpc::CompletionQueue cq; in handleConfigPhase()
149 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleConfigPhase()
195 ::grpc::ClientContext context; in handleExecutionPhase()
200 ::grpc::CompletionQueue cq; in handleExecutionPhase()
201 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleExecutionPhase()
234 ::grpc::ClientContext context; in handleStopWithFlushPhase()
240 ::grpc::CompletionQueue cq; in handleStopWithFlushPhase()
241 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleStopWithFlushPhase()
277 ::grpc::ClientContext context; in handleStopImmediatePhase()
283 ::grpc::CompletionQueue cq; in handleStopImmediatePhase()
284 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleStopImmediatePhase()
318 ::grpc::ClientContext context; in handleResetPhase()
323 ::grpc::CompletionQueue cq; in handleResetPhase()
324 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleResetPhase()
359 ::grpc::ClientContext context; in StartGraphProfiling()
364 ::grpc::CompletionQueue cq; in StartGraphProfiling()
365 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in StartGraphProfiling()
383 ::grpc::ClientContext context; in StopGraphProfiling()
388 ::grpc::CompletionQueue cq; in StopGraphProfiling()
389 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in StopGraphProfiling()
406 ::grpc::ClientContext context; in GetDebugInfo()
411 ::grpc::CompletionQueue cq; in GetDebugInfo()
412 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::ProfilingDataResponse>> rpc( in GetDebugInfo()