Lines Matching refs:rpc

38         ::grpc::ClientAsyncResponseReader<RpcType>* rpc, ::grpc::CompletionQueue* cq,  in FinishRpcAndGetResult()  argument
42 rpc->Finish(response, &grpcStatus, reinterpret_cast<void*>(random_tag)); in FinishRpcAndGetResult()
100 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::GraphOptionsResponse>> rpc( in initialize() local
104 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in initialize()
149 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleConfigPhase() local
153 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleConfigPhase()
201 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleExecutionPhase() local
205 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleExecutionPhase()
241 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleStopWithFlushPhase() local
245 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleStopWithFlushPhase()
284 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleStopImmediatePhase() local
288 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleStopImmediatePhase()
324 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleResetPhase() local
328 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleResetPhase()
365 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in StartGraphProfiling() local
369 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in StartGraphProfiling()
389 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in StopGraphProfiling() local
393 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in StopGraphProfiling()
412 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::ProfilingDataResponse>> rpc( in GetDebugInfo() local
416 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in GetDebugInfo()