Lines Matching refs:mStatus
79 return mStatus; in GetStatus()
104 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in initialize()
106 if (mStatus != Status::SUCCESS) { in initialize()
127 mStatus = Status::ILLEGAL_STATE; in handleConfigPhase()
133 mStatus = Status::INVALID_ARGUMENT; in handleConfigPhase()
134 return mStatus; in handleConfigPhase()
136 mStatus = Status::SUCCESS; in handleConfigPhase()
137 return mStatus; in handleConfigPhase()
153 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleConfigPhase()
154 if (mStatus != Status::SUCCESS) { in handleConfigPhase()
156 return mStatus; in handleConfigPhase()
163 mStatus = static_cast<Status>(static_cast<int>(response.code())); in handleConfigPhase()
168 return mStatus; in handleConfigPhase()
175 mStatus = Status::ILLEGAL_STATE; in handleExecutionPhase()
176 return mStatus; in handleExecutionPhase()
181 mStatus = Status::INVALID_ARGUMENT; in handleExecutionPhase()
182 return mStatus; in handleExecutionPhase()
184 mStatus = Status::SUCCESS; in handleExecutionPhase()
185 return mStatus; in handleExecutionPhase()
189 mStatus = mStreamSetObserver->startObservingStreams(); in handleExecutionPhase()
190 if (mStatus != Status::SUCCESS) { in handleExecutionPhase()
192 return mStatus; in handleExecutionPhase()
205 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleExecutionPhase()
206 if (mStatus != Status::SUCCESS) { in handleExecutionPhase()
208 return mStatus; in handleExecutionPhase()
211 mStatus = static_cast<Status>(static_cast<int>(response.code())); in handleExecutionPhase()
214 if (mStatus == Status::SUCCESS) { in handleExecutionPhase()
218 return mStatus; in handleExecutionPhase()
245 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleStopWithFlushPhase()
246 if (mStatus != Status::SUCCESS) { in handleStopWithFlushPhase()
254 mStatus = static_cast<Status>(static_cast<int>(response.code())); in handleStopWithFlushPhase()
257 if (mStatus == Status::SUCCESS) { in handleStopWithFlushPhase()
261 return mStatus; in handleStopWithFlushPhase()
288 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleStopImmediatePhase()
289 if (mStatus != Status::SUCCESS) { in handleStopImmediatePhase()
294 mStatus = static_cast<Status>(static_cast<int>(response.code())); in handleStopImmediatePhase()
300 if (mStatus == Status::SUCCESS) { in handleStopImmediatePhase()
303 return mStatus; in handleStopImmediatePhase()
328 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in handleResetPhase()
329 if (mStatus != Status::SUCCESS) { in handleResetPhase()
334 mStatus = static_cast<Status>(static_cast<int>(response.code())); in handleResetPhase()
338 return mStatus; in handleResetPhase()
369 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in StartGraphProfiling()
370 if (mStatus != Status::SUCCESS) { in StartGraphProfiling()
375 mStatus = static_cast<Status>(static_cast<int>(response.code())); in StartGraphProfiling()
378 return mStatus; in StartGraphProfiling()
393 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in StopGraphProfiling()
394 if (mStatus != Status::SUCCESS) { in StopGraphProfiling()
399 mStatus = static_cast<Status>(static_cast<int>(response.code())); in StopGraphProfiling()
402 return mStatus; in StopGraphProfiling()
416 auto [mStatus, mErrorMessage] = FinishRpcAndGetResult(rpc.get(), &cq, &response); in GetDebugInfo()
417 if (mStatus != Status::SUCCESS) { in GetDebugInfo()
445 mStatus = status; in dispatchGraphTerminationMessage()
450 engineInterface->DispatchGraphTerminationMessage(mStatus, std::move(errorMessageTmp)); in dispatchGraphTerminationMessage()