| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_rpc_factory_registration.cc | 26 int64 timeout_in_ms) {
27 return new GrpcRPCFactory(ctx, fail_fast, timeout_in_ms);
|
| 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) {
176 // If timeout_in_ms is set, exit the retry loop on timeout.
|
| grpc_rpc_factory.h | 36 int64 timeout_in_ms);
|
| grpc_state.h | 48 /*timeout_in_ms=*/0, max_retries) {}
54 thread::ThreadPool* threadpool, bool fail_fast, int64 timeout_in_ms,
63 timeout_in_ms_(timeout_in_ms),
|
| grpc_master_service.cc | 187 if (call->request.options().timeout_in_ms() > 0) {
188 call_opts->SetTimeout(call->request.options().timeout_in_ms());
|
| grpc_rpc_factory.cc | 81 int64 timeout_in_ms)
82 : RPCFactory(), fail_fast_(fail_fast), timeout_in_ms_(timeout_in_ms) {
|
| grpc_session.cc | 141 call_options.SetTimeout(run_options.timeout_in_ms());
178 call_options.SetTimeout(run_options.timeout_in_ms());
196 if (run_options.timeout_in_ms() == 0) {
226 call_options.SetTimeout(req->options().timeout_in_ms());
|
| /external/tensorflow/tensorflow/core/util/rpc/ |
| rpc_factory_registry_test.cc | 24 int64 timeout_in_ms) {
|
| rpc_factory_registry.h | 30 int64 timeout_in_ms)>
|
| /external/tensorflow/tensorflow/core/kernels/ |
| rpc_op.cc | 47 int64 timeout_in_ms; local
48 OP_REQUIRES_OK(context, context->GetAttr("timeout_in_ms", &timeout_in_ms));
56 rpc_factory_.reset((*rpc_factory_fn)(context, fail_fast, timeout_in_ms));
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| local_master.cc | 28 int64 timeout_in_ms = call_options->GetTimeout(); local
29 if (timeout_in_ms == 0) {
30 timeout_in_ms = default_timeout_in_ms;
32 if (timeout_in_ms > 0) {
33 int64 timeout_in_us = timeout_in_ms * 1000;
|
| message_wrappers_test.cc | 69 EXPECT_EQ(37, request.options().timeout_in_ms());
|
| master_session.cc | [all...] |
| /external/webrtc/webrtc/p2p/base/ |
| tcpport.h | 136 void set_reconnection_timeout(int timeout_in_ms) {
137 reconnection_timeout_ = timeout_in_ms;
|
| /external/tensorflow/tensorflow/python/tpu/ |
| session_support.py | 106 def ping(self, request=None, timeout_in_ms=5000):
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/tensorflow/tensorflow/contrib/rpc/python/kernel_tests/ |
| 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/core/grappler/ |
| utils.cc | 192 bool ExecuteWithTimeout(std::function<void()> fn, const int64 timeout_in_ms,
194 if (timeout_in_ms <= 0) {
204 WaitForNotificationWithTimeout(done.get(), timeout_in_ms * 1000);
|
| utils.h | 231 bool ExecuteWithTimeout(std::function<void()> fn, int64 timeout_in_ms,
|
| /art/openjdkjvmti/ |
| ti_monitor.cc | 145 bool Wait(art::Thread* self, uint64_t timeout_in_ms) {
147 cond_.wait_for(lk, std::chrono::milliseconds(timeout_in_ms));
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| direct_session.h | 286 int64 timeout_in_ms);
288 int64 timeout_in_ms);
|
| direct_session.cc | 658 run_options.timeout_in_ms() > 0
659 ? run_options.timeout_in_ms()
[all...] |
| /external/tensorflow/tensorflow/python/training/ |
| monitored_session.py | [all...] |
| 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))
|
| monitored_session_test.py | [all...] |
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| fifo_queue_test.py | [all...] |
