Searched refs:deadline_micros (Results 1 – 6 of 6) sorted by relevance
/external/tensorflow/tensorflow/core/common_runtime/ |
D | allocator_retry.cc | 60 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/ |
D | grpc_util.cc | 41 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()
|
D | grpc_util.h | 37 int64 deadline_micros);
|
/external/tensorflow/tensorflow/core/kernels/data/experimental/ |
D | data_service_ops.cc | 63 int64 deadline_micros = EnvTime::NowMicros() + kRetryTimeoutMicros; in Compute() local 69 deadline_micros)); in Compute()
|
D | data_service_dataset_op.cc | 265 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/ |
D | batch_kernels.cc | 612 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
|