| /external/tensorflow/tensorflow/cc/training/ |
| D | queue_runner.cc | 22 Status QueueRunner::New(const QueueRunnerDef& queue_runner_def, in New()
23 std::unique_ptr<QueueRunner>* result) { in New()
24 result->reset(new QueueRunner()); in New()
28 Status QueueRunner::New(const QueueRunnerDef& queue_runner_def, in New()
30 std::unique_ptr<QueueRunner>* result) { in New()
31 result->reset(new QueueRunner()); in New()
36 void QueueRunner::AddErrorCallback(const std::function<void(Status)>& cb) { in AddErrorCallback()
41 void QueueRunner::ClearErrorCallbacks() { in ClearErrorCallbacks()
46 Status QueueRunner::Init(const QueueRunnerDef& queue_runner_def) { in Init()
82 QueueRunner::~QueueRunner() { in ~QueueRunner()
[all …]
|
| D | queue_runner_test.cc | 118 std::unique_ptr<QueueRunner> qr; in TEST()
119 TF_EXPECT_OK(QueueRunner::New(queue_runner_def, &qr)); in TEST()
138 std::unique_ptr<QueueRunner> qr; in TEST()
139 TF_EXPECT_OK(QueueRunner::New(queue_runner_def, &qr)); in TEST()
157 std::unique_ptr<QueueRunner> qr; in TEST()
158 TF_EXPECT_OK(QueueRunner::New(queue_runner_def, &qr)); in TEST()
171 std::unique_ptr<QueueRunner> qr; in TEST()
172 TF_EXPECT_OK(QueueRunner::New(queue_runner_def, &qr)); in TEST()
210 std::unique_ptr<QueueRunner> qr; in TEST()
211 TF_EXPECT_OK(QueueRunner::New(queue_runner_def, &qr)); in TEST()
[all …]
|
| D | queue_runner.h | 38 class QueueRunner : public RunnerInterface {
44 std::unique_ptr<QueueRunner>* result);
48 std::unique_ptr<QueueRunner>* result);
57 ~QueueRunner();
89 QueueRunner() : coord_(nullptr), stopped_(false), cg_mu_(nullptr) {} in QueueRunner() function
|
| /external/tensorflow/tensorflow/python/training/ |
| D | queue_runner_test.py | 53 qr = queue_runner_impl.QueueRunner(queue, [count_up_to])
74 qr = queue_runner_impl.QueueRunner(queue, [count_up_to_3, count_up_to_30])
91 qr = queue_runner_impl.QueueRunner(queue, [_MockOp("i fail"),
112 qr = queue_runner_impl.QueueRunner(q1, [enqueue1])
140 qr = queue_runner_impl.QueueRunner(queue, [count_up_to])
159 qr = queue_runner_impl.QueueRunner(queue, [_MockOp("not an op")])
174 qr = queue_runner_impl.QueueRunner(queue, [enqueue])
194 qr = queue_runner_impl.QueueRunner(queue, [count_up_to])
209 qr = queue_runner_impl.QueueRunner(queue, [count_up_to])
224 qr = queue_runner_impl.QueueRunner(queue, [count_up_to,
[all …]
|
| D | queue_runner_impl.py | 38 class QueueRunner(object): class
390 return QueueRunner(queue_runner_def=queue_runner_def,
485 to_proto=QueueRunner.to_proto,
486 from_proto=QueueRunner.from_proto)
|
| D | input.py | 198 queue_runner.QueueRunner(
736 queue_runner.add_queue_runner(queue_runner.QueueRunner(queue, enqueue_ops))
753 queue_runner.add_queue_runner(queue_runner.QueueRunner(queue, enqueue_ops))
|
| D | sync_replicas_optimizer.py | 350 self._chief_queue_runner = queue_runner.QueueRunner(dummy_queue,
|
| D | saver_test.py | 1636 qr = queue_runner_impl.QueueRunner(input_queue, [count_up_to])
|
| /external/tensorflow/tensorflow/tools/api/golden/v1/ |
| D | tensorflow.train.-queue-runner.pbtxt | 1 path: "tensorflow.train.QueueRunner"
3 is_instance: "<class \'tensorflow.python.training.queue_runner_impl.QueueRunner\'>"
|
| D | tensorflow.train.queue_runner.-queue-runner.pbtxt | 1 path: "tensorflow.train.queue_runner.QueueRunner"
3 is_instance: "<class \'tensorflow.python.training.queue_runner_impl.QueueRunner\'>"
|
| D | tensorflow.train.queue_runner.pbtxt | 4 name: "QueueRunner"
|
| D | tensorflow.train.pbtxt | 152 name: "QueueRunner"
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | queue_runner.proto | 11 // Protocol buffer representing a QueueRunner.
|
| /external/tensorflow/tensorflow/contrib/slim/python/slim/data/ |
| D | prefetch_queue.py | 89 queue_runner.QueueRunner(queue, [enqueue_op] * num_threads))
|
| D | parallel_reader.py | 165 queue_runner.QueueRunner(self._common_queue, enqueue_ops))
|
| /external/tensorflow/tensorflow/contrib/training/python/training/ |
| D | bucket_ops.py | 269 queue_runner.QueueRunner(
276 queue_runner.QueueRunner(
|
| D | sampling_ops_threading_test.py | 58 queue_runner_impl.QueueRunner(queue, [enqueue_op] * 25))
|
| D | sequence_queueing_state_saver.py | 1531 q_runner = queue_runner.QueueRunner(
|
| /external/tensorflow/tensorflow/core/grappler/clusters/ |
| D | single_machine.cc | 174 std::unique_ptr<QueueRunner> queue_runner; in Run()
175 TF_RETURN_IF_ERROR(QueueRunner::New(queue_runner_defs_[i], in Run()
|
| /external/tensorflow/tensorflow/contrib/learn/python/learn/learn_io/ |
| D | graph_io.py | 416 queue_runner.QueueRunner(file_name_queue, [enqueue_op]))
719 queue_runner.QueueRunner(
|
| /external/tensorflow/tensorflow/contrib/factorization/python/ops/ |
| D | gmm_test.py | 207 queue_runner.add_queue_runner(queue_runner.QueueRunner(queue,
|
| D | kmeans_test.py | 601 queue_runner.QueueRunner(queue, [enqueue_op]))
|
| /external/tensorflow/tensorflow/contrib/learn/python/learn/estimators/ |
| D | estimator_input_test.py | 63 queue_runner = queue_runner_impl.QueueRunner(fake_queue,
|
| D | kmeans_test.py | 570 queue_runner.QueueRunner(queue, [enqueue_op]))
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | meta_graph_test.py | 670 qr = queue_runner_impl.QueueRunner(input_queue, [enqueue], close)
|