Searched refs:call_options (Results 1 - 9 of 9) sorted by relevance

/external/tensorflow/tensorflow/contrib/verbs/
H A Dgrpc_verbs_client.cc24 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 Dgrpc_verbs_client.h21 #include "tensorflow/core/distributed_runtime/call_options.h"
34 Status GetRemoteAddress(CallOptions* call_options,
/external/tensorflow/tensorflow/core/distributed_runtime/
H A Dmaster_interface.h19 #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 Dlocal_master.h43 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 Dlocal_master.cc26 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 Dcluster_function_library_runtime.cc197 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 Dgrpc_remote_master.cc20 #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 Dgrpc_session.cc21 #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 Dgrpc_session.h23 #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);

Completed in 266 milliseconds