Home
last modified time | relevance | path

Searched refs:call_options (Results 1 – 15 of 15) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_remote_master.cc47 Status CreateSession(CallOptions* call_options, in CreateSession() argument
50 return CallWithRetry(call_options, request, response, in CreateSession()
54 Status ExtendSession(CallOptions* call_options, in ExtendSession() argument
57 return CallWithRetry(call_options, request, response, in ExtendSession()
61 Status PartialRunSetup(CallOptions* call_options, in PartialRunSetup() argument
64 return CallWithRetry(call_options, request, response, in PartialRunSetup()
68 Status RunStep(CallOptions* call_options, RunStepRequestWrapper* request, in RunStep() argument
70 return CallWithRetry(call_options, &request->ToProto(), in RunStep()
75 Status CloseSession(CallOptions* call_options, in CloseSession() argument
78 return CallWithRetry(call_options, request, response, in CloseSession()
[all …]
Dgrpc_session.cc114 Status GrpcSession::CreateImpl(CallOptions* call_options, GraphDef graph) { in CreateImpl() argument
127 Status s = master_->CreateSession(call_options, &req, &resp); in CreateImpl()
144 CallOptions call_options; in Create() local
145 call_options.SetTimeout(options_.config.operation_timeout_in_ms()); in Create()
146 return CreateImpl(&call_options, std::move(graph)); in Create()
150 CallOptions call_options; in Create() local
151 call_options.SetTimeout(run_options.timeout_in_ms()); in Create()
152 return CreateImpl(&call_options, std::move(graph)); in Create()
155 Status GrpcSession::ExtendImpl(CallOptions* call_options, GraphDef graph) { in ExtendImpl() argument
171 Status s = master_->ExtendSession(call_options, &req, &resp); in ExtendImpl()
[all …]
Dgrpc_session.h139 Status RunProto(CallOptions* call_options, MutableRunStepRequestWrapper* req,
143 Status CreateImpl(CallOptions* call_options, GraphDef graph);
144 Status ExtendImpl(CallOptions* call_options, GraphDef graph);
DBUILD77 "//tensorflow/core/distributed_runtime:call_options",
97 "//tensorflow/core/distributed_runtime:call_options",
253 "//tensorflow/core/distributed_runtime:call_options",
450 "//tensorflow/core/distributed_runtime:call_options",
/external/tensorflow/tensorflow/core/distributed_runtime/
Dlocal_master.cc26 Status WaitForNotification(CallOptions* call_options, in WaitForNotification() argument
28 int64 timeout_in_ms = call_options->GetTimeout(); in WaitForNotification()
36 call_options->StartCancel(); in WaitForNotification()
53 Status LocalMaster::CreateSession(CallOptions* call_options, in CreateSession() argument
63 WaitForNotification(call_options, default_timeout_in_ms_, &n)); in CreateSession()
67 Status LocalMaster::ExtendSession(CallOptions* call_options, in ExtendSession() argument
77 WaitForNotification(call_options, default_timeout_in_ms_, &n)); in ExtendSession()
81 Status LocalMaster::PartialRunSetup(CallOptions* call_options, in PartialRunSetup() argument
91 WaitForNotification(call_options, default_timeout_in_ms_, &n)); in PartialRunSetup()
95 Status LocalMaster::RunStep(CallOptions* call_options, in RunStep() argument
[all …]
Dmaster_interface.h36 virtual Status CreateSession(CallOptions* call_options,
40 virtual Status ExtendSession(CallOptions* call_options,
44 virtual Status PartialRunSetup(CallOptions* call_options, in PartialRunSetup() argument
50 virtual Status RunStep(CallOptions* call_options,
54 virtual Status RunStep(CallOptions* call_options, in RunStep() argument
61 return RunStep(call_options, wrapped_request.get(), wrapped_response.get()); in RunStep()
84 virtual Status CloseSession(CallOptions* call_options,
88 virtual Status ListDevices(CallOptions* call_options,
92 virtual Status Reset(CallOptions* call_options, const ResetRequest* request,
95 virtual Status MakeCallable(CallOptions* call_options,
[all …]
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,
74 Status MakeCallable(CallOptions* call_options,
77 Status RunCallable(CallOptions* call_options,
80 Status ReleaseCallable(CallOptions* call_options,
DBUILD194 ":call_options",
224 name = "call_options",
225 srcs = ["call_options.cc"],
226 hdrs = ["call_options.h"],
237 ":call_options",
248 ":call_options",
309 ":call_options",
322 ":call_options",
345 ":call_options",
535 ":call_options",
[all …]
Dcluster_function_library_runtime.cc293 CallOptions* call_options = new CallOptions(); in Run() local
295 call_options, req, resp, in Run()
296 [call_options, req, resp, rets, recv_keys, done](const Status& status) { in Run()
299 gtl::MakeCleanup([call_options, req, resp, local_status, done] { in Run()
301 delete call_options; in Run()
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/
D_beta_features_test.py189 call_options = interfaces.grpc_call_options(
194 protocol_options=call_options)
206 call_options = interfaces.grpc_call_options(
211 protocol_options=call_options)
223 call_options = interfaces.grpc_call_options(
229 protocol_options=call_options)
246 call_options = interfaces.grpc_call_options(
252 protocol_options=call_options)
320 call_options = interfaces.grpc_call_options(
325 protocol_options=call_options)
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
DBUILD49 "//tensorflow/core/distributed_runtime:call_options",
76 "//tensorflow/core/distributed_runtime:call_options",
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
DBUILD31 "//tensorflow/core/distributed_runtime:call_options",
/external/tensorflow/tensorflow/python/autograph/core/
Dfunction_wrappers.py54 self.callopts = options.call_options()
Dconverter.py187 def call_options(self): member in ConversionOptions
/external/tensorflow/tensorflow/python/autograph/converters/
Dfunctions.py51 return self.ctx.user.options.call_options()