| /external/tensorflow/tensorflow/compiler/tests/ |
| D | fifo_queue_test.py | 76 enqueue_ops = [q.enqueue((x,)) for x in elems]
84 self.checkedThread(target=enqueue, args=(e,)) for e in enqueue_ops
101 enqueue_ops = [q.enqueue((x,)) for x in elems]
105 for enqueue_op in enqueue_ops:
114 threads = [self.checkedThread(target=dequeue) for _ in enqueue_ops]
125 enqueue_ops = [q.enqueue((x,)) for x in elems]
128 for enqueue_op in enqueue_ops:
139 enqueue_ops = [q.enqueue((x,)) for x in elems]
146 for enqueue_op in enqueue_ops:
169 enqueue_ops = [q.enqueue((x, y)) for x, y in elems]
[all …]
|
| /external/tensorflow/tensorflow/python/training/ |
| D | queue_runner_impl.py | 61 def __init__(self, queue=None, enqueue_ops=None, close_op=None, argument
103 if queue or enqueue_ops:
109 queue=queue, enqueue_ops=enqueue_ops,
120 def _init_from_args(self, queue=None, enqueue_ops=None, close_op=None, argument
138 if not queue or not enqueue_ops:
141 self._enqueue_ops = enqueue_ops
199 def enqueue_ops(self): member in QueueRunner
373 for enqueue_op in self.enqueue_ops:
|
| D | queue_runner_test.py | 333 self.assertEqual(1, len(qr0_recon.enqueue_ops))
334 self.assertEqual(enqueue_op, qr0_recon.enqueue_ops[0])
346 self.assertEqual(1, len(qr0_legacy_recon.enqueue_ops))
347 self.assertEqual(enqueue_op, qr0_legacy_recon.enqueue_ops[0])
|
| D | input.py | 728 enqueue_ops = [enqueue_fn(_select_which_to_enqueue(x, keep_input))
731 enqueue_ops = [utils.smart_cond(
735 queue_runner.add_queue_runner(queue_runner.QueueRunner(queue, enqueue_ops))
745 enqueue_ops = [
748 enqueue_ops = [utils.smart_cond(
752 queue_runner.add_queue_runner(queue_runner.QueueRunner(queue, enqueue_ops))
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | priority_queue_test.py | 83 enqueue_ops = [
96 target=enqueue, args=(op,)) for op in enqueue_ops
134 enqueue_ops = [
155 target=enqueue, args=(op,)) for op in enqueue_ops
187 enqueue_ops = [
211 target=enqueue, args=(op,)) for op in enqueue_ops
245 enqueue_ops = [
260 target=enqueue, args=(op,)) for op in enqueue_ops
|
| D | padding_fifo_queue_test.py | 129 enqueue_ops = [q.enqueue((x,)) for x in elems]
138 target=enqueue, args=(e,)) for e in enqueue_ops
158 enqueue_ops = [q.enqueue((x,)) for x in elems]
162 for enqueue_op in enqueue_ops:
171 threads = [self.checkedThread(target=dequeue) for _ in enqueue_ops]
182 enqueue_ops = [q.enqueue((x,)) for x in elems]
185 for enqueue_op in enqueue_ops:
199 enqueue_ops = [q.enqueue((x,)) for x in elems]
206 for enqueue_op in enqueue_ops:
231 enqueue_ops = [q.enqueue((x, y)) for x, y in elems]
[all …]
|
| D | fifo_queue_test.py | 782 enqueue_ops = [q.enqueue((x,)) for x in elems]
791 target=enqueue, args=(e,)) for e in enqueue_ops
811 enqueue_ops = [q.enqueue((x,)) for x in elems]
815 for enqueue_op in enqueue_ops:
824 threads = [self.checkedThread(target=dequeue) for _ in enqueue_ops]
838 enqueue_ops = [q.enqueue((x,)) for x in elems]
845 for enqueue_op in enqueue_ops:
|
| D | metrics_test.py | 1399 def _enqueue_as_batches(x, enqueue_ops): argument
1404 enqueue_ops[i].append(x_queue.enqueue(x_batches[i, :]))
1412 enqueue_ops = [[] for i in range(num_batches)]
1413 tf_predictions = _enqueue_as_batches(predictions, enqueue_ops)
1414 tf_labels = _enqueue_as_batches(labels, enqueue_ops)
1415 tf_weights = (_enqueue_as_batches(weights, enqueue_ops) if
1419 sess.run(enqueue_ops[i])
|
| /external/tensorflow/tensorflow/tools/api/golden/v1/ |
| D | tensorflow.train.queue_runner.-queue-runner.pbtxt | 14 name: "enqueue_ops"
35 …argspec: "args=[\'self\', \'queue\', \'enqueue_ops\', \'close_op\', \'cancel_op\', \'queue_closed_…
|
| D | tensorflow.train.-queue-runner.pbtxt | 14 name: "enqueue_ops"
35 …argspec: "args=[\'self\', \'queue\', \'enqueue_ops\', \'close_op\', \'cancel_op\', \'queue_closed_…
|
| /external/tensorflow/tensorflow/core/grappler/ |
| D | grappler_item.cc | 77 std::vector<string> enqueue_ops; in EnqueueOpsFanin() local
80 enqueue_ops.push_back(enqueue_op); in EnqueueOpsFanin()
|
| /external/tensorflow/tensorflow/python/kernel_tests/random/ |
| D | random_shuffle_queue_test.py | 105 enqueue_ops = [q.enqueue((x,)) for x in elems]
114 target=enqueue, args=(e,)) for e in enqueue_ops
131 enqueue_ops = [q.enqueue((x,)) for x in elems]
135 for enqueue_op in enqueue_ops:
144 threads = [self.checkedThread(target=dequeue) for _ in enqueue_ops]
155 enqueue_ops = [q.enqueue((x,)) for x in elems]
158 for enqueue_op in enqueue_ops:
168 enqueue_ops = [q.enqueue((x,)) for x in elems]
175 for enqueue_op in enqueue_ops:
198 enqueue_ops = [q.enqueue((x, y)) for x, y in elems]
[all …]
|
| /external/tensorflow/tensorflow/python/grappler/ |
| D | item_wrapper.cc | 160 std::vector<const tensorflow::NodeDef*> enqueue_ops = in PYBIND11_MODULE() local
166 for (auto op : enqueue_ops) { in PYBIND11_MODULE()
|
| /external/tensorflow/tensorflow/python/tpu/ |
| D | tpu_feed.py | 859 enqueue_ops = []
895 enqueue_ops.append(
902 return enqueue_ops
|
| D | tpu_embedding_v2.py | 1298 enqueue_ops = []
1317 enqueue_ops.append(enqueue_op)
1318 ops.get_default_graph().control_outputs.extend(enqueue_ops)
|
| /external/tensorflow/tensorflow/cc/training/ |
| D | queue_runner_test.cc | 84 const std::string& queue_name, const std::vector<std::string>& enqueue_ops, in BuildQueueRunnerDef() argument
89 for (const std::string& enqueue_op : enqueue_ops) { in BuildQueueRunnerDef()
|