Home
last modified time | relevance | path

Searched refs:already_cancelled (Results 1 – 10 of 10) sorted by relevance

/external/tensorflow/tensorflow/core/kernels/
Dfifo_queue.cc54 bool already_cancelled; in TryEnqueue() local
57 already_cancelled = !cm->RegisterCallback( in TryEnqueue()
59 if (!already_cancelled) { in TryEnqueue()
79 if (!already_cancelled) { in TryEnqueue()
112 bool already_cancelled; in TryEnqueueMany() local
115 already_cancelled = !cm->RegisterCallback( in TryEnqueueMany()
117 if (!already_cancelled) { in TryEnqueueMany()
147 if (!already_cancelled) { in TryEnqueueMany()
158 bool already_cancelled; in TryDequeue() local
161 already_cancelled = !cm->RegisterCallback( in TryDequeue()
[all …]
Dpriority_queue.cc75 bool already_cancelled; in TryEnqueue() local
78 already_cancelled = !cm->RegisterCallback( in TryEnqueue()
80 if (!already_cancelled) { in TryEnqueue()
108 if (!already_cancelled) { in TryEnqueue()
140 bool already_cancelled; in TryEnqueueMany() local
143 already_cancelled = !cm->RegisterCallback( in TryEnqueueMany()
145 if (!already_cancelled) { in TryEnqueueMany()
189 if (!already_cancelled) { in TryEnqueueMany()
201 bool already_cancelled; in TryDequeue() local
204 already_cancelled = !cm->RegisterCallback( in TryDequeue()
[all …]
Drandom_shuffle_queue_op.cc131 bool already_cancelled; in TryEnqueue() local
134 already_cancelled = !cm->RegisterCallback( in TryEnqueue()
136 if (!already_cancelled) { in TryEnqueue()
156 if (!already_cancelled) { in TryEnqueue()
189 bool already_cancelled; in TryEnqueueMany() local
192 already_cancelled = !cm->RegisterCallback( in TryEnqueueMany()
194 if (!already_cancelled) { in TryEnqueueMany()
224 if (!already_cancelled) { in TryEnqueueMany()
236 bool already_cancelled; in TryDequeue() local
239 already_cancelled = !cm->RegisterCallback( in TryDequeue()
[all …]
Dconditional_accumulator_base.cc74 bool already_cancelled; in TryTakeGrad() local
77 already_cancelled = !cm->RegisterCallback( in TryTakeGrad()
79 if (!already_cancelled) { in TryTakeGrad()
98 if (!already_cancelled) { in TryTakeGrad()
Dpadding_fifo_queue.cc91 bool already_cancelled; in TryDequeueMany() local
94 already_cancelled = !cm->RegisterCallback( in TryDequeueMany()
96 if (!already_cancelled) { in TryDequeueMany()
230 if (!already_cancelled) { in TryDequeueMany()
Dmutex_ops.cc118 const bool already_cancelled = in AcquireAsync() local
124 if (already_cancelled) { in AcquireAsync()
Dcontrol_flow_ops.cc612 bool already_cancelled = cm->IsCancelled(); in Compute() local
613 OP_REQUIRES(context, !already_cancelled, in Compute()
/external/tensorflow/tensorflow/core/framework/
Dreader_op_kernel.h57 bool already_cancelled = in Compute() local
60 if (!already_cancelled) { in Compute()
/external/tensorflow/tensorflow/core/distributed_runtime/
Dworker.cc214 bool already_cancelled = !cancellation_manager_.RegisterCallback( in DoRunGraph() local
216 if (already_cancelled) { in DoRunGraph()
/external/tensorflow/tensorflow/core/common_runtime/
Ddirect_session.cc589 const bool already_cancelled = !cancellation_manager_->RegisterCallback( in RunInternal() local
593 if (already_cancelled) { in RunInternal()