| /external/tensorflow/tensorflow/python/training/ |
| queue_runner_impl.py | 56 def __init__(self, queue=None, enqueue_ops=None, close_op=None,
73 close_op: Op to close the queue. Pending enqueue ops are preserved.
105 close_op=close_op, cancel_op=cancel_op,
115 def _init_from_args(self, queue=None, enqueue_ops=None, close_op=None,
122 close_op: Op to close the queue. Pending enqueue ops are preserved.
137 self._close_op = close_op
198 def close_op(self): member in class:QueueRunner
262 # Intentionally ignore errors from close_op.
372 self.close_op.name, export_scope
[all...] |
| queue_runner_test.py | 320 close_op = control_flow_ops.no_op(name="close")
324 close_op,
333 self.assertEqual(close_op, qr0_recon.close_op)
346 self.assertEqual(close_op, qr0_legacy_recon.close_op)
|
| /external/tensorflow/tensorflow/python/kernel_tests/random/ |
| random_shuffle_queue_test.py | 640 close_op = q.close()
644 close_op.run()
660 close_op = q.close()
687 close_op.run()
695 close_op = q.close()
709 # The close_op should run after the dequeue_thread has blocked.
713 close_op.run()
722 close_op = q.close()
741 # The close_op should run after the dequeue_thread has blocked.
749 close_op.run(
[all...] |
| /external/tensorflow/tensorflow/python/estimator/inputs/queues/ |
| feeding_queue_runner.py | 32 def __init__(self, queue=None, enqueue_ops=None, close_op=None,
44 close_op: Op to close the queue. Pending enqueue ops are preserved.
61 queue, enqueue_ops, close_op,
104 # Intentionally ignore errors from close_op.
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| fifo_queue_test.py | 559 close_op = q.close()
563 close_op.run()
621 close_op = q.close()
643 close_op.run()
765 close_op = q.close()
769 close_op.run()
783 close_op = q.close()
798 # The close_op should run after the dequeue_thread has blocked.
801 close_op.run()
807 close_op = q.close(
[all...] |
| padding_fifo_queue_test.py | 673 close_op = q.close()
677 close_op.run()
735 close_op = q.close()
757 close_op.run()
[all...] |
| barrier_ops_test.py | 147 close_op = b.close()
152 close_op.run()
389 close_op = b.close()
399 close_op.run()
520 close_op = b.close(cancel_pending_enqueues=cancel)
559 close_op.run()
593 close_op = b.close(cancel_pending_enqueues=cancel)
658 close_op.run()
|
| /external/tensorflow/tensorflow/contrib/training/python/training/ |
| bucket_ops.py | 271 close_op=top_queue.close(),
279 close_op=control_flow_ops.group(
|
| /external/tensorflow/tensorflow/python/data/kernel_tests/ |
| map_dataset_op_test.py | 296 close_op = queue.close()
304 sess.run(close_op)
319 close_op = queue.close()
329 sess.run(close_op)
|
| /external/tensorflow/tensorflow/cc/training/ |
| queue_runner_test.cc | 85 const std::string& close_op, const std::string& cancel_op,
92 *queue_runner_def.mutable_close_op_name() = close_op;
|
