Home
last modified time | relevance | path

Searched refs:deadline_micros (Results 1 – 6 of 6) sorted by relevance

/external/tensorflow/tensorflow/core/common_runtime/
Dallocator_retry.cc60 uint64 deadline_micros = 0; in AllocateRaw() local
68 deadline_micros = now + max_millis_to_wait * 1000; in AllocateRaw()
71 if (now < deadline_micros) { in AllocateRaw()
75 (deadline_micros - now) / 1000); in AllocateRaw()
/external/tensorflow/tensorflow/core/data/service/
Dgrpc_util.cc41 int64 deadline_micros) { in Retry() argument
49 if (now_micros > deadline_micros) { in Retry()
58 std::min(deadline_with_backoff_micros, deadline_micros); in Retry()
Dgrpc_util.h37 int64 deadline_micros);
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Ddata_service_ops.cc63 int64 deadline_micros = EnvTime::NowMicros() + kRetryTimeoutMicros; in Compute() local
69 deadline_micros)); in Compute()
Ddata_service_dataset_op.cc265 int64 deadline_micros = kint64max; in Initialize() local
281 deadline_micros)); in Initialize()
654 int64 deadline_micros = kint64max; in RunWorkerThread() local
657 s = GetElementTraced(task_to_process.get(), deadline_micros, in RunWorkerThread()
661 s = GetElementTraced(task_to_process.get(), deadline_micros, in RunWorkerThread()
723 Status GetElementTraced(Task* task, int64 deadline_micros, in GetElementTraced() argument
749 if (now_micros > deadline_micros) { in GetElementTraced()
753 deadline_micros, in GetElementTraced()
/external/tensorflow/tensorflow/core/kernels/
Dbatch_kernels.cc612 const uint64 deadline_micros = in Compute() local
618 WaitingCallback{deadline_micros, context, done}) in Compute()
639 WaitingTensor{deadline_micros, split_inputs[i]}) in Compute()
670 if (waiting_tensor.deadline_micros < now) { in EnforceTimeout()
680 if (waiting_callback.deadline_micros < now) { in EnforceTimeout()
697 uint64 deadline_micros; member
702 uint64 deadline_micros; member