| D | GrpcGraph.cpp | 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()
[all …]
|