/external/tensorflow/tensorflow/contrib/verbs/ |
H A D | grpc_verbs_client.cc | 24 Status GrpcVerbsClient::GetRemoteAddress(CallOptions* call_options, argument 29 SetDeadline(&ctx, call_options->GetTimeout()); 35 CallOptions call_options; local 36 call_options.SetTimeout(-1); // no time out 37 return GetRemoteAddress(&call_options, request, response);
|
H A D | grpc_verbs_client.h | 21 #include "tensorflow/core/distributed_runtime/call_options.h" 34 Status GetRemoteAddress(CallOptions* call_options,
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
H A D | master_interface.h | 19 #include "tensorflow/core/distributed_runtime/call_options.h" 35 virtual Status CreateSession(CallOptions* call_options, 39 virtual Status ExtendSession(CallOptions* call_options, 43 virtual Status PartialRunSetup(CallOptions* call_options, argument 49 virtual Status RunStep(CallOptions* call_options, 53 virtual Status RunStep(CallOptions* call_options, argument 60 return RunStep(call_options, wrapped_request.get(), wrapped_response.get()); 81 virtual Status CloseSession(CallOptions* call_options, 85 virtual Status ListDevices(CallOptions* call_options, 89 virtual Status Reset(CallOptions* call_options, cons [all...] |
H A D | local_master.h | 43 Status CreateSession(CallOptions* call_options, 47 Status ExtendSession(CallOptions* call_options, 51 Status PartialRunSetup(CallOptions* call_options, 55 Status RunStep(CallOptions* call_options, RunStepRequestWrapper* request, 62 Status CloseSession(CallOptions* call_options, 66 Status ListDevices(CallOptions* call_options, 71 Status Reset(CallOptions* call_options, const ResetRequest* request,
|
H A D | local_master.cc | 26 Status WaitForNotification(CallOptions* call_options, argument 28 int64 timeout_in_ms = call_options->GetTimeout(); 36 call_options->StartCancel(); 53 Status LocalMaster::CreateSession(CallOptions* call_options, argument 63 WaitForNotification(call_options, default_timeout_in_ms_, &n)); 67 Status LocalMaster::ExtendSession(CallOptions* call_options, argument 77 WaitForNotification(call_options, default_timeout_in_ms_, &n)); 81 Status LocalMaster::PartialRunSetup(CallOptions* call_options, argument 91 WaitForNotification(call_options, default_timeout_in_ms_, &n)); 95 Status LocalMaster::RunStep(CallOptions* call_options, argument 118 CloseSession(CallOptions* call_options, const CloseSessionRequest* request, CloseSessionResponse* response) argument 132 ListDevices(CallOptions* call_options, const ListDevicesRequest* request, ListDevicesResponse* response) argument 146 Reset(CallOptions* call_options, const ResetRequest* request, ResetResponse* response) argument [all...] |
H A D | cluster_function_library_runtime.cc | 197 CallOptions* call_options = new CallOptions(); local 199 call_options, &req, resp, 200 [call_options, resp, rets, recv_keys, done](const Status& status) { 203 delete call_options; 215 delete call_options; 224 delete call_options; 231 delete call_options;
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
H A D | grpc_remote_master.cc | 20 #include "tensorflow/core/distributed_runtime/call_options.h" 43 Status CreateSession(CallOptions* call_options, 47 return Call(&ctx, call_options, request, response, 51 Status ExtendSession(CallOptions* call_options, 55 return Call(&ctx, call_options, request, response, 59 Status PartialRunSetup(CallOptions* call_options, 63 return Call(&ctx, call_options, request, response, 67 Status RunStep(CallOptions* call_options, RunStepRequestWrapper* request, 71 return Call(&ctx, call_options, &request->ToProto(), 75 Status CloseSession(CallOptions* call_options, 114 Call(::grpc::ClientContext* ctx, CallOptions* call_options, const Request* request, Response* response, ::grpc::Status (MasterServiceStub::*pfunc)(::grpc::ClientContext*, const Request&, Response*)) argument [all...] |
H A D | grpc_session.cc | 21 #include "tensorflow/core/distributed_runtime/call_options.h" 93 Status GrpcSession::CreateImpl(CallOptions* call_options, argument 107 Status s = master_->CreateSession(call_options, &req, &resp); 117 CallOptions call_options; local 118 call_options.SetTimeout(options_.config.operation_timeout_in_ms()); 119 return CreateImpl(&call_options, graph); 124 CallOptions call_options; local 125 call_options.SetTimeout(run_options.timeout_in_ms()); 126 return CreateImpl(&call_options, graph); 129 Status GrpcSession::ExtendImpl(CallOptions* call_options, argument 154 CallOptions call_options; local 161 CallOptions call_options; local 209 CallOptions call_options; local 273 RunProto(CallOptions* call_options, MutableRunStepRequestWrapper* req, MutableRunStepResponseWrapper* resp) argument 294 CallOptions call_options; local 339 CallOptions call_options; local 362 CallOptions call_options; local 395 CallOptions call_options; local [all...] |
H A D | grpc_session.h | 23 #include "tensorflow/core/distributed_runtime/call_options.h" 121 Status RunProto(CallOptions* call_options, MutableRunStepRequestWrapper* req, 125 Status CreateImpl(CallOptions* call_options, const GraphDef& graph); 126 Status ExtendImpl(CallOptions* call_options, const GraphDef& graph);
|