| /external/tensorflow/tensorflow/core/grappler/ |
| D | grappler_item.cc | 57 for (const auto& queue_runner : queue_runners) { in EnqueueOpsFanin() local
58 for (const string& enqueue_op : queue_runner.enqueue_op_name()) { in EnqueueOpsFanin()
106 for (const auto& queue_runner : queue_runners) { in NodesToPreserve() local
107 for (const string& enqueue_op : queue_runner.enqueue_op_name()) { in NodesToPreserve()
110 if (!queue_runner.close_op_name().empty()) { in NodesToPreserve()
111 result.insert(NodeName(queue_runner.close_op_name())); in NodesToPreserve()
113 if (!queue_runner.cancel_op_name().empty()) { in NodesToPreserve()
114 result.insert(NodeName(queue_runner.cancel_op_name())); in NodesToPreserve()
|
| D | grappler_item_builder.cc | 418 QueueRunnerDef queue_runner; in GrapplerItemFromMetaGraphDef() local
419 if (!queue_runner.ParseFromString(raw)) { in GrapplerItemFromMetaGraphDef()
423 if (queue_runner.cancel_op_name().empty()) { in GrapplerItemFromMetaGraphDef()
427 new_item->queue_runners.push_back(queue_runner); in GrapplerItemFromMetaGraphDef()
|
| /external/tensorflow/tensorflow/core/grappler/inputs/ |
| D | trivial_test_graph_input_yielder.cc | 113 QueueRunnerDef queue_runner; in NextItem() local
114 queue_runner.set_queue_name("queue"); in NextItem()
115 queue_runner.set_cancel_op_name("cancel"); in NextItem()
116 *queue_runner.add_enqueue_op_name() = "enqueue"; in NextItem()
117 r.queue_runners.push_back(queue_runner); in NextItem()
|
| /external/tensorflow/tensorflow/contrib/slim/python/slim/data/ |
| D | prefetch_queue.py | 26 from tensorflow.python.training import queue_runner
88 queue_runner.add_queue_runner(
89 queue_runner.QueueRunner(queue, [enqueue_op] * num_threads))
|
| D | parallel_reader.py | 29 from tensorflow.python.training import queue_runner
164 queue_runner.add_queue_runner(
165 queue_runner.QueueRunner(self._common_queue, enqueue_ops))
|
| /external/tensorflow/tensorflow/contrib/training/python/training/ |
| D | bucket_ops.py | 41 from tensorflow.python.training import queue_runner
268 queue_runner.add_queue_runner(
269 queue_runner.QueueRunner(
275 queue_runner.add_queue_runner(
276 queue_runner.QueueRunner(
|
| /external/tensorflow/tensorflow/contrib/learn/python/learn/learn_io/ |
| D | graph_io.py | 41 from tensorflow.python.training import queue_runner
415 queue_runner.add_queue_runner(
416 queue_runner.QueueRunner(file_name_queue, [enqueue_op]))
718 queue_runner.add_queue_runner(
719 queue_runner.QueueRunner(
|
| /external/tensorflow/tensorflow/core/grappler/clusters/ |
| D | single_machine.cc | 174 std::unique_ptr<QueueRunner> queue_runner; in Run() local
176 coordinator_.get(), &queue_runner)); in Run()
178 TF_RETURN_IF_ERROR(queue_runner->StartAndCollectCostGraph( in Run()
181 coordinator_->RegisterRunner(std::move(queue_runner))); in Run()
|
| D | single_machine_test.cc | 527 QueueRunnerDef queue_runner; in CreateGrapplerItemWithResourceMemory() local
528 queue_runner.set_queue_name("queue"); in CreateGrapplerItemWithResourceMemory()
529 *queue_runner.add_enqueue_op_name() = "enqueue"; in CreateGrapplerItemWithResourceMemory()
530 item.queue_runners.push_back(queue_runner); in CreateGrapplerItemWithResourceMemory()
|
| D | BUILD | 116 "//tensorflow/cc:queue_runner",
|
| /external/tensorflow/tensorflow/cc/ |
| D | BUILD | 724 name = "queue_runner",
725 srcs = ["training/queue_runner.cc"],
726 hdrs = ["training/queue_runner.h"],
743 ":queue_runner",
774 ":queue_runner",
798 ":queue_runner",
|
| /external/tensorflow/tensorflow/contrib/factorization/python/ops/ |
| D | gmm_test.py | 33 from tensorflow.python.training import queue_runner
207 queue_runner.add_queue_runner(queue_runner.QueueRunner(queue,
|
| D | kmeans_test.py | 43 from tensorflow.python.training import queue_runner
600 queue_runner.add_queue_runner(
601 queue_runner.QueueRunner(queue, [enqueue_op]))
|
| /external/tensorflow/tensorflow/python/training/ |
| D | input.py | 47 from tensorflow.python.training import queue_runner
197 queue_runner.add_queue_runner(
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 | 32 from tensorflow.python.training import queue_runner
350 self._chief_queue_runner = queue_runner.QueueRunner(dummy_queue,
|
| D | training.py | 49 from tensorflow.python.training.queue_runner import *
|
| /external/tensorflow/tensorflow/tools/api/golden/v1/ |
| D | tensorflow.train.queue_runner.pbtxt | 1 path: "tensorflow.train.queue_runner"
|
| D | tensorflow.train.queue_runner.-queue-runner.pbtxt | 1 path: "tensorflow.train.queue_runner.QueueRunner"
|
| /external/tensorflow/tensorflow/contrib/learn/python/learn/ |
| D | graph_actions.py | 51 from tensorflow.python.training import queue_runner
557 threads = queue_runner.start_queue_runners(session, coord)
696 threads = queue_runner.start_queue_runners(session, coord=coord)
|
| /external/tensorflow/tensorflow/contrib/learn/python/learn/estimators/ |
| D | kmeans_test.py | 43 from tensorflow.python.training import queue_runner
569 queue_runner.add_queue_runner(
570 queue_runner.QueueRunner(queue, [enqueue_op]))
|
| D | estimator_input_test.py | 63 queue_runner = queue_runner_impl.QueueRunner(fake_queue,
65 queue_runner_impl.add_queue_runner(queue_runner)
|
| /external/tensorflow/tensorflow/contrib/makefile/ |
| D | tf_proto_files.txt | 42 tensorflow/core/protobuf/queue_runner.proto
|
| D | proto_text_pb_cc_files.txt | 36 tensorflow/core/protobuf/queue_runner.pb.cc
|
| D | proto_text_pb_h_files.txt | 36 tensorflow/core/protobuf/queue_runner.pb.h
|
| /external/tensorflow/tensorflow/cc/training/ |
| D | queue_runner_test.cc | 231 void JoinThread(QueueRunner* queue_runner, bool* join_succeeded, in JoinThread() argument
233 EXPECT_EQ(queue_runner->Join().code(), Code::CANCELLED); in JoinThread()
|