| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_remote_master.cc | 44 Status CreateSession(CallOptions* call_options, in CreateSession() argument
47 return CallWithRetry(call_options, request, response, in CreateSession()
51 Status ExtendSession(CallOptions* call_options, in ExtendSession() argument
54 return CallWithRetry(call_options, request, response, in ExtendSession()
58 Status PartialRunSetup(CallOptions* call_options, in PartialRunSetup() argument
61 return CallWithRetry(call_options, request, response, in PartialRunSetup()
65 Status RunStep(CallOptions* call_options, RunStepRequestWrapper* request, in RunStep() argument
67 return CallWithRetry(call_options, &request->ToProto(), in RunStep()
72 Status CloseSession(CallOptions* call_options, in CloseSession() argument
75 return CallWithRetry(call_options, request, response, in CloseSession()
[all …]
|
| D | grpc_session.cc | 111 Status GrpcSession::CreateImpl(CallOptions* call_options, in CreateImpl() argument
125 Status s = master_->CreateSession(call_options, &req, &resp); in CreateImpl()
133 CallOptions call_options; in Create() local
134 call_options.SetTimeout(options_.config.operation_timeout_in_ms()); in Create()
135 return CreateImpl(&call_options, graph); in Create()
140 CallOptions call_options; in Create() local
141 call_options.SetTimeout(run_options.timeout_in_ms()); in Create()
142 return CreateImpl(&call_options, graph); in Create()
145 Status GrpcSession::ExtendImpl(CallOptions* call_options, in ExtendImpl() argument
162 Status s = master_->ExtendSession(call_options, &req, &resp); in ExtendImpl()
[all …]
|
| D | grpc_session.h | 133 Status RunProto(CallOptions* call_options, MutableRunStepRequestWrapper* req,
137 Status CreateImpl(CallOptions* call_options, const GraphDef& graph);
138 Status ExtendImpl(CallOptions* call_options, const GraphDef& graph);
|
| D | BUILD | 73 "//tensorflow/core/distributed_runtime:call_options",
224 "//tensorflow/core/distributed_runtime:call_options",
406 "//tensorflow/core/distributed_runtime:call_options",
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | local_master.cc | 26 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 …]
|
| D | master_interface.h | 36 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 …]
|
| 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,
74 Status MakeCallable(CallOptions* call_options,
77 Status RunCallable(CallOptions* call_options,
80 Status ReleaseCallable(CallOptions* call_options,
|
| D | cluster_function_library_runtime.cc | 204 CallOptions* call_options = new CallOptions(); in Run() local
206 call_options, req, resp, in Run()
207 [call_options, req, resp, rets, recv_keys, done](const Status& status) { in Run()
210 delete call_options; in Run()
224 delete call_options; in Run()
235 delete call_options; in Run()
242 delete call_options; in Run()
|
| D | BUILD | 183 ":call_options",
212 name = "call_options",
213 srcs = ["call_options.cc"],
214 hdrs = ["call_options.h"],
225 ":call_options",
235 ":call_options",
298 ":call_options",
311 ":call_options",
334 ":call_options",
559 ":call_options",
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| D | grpc_verbs_client.cc | 24 Status GrpcVerbsClient::GetRemoteAddress(CallOptions* call_options, in GetRemoteAddress() argument
29 SetDeadline(&ctx, call_options->GetTimeout()); in GetRemoteAddress()
35 CallOptions call_options; in GetRemoteAddress() local
36 call_options.SetTimeout(-1); // no time out in GetRemoteAddress()
37 return GetRemoteAddress(&call_options, request, response); in GetRemoteAddress()
|
| D | grpc_verbs_client.h | 34 Status GetRemoteAddress(CallOptions* call_options,
|
| D | BUILD | 84 "//tensorflow/core/distributed_runtime:call_options",
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _beta_features_test.py | 189 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)
|