Searched refs:QueueRunner (Results 1 – 15 of 15) sorted by relevance
| /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 | 197 queue_runner.QueueRunner(
735 queue_runner.add_queue_runner(queue_runner.QueueRunner(queue, enqueue_ops))
752 queue_runner.add_queue_runner(queue_runner.QueueRunner(queue, enqueue_ops))
|
| D | sync_replicas_optimizer.py | 338 self._chief_queue_runner = queue_runner.QueueRunner(
|
| D | saver_test.py | 1828 qr = queue_runner_impl.QueueRunner(input_queue, [count_up_to])
|
| /external/tensorflow/tensorflow/tools/api/golden/v1/ |
| 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 | 1 path: "tensorflow.train.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 | 156 name: "QueueRunner"
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | queue_runner.proto | 13 // Protocol buffer representing a QueueRunner.
|
| /external/tensorflow/tensorflow/core/grappler/clusters/ |
| D | single_machine.cc | 173 std::unique_ptr<QueueRunner> queue_runner; in Run()
174 TF_RETURN_IF_ERROR(QueueRunner::New(queue_runner_defs_[i], in Run()
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | meta_graph_test.py | 716 qr = queue_runner_impl.QueueRunner(input_queue, [enqueue], close)
|