Searched refs:FromGrpcStatus (Results 1 – 10 of 10) sorted by relevance
| /external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/ |
| D | client.cc | 97 VLOG(1) << "Connect failed() with status: " << FromGrpcStatus(status); in Connect()
99 LOG(INFO) << "Connect failed() with status: " << FromGrpcStatus(status); in Connect()
112 << "; most recent failure status: " << FromGrpcStatus(status); in Connect()
117 FromGrpcStatus(status).ToString())); in Connect()
155 return FromGrpcStatus(status); in EnumerateDevices()
180 LOG(INFO) << "Distributed task shutdown result: " << FromGrpcStatus(status); in Shutdown()
182 return FromGrpcStatus(status); in Shutdown()
214 return FromGrpcStatus(status); in BlockingKeyValueGet()
238 return FromGrpcStatus(status); in KeyValueSet()
274 options_.missed_heartbeat_callback(FromGrpcStatus(status), in HeartbeatLoop()
|
| D | util.h | 24 inline Status FromGrpcStatus(const ::grpc::Status& s) { in FromGrpcStatus() function
|
| /external/tensorflow/tensorflow/core/profiler/rpc/client/ |
| D | profiler_client.cc | 33 inline Status FromGrpcStatus(const ::grpc::Status& s) { in FromGrpcStatus() function
61 FromGrpcStatus(stub->Profile(&context, request, response))); in ProfileGrpc()
72 FromGrpcStatus(stub->NewSession(&context, request, response))); in NewSessionGrpc()
82 FromGrpcStatus(stub->Monitor(&context, request, response))); in MonitorGrpc()
150 status_on_completion_.Update(FromGrpcStatus(grpc_status_)); in WaitForCompletion()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | master_test.cc | 72 const Status s = FromGrpcStatus(master_->CreateSession(&ctx, req, &resp)); in CreateSession()
88 const Status s = FromGrpcStatus(master_->ExtendSession(&ctx, req, &resp)); in ExtendSession()
113 const Status s = FromGrpcStatus(master_->RunStep(&ctx, req, &resp)); in RunStep()
129 return FromGrpcStatus(master_->CloseSession(&ctx, req, &resp)); in CloseSession()
136 return FromGrpcStatus(master_->Reset(&ctx, req, &resp)); in Reset()
153 const Status s = FromGrpcStatus(master_->ListDevices(&ctx, req, &resp)); in TEST_F()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_state.h | 113 done_(FromGrpcStatus(s)); in RPCState()
145 Status s = FromGrpcStatus(status_); in OnCompleted()
437 Status status = FromGrpcStatus(s); in SendNextRequest()
538 Status s = FromGrpcStatus(call_status_); in CallFinished()
|
| D | grpc_util.h | 83 inline Status FromGrpcStatus(const ::grpc::Status& s) { in FromGrpcStatus() function
|
| D | grpc_remote_master.cc | 153 s = FromGrpcStatus((stub_.get()->*pfunc)(&ctx, *request, response));
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | grpc_util.cc | 34 Status s = FromGrpcStatus(status); in WrapError()
|
| /external/tensorflow/tensorflow/compiler/xla/rpc/ |
| D | grpc_stub.cc | 27 return tensorflow::FromGrpcStatus(s); in MakeRPC()
|
| /external/tensorflow/tensorflow/core/tpu/kernels/ |
| D | tpu_compilation_cache_rpc_lookup.cc | 157 FromGrpcStatus(stub_->GetTpuProgram(&client_context, request, &response)); in RemoteLookupLocked()
|