Lines Matching refs:cq
38 ::grpc::ClientAsyncResponseReader<RpcType>* rpc, ::grpc::CompletionQueue* cq, in FinishRpcAndGetResult() argument
45 if (!cq->Next(&got_tag, &ok)) { in FinishRpcAndGetResult()
97 ::grpc::CompletionQueue cq; in initialize()
101 mGraphStub->AsyncGetGraphOptions(&context, getGraphOptionsRequest, &cq)); in initialize()
104 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in initialize()
143 ::grpc::CompletionQueue cq; in handleConfigPhase()
150 mGraphStub->AsyncSetGraphConfig(&context, setGraphConfigRequest, &cq)); in handleConfigPhase()
153 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleConfigPhase()
200 ::grpc::CompletionQueue cq; in handleExecutionPhase()
202 mGraphStub->AsyncStartGraphExecution(&context, startExecutionRequest, &cq)); in handleExecutionPhase()
205 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleExecutionPhase()
240 ::grpc::CompletionQueue cq; in handleStopWithFlushPhase()
242 mGraphStub->AsyncStopGraphExecution(&context, stopExecutionRequest, &cq)); in handleStopWithFlushPhase()
245 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleStopWithFlushPhase()
283 ::grpc::CompletionQueue cq; in handleStopImmediatePhase()
285 mGraphStub->AsyncStopGraphExecution(&context, stopExecutionRequest, &cq)); in handleStopImmediatePhase()
288 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleStopImmediatePhase()
323 ::grpc::CompletionQueue cq; in handleResetPhase()
325 mGraphStub->AsyncResetGraph(&context, resetGraphRequest, &cq)); in handleResetPhase()
328 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleResetPhase()
364 ::grpc::CompletionQueue cq; in StartGraphProfiling()
366 mGraphStub->AsyncStartGraphProfiling(&context, startProfilingRequest, &cq)); in StartGraphProfiling()
369 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in StartGraphProfiling()
388 ::grpc::CompletionQueue cq; in StopGraphProfiling()
390 mGraphStub->AsyncStopGraphProfiling(&context, stopProfilingRequest, &cq)); in StopGraphProfiling()
393 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in StopGraphProfiling()
411 ::grpc::CompletionQueue cq; in GetDebugInfo()
413 mGraphStub->AsyncGetProfilingData(&context, profilingDataRequest, &cq)); in GetDebugInfo()
416 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in GetDebugInfo()