Searched refs:ToGrpcStatus (Results 1 – 10 of 10) sorted by relevance
87 return ToGrpcStatus(xla::InvalidArgument("Invalid protocol version %d", in Connect()94 return ToGrpcStatus(tensorflow::errors::Aborted( in Connect()100 return ToGrpcStatus(status); in Connect()119 return ToGrpcStatus(tensorflow::errors::DeadlineExceeded( in Connect()136 return ToGrpcStatus( in Connect()163 return ToGrpcStatus(status); in Shutdown()168 return ToGrpcStatus(service_status_); in Shutdown()170 return ToGrpcStatus(xla::FailedPrecondition( in Shutdown()176 return ToGrpcStatus(status); in Shutdown()187 return ToGrpcStatus(tensorflow::errors::DeadlineExceeded( in Shutdown()[all …]
33 inline ::grpc::Status ToGrpcStatus(const Status& s) { in ToGrpcStatus() function
157 call->SendResponse(ToGrpcStatus(status)); in CreateSessionHandler()168 call->SendResponse(ToGrpcStatus(status)); in ExtendSessionHandler()178 call->SendResponse(ToGrpcStatus(status)); in PartialRunSetupHandler()207 call->SendResponse(ToGrpcStatus(Status::OK())); in RunStepHandler()209 call->SendResponse(ToGrpcStatus(status)); in RunStepHandler()220 call->SendResponse(ToGrpcStatus(status)); in CloseSessionHandler()230 call->SendResponse(ToGrpcStatus(status)); in ListDevicesHandler()239 call->SendResponse(ToGrpcStatus(status)); in ResetHandler()249 call->SendResponse(ToGrpcStatus(status)); in MakeCallableHandler()269 call->SendResponse(ToGrpcStatus(status)); in RunCallableHandler()[all …]
199 call->SendResponse(ToGrpcStatus(s)); \227 call->SendResponse(ToGrpcStatus(s)); in GetStepSequenceHandler()260 call->SendResponse(ToGrpcStatus(s)); in RunGraphHandler()280 call->SendResponse(ToGrpcStatus(s)); in RecvTensorHandlerRaw()297 call->SendResponse(ToGrpcStatus(s)); in RecvBufHandler()316 call->SendResponse(ToGrpcStatus(s)); in CompleteGroupHandler()335 call->SendResponse(ToGrpcStatus(s)); in CompleteInstanceHandler()
97 inline ::grpc::Status ToGrpcStatus(const ::tensorflow::Status& s) { in ToGrpcStatus() function
59 ToGrpcStatus(local_impl_.method(&call->request, &call->response))); \78 call->SendResponse(ToGrpcStatus(local_impl_.Enqueue( in EnqueueHandler()99 call->SendResponse(ToGrpcStatus(s)); in RunComponentFunctionHandler()142 call->Finish(ToGrpcStatus(status)); in StreamingEnqueueHandler()
110 return call->SendResponse(ToGrpcStatus(s)); in GetTpuProgram()135 return call->SendResponse(ToGrpcStatus(buffer_slices.status())); in GetTpuProgram()
43 return ToGrpcStatus(impl_.method(request, response)); \
41 return ToGrpcStatus(impl_.method(request, response)); \
32 return tensorflow::ToGrpcStatus(s); in DelegateRPC()