37 std::pair<Status, std::string> FinishRpcAndGetResult(  in FinishRpcAndGetResult()
41     ::grpc::Status grpcStatus;  in FinishRpcAndGetResult()
47         return std::pair(Status::FATAL_ERROR, "Unexpected shutdown of the completion queue");  in FinishRpcAndGetResult()
52         return std::pair(Status::FATAL_ERROR, "Unable to complete RPC request");  in FinishRpcAndGetResult()
60         return std::pair(Status::FATAL_ERROR, std::move(error_message));  in FinishRpcAndGetResult()
63     return std::pair(Status::SUCCESS, std::string(""));  in FinishRpcAndGetResult()
77 Status GrpcGraph::GetStatus() const {  in GetStatus()
87 Status GrpcGraph::initialize(const std::string& address,  in initialize()
106     if (mStatus != Status::SUCCESS) {  in initialize()
108         return Status::FATAL_ERROR;  in initialize()
115         return Status::FATAL_ERROR;  in initialize()
119     return Status::SUCCESS;  in initialize()
124 Status GrpcGraph::handleConfigPhase(const runner::ClientConfig& e) {  in handleConfigPhase()
127         mStatus = Status::ILLEGAL_STATE;  in handleConfigPhase()
128         return Status::ILLEGAL_STATE;  in handleConfigPhase()
133         mStatus = Status::INVALID_ARGUMENT;  in handleConfigPhase()
136         mStatus = Status::SUCCESS;  in handleConfigPhase()
154     if (mStatus != Status::SUCCESS) {  in handleConfigPhase()
163     mStatus = static_cast<Status>(static_cast<int>(response.code()));  in handleConfigPhase()
172 Status GrpcGraph::handleExecutionPhase(const runner::RunnerEvent& e) {  in handleExecutionPhase()
175         mStatus = Status::ILLEGAL_STATE;  in handleExecutionPhase()
181         mStatus = Status::INVALID_ARGUMENT;  in handleExecutionPhase()
184         mStatus = Status::SUCCESS;  in handleExecutionPhase()
190     if (mStatus != Status::SUCCESS) {  in handleExecutionPhase()
206     if (mStatus != Status::SUCCESS) {  in handleExecutionPhase()
211     mStatus = static_cast<Status>(static_cast<int>(response.code()));  in handleExecutionPhase()
214     if (mStatus == Status::SUCCESS) {  in handleExecutionPhase()
222 Status GrpcGraph::handleStopWithFlushPhase(const runner::RunnerEvent& e) {  in handleStopWithFlushPhase()
225         return Status::ILLEGAL_STATE;  in handleStopWithFlushPhase()
229         return Status::INVALID_ARGUMENT;  in handleStopWithFlushPhase()
231         return Status::SUCCESS;  in handleStopWithFlushPhase()
246     if (mStatus != Status::SUCCESS) {  in handleStopWithFlushPhase()
248         return Status::FATAL_ERROR;  in handleStopWithFlushPhase()
254     mStatus = static_cast<Status>(static_cast<int>(response.code()));  in handleStopWithFlushPhase()
257     if (mStatus == Status::SUCCESS) {  in handleStopWithFlushPhase()
265 Status GrpcGraph::handleStopImmediatePhase(const runner::RunnerEvent& e) {  in handleStopImmediatePhase()
268         return Status::ILLEGAL_STATE;  in handleStopImmediatePhase()
272         return Status::INVALID_ARGUMENT;  in handleStopImmediatePhase()
274         return Status::SUCCESS;  in handleStopImmediatePhase()
289     if (mStatus != Status::SUCCESS) {  in handleStopImmediatePhase()
291         return Status::FATAL_ERROR;  in handleStopImmediatePhase()
294     mStatus = static_cast<Status>(static_cast<int>(response.code()));  in handleStopImmediatePhase()
300     if (mStatus == Status::SUCCESS) {  in handleStopImmediatePhase()
306 Status GrpcGraph::handleResetPhase(const runner::RunnerEvent& e) {  in handleResetPhase()
309         return Status::ILLEGAL_STATE;  in handleResetPhase()
313         return Status::INVALID_ARGUMENT;  in handleResetPhase()
315         return Status::SUCCESS;  in handleResetPhase()
329     if (mStatus != Status::SUCCESS) {  in handleResetPhase()
331         return Status::FATAL_ERROR;  in handleResetPhase()
334     mStatus = static_cast<Status>(static_cast<int>(response.code()));  in handleResetPhase()
341 Status GrpcGraph::SetInputStreamData(int /*streamIndex*/, int64_t /*timestamp*/,  in SetInputStreamData()
344     return Status::FATAL_ERROR;  in SetInputStreamData()
347 Status GrpcGraph::SetInputStreamPixelData(int /*streamIndex*/, int64_t /*timestamp*/,  in SetInputStreamPixelData()
350     return Status::FATAL_ERROR;  in SetInputStreamPixelData()
353 Status GrpcGraph::StartGraphProfiling() {  in StartGraphProfiling()
356         return Status::ILLEGAL_STATE;  in StartGraphProfiling()
370     if (mStatus != Status::SUCCESS) {  in StartGraphProfiling()
372         return Status::FATAL_ERROR;  in StartGraphProfiling()
375     mStatus = static_cast<Status>(static_cast<int>(response.code()));  in StartGraphProfiling()
381 Status GrpcGraph::StopGraphProfiling() {  in StopGraphProfiling()
394     if (mStatus != Status::SUCCESS) {  in StopGraphProfiling()
396         return Status::FATAL_ERROR;  in StopGraphProfiling()
399     mStatus = static_cast<Status>(static_cast<int>(response.code()));  in StopGraphProfiling()
417     if (mStatus != Status::SUCCESS) {  in GetDebugInfo()
442 void GrpcGraph::dispatchGraphTerminationMessage(Status status, std::string&& errorMessage) {  in dispatchGraphTerminationMessage()
457     Status status = prebuiltGraph->initialize(address, engineInterface);  in GetRemoteGraphFromAddress()
458     if (status != Status::SUCCESS) {  in GetRemoteGraphFromAddress()