| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_remote_master.cc | 126 int64 timeout_in_ms = call_options->GetTimeout(); local
128 if (timeout_in_ms > 0) {
129 expired_time_micros += (timeout_in_ms / 1000.);
139 if (timeout_in_ms > 0) {
147 ctx.set_deadline(gpr_time_from_millis(timeout_in_ms, GPR_TIMESPAN));
169 (timeout_in_ms <= 0 ||
175 timeout_in_ms > 0) {
|
| D | grpc_rpc_factory_registration.cc | 26 int64 timeout_in_ms) { in Function()
27 return new GrpcRPCFactory(ctx, fail_fast, timeout_in_ms); in Function()
|
| D | grpc_state.h | 54 thread::ThreadPool* threadpool, bool fail_fast, int64 timeout_in_ms, in RPCState() argument
63 timeout_in_ms_(timeout_in_ms), in RPCState()
|
| D | grpc_session.cc | 141 call_options.SetTimeout(run_options.timeout_in_ms()); in Create()
178 call_options.SetTimeout(run_options.timeout_in_ms()); in Extend()
196 if (run_options.timeout_in_ms() == 0) { in RunHelper()
226 call_options.SetTimeout(req->options().timeout_in_ms()); in RunHelper()
|
| D | grpc_rpc_factory.cc | 81 int64 timeout_in_ms) in GrpcRPCFactory() argument
82 : RPCFactory(), fail_fast_(fail_fast), timeout_in_ms_(timeout_in_ms) { in GrpcRPCFactory()
|
| D | grpc_rpc_factory.h | 36 int64 timeout_in_ms);
|
| D | grpc_master_service.cc | 187 if (call->request.options().timeout_in_ms() > 0) { in RunStepHandler()
188 call_opts->SetTimeout(call->request.options().timeout_in_ms()); in RunStepHandler()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | local_master.cc | 28 int64 timeout_in_ms = call_options->GetTimeout(); in WaitForNotification() local
29 if (timeout_in_ms == 0) { in WaitForNotification()
30 timeout_in_ms = default_timeout_in_ms; in WaitForNotification()
32 if (timeout_in_ms > 0) { in WaitForNotification()
33 int64 timeout_in_us = timeout_in_ms * 1000; in WaitForNotification()
|
| D | message_wrappers_test.cc | 69 EXPECT_EQ(37, request.options().timeout_in_ms()); in CheckRunStepRequest()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | rpc_op.cc | 47 int64 timeout_in_ms; in RpcOp() local
48 OP_REQUIRES_OK(context, context->GetAttr("timeout_in_ms", &timeout_in_ms)); in RpcOp()
56 rpc_factory_.reset((*rpc_factory_fn)(context, fail_fast, timeout_in_ms)); in RpcOp()
|
| /external/tensorflow/tensorflow/python/tpu/ |
| D | session_support.py | 106 def ping(self, request=None, timeout_in_ms=5000): argument
111 options = config_pb2.RunOptions(timeout_in_ms=timeout_in_ms)
418 self.timeout_in_ms = timeout_ms
421 lame_workers.shutdown(timeout_ms=self.timeout_in_ms)
|
| /external/webrtc/webrtc/p2p/base/ |
| D | tcpport.h | 136 void set_reconnection_timeout(int timeout_in_ms) { in set_reconnection_timeout() argument
137 reconnection_timeout_ = timeout_in_ms; in set_reconnection_timeout()
|
| /external/tensorflow/tensorflow/core/util/rpc/ |
| D | rpc_factory_registry_test.cc | 24 int64 timeout_in_ms) { in Function()
|
| D | rpc_factory_registry.h | 30 int64 timeout_in_ms)>
|
| /external/tensorflow/tensorflow/core/api_def/base_api/ |
| D | api_def_Rpc.pbtxt | 48 name: "timeout_in_ms"
53 the RPC takes longer than `timeout_in_ms`.
|
| D | api_def_TryRpc.pbtxt | 61 name: "timeout_in_ms"
66 the RPC takes longer than `timeout_in_ms`.
|
| /external/tensorflow/tensorflow/contrib/rpc/python/kernel_tests/ |
| D | rpc_op_test_base.py | 253 options = config_pb2.RunOptions(timeout_in_ms=timeout_ms)
264 timeout_in_ms=1000,
273 timeout_in_ms=1000,
|
| /external/tensorflow/tensorflow/tools/api/golden/v1/ |
| D | tensorflow.-run-options.pbtxt | 13 name: "timeout_in_ms"
|
| /external/tensorflow/tensorflow/core/grappler/ |
| D | utils.cc | 192 bool ExecuteWithTimeout(std::function<void()> fn, const int64 timeout_in_ms, in ExecuteWithTimeout() argument
194 if (timeout_in_ms <= 0) { in ExecuteWithTimeout()
204 WaitForNotificationWithTimeout(done.get(), timeout_in_ms * 1000); in ExecuteWithTimeout()
|
| D | utils.h | 231 bool ExecuteWithTimeout(std::function<void()> fn, int64 timeout_in_ms,
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | direct_session.h | 286 int64 timeout_in_ms);
288 int64 timeout_in_ms);
|
| D | direct_session.cc | 658 run_options.timeout_in_ms() > 0 in RunInternal()
659 ? run_options.timeout_in_ms() in RunInternal()
1689 int64 timeout_in_ms) { in WaitForNotification() argument
1691 WaitForNotification(&run_state->executors_done, timeout_in_ms); in WaitForNotification()
1706 Notification* notification, int64 timeout_in_ms) { in WaitForNotification() argument
1707 if (timeout_in_ms > 0) { in WaitForNotification()
1708 const int64 timeout_in_us = timeout_in_ms * 1000; in WaitForNotification()
|
| /external/tensorflow/tensorflow/python/training/ |
| D | monitored_session.py | 1459 options.timeout_in_ms = max(options.timeout_in_ms,
1460 incoming_options.timeout_in_ms)
|
| D | server_lib_test.py | 222 sess.run(blocking_t, options=config_pb2.RunOptions(timeout_in_ms=1000))
226 sess.run(blocking_t, options=config_pb2.RunOptions(timeout_in_ms=1000))
|
| D | monitored_session_test.py | 1393 def __init__(self, trace_level, timeout_in_ms, output_partition_graphs, argument
1396 self._timeout_in_ms = timeout_in_ms
1408 timeout_in_ms=self._timeout_in_ms,
1798 timeout_in_ms=60000,
1830 timeout_in_ms=30000,
1846 timeout_in_ms=60000,
|