Searched refs:queue_runner_def (Results 1 - 5 of 5) sorted by relevance

/external/tensorflow/tensorflow/python/training/
H A Dqueue_runner_impl.py58 queue_runner_def=None, import_scope=None):
80 queue_runner_def: Optional `QueueRunnerDef` protocol buffer. If specified,
81 recreates the QueueRunner from its contents. `queue_runner_def` and the
87 ValueError: If both `queue_runner_def` and `queue` are both specified.
89 restoring from `queue_runner_def`.
97 if queue_runner_def:
99 raise ValueError("queue_runner_def and queue are mutually exclusive.")
100 self._init_from_proto(queue_runner_def,
129 restoring from `queue_runner_def`.
163 def _init_from_proto(self, queue_runner_def, import_scop
[all...]
/external/tensorflow/tensorflow/cc/training/
H A Dqueue_runner.cc22 Status QueueRunner::New(const QueueRunnerDef& queue_runner_def, argument
25 return (*result)->Init(queue_runner_def);
28 Status QueueRunner::New(const QueueRunnerDef& queue_runner_def, argument
33 return (*result)->Init(queue_runner_def);
46 Status QueueRunner::Init(const QueueRunnerDef& queue_runner_def) { argument
47 queue_name_ = queue_runner_def.queue_name();
50 queue_runner_def.enqueue_op_name().begin(),
51 queue_runner_def.enqueue_op_name().end());
61 close_op_name_ = queue_runner_def.close_op_name();
62 cancel_op_name_ = queue_runner_def
[all...]
H A Dqueue_runner_test.cc87 QueueRunnerDef queue_runner_def; local
88 *queue_runner_def.mutable_queue_name() = queue_name;
90 *queue_runner_def.mutable_enqueue_op_name()->Add() = enqueue_op;
92 *queue_runner_def.mutable_close_op_name() = close_op;
93 *queue_runner_def.mutable_cancel_op_name() = cancel_op;
95 *queue_runner_def.mutable_queue_closed_exception_types()->Add() =
98 return queue_runner_def;
115 QueueRunnerDef queue_runner_def = BuildQueueRunnerDef( local
119 TF_EXPECT_OK(QueueRunner::New(queue_runner_def, &qr));
134 QueueRunnerDef queue_runner_def local
153 QueueRunnerDef queue_runner_def = local
168 QueueRunnerDef queue_runner_def = BuildQueueRunnerDef( local
208 QueueRunnerDef queue_runner_def = local
245 QueueRunnerDef queue_runner_def = BuildQueueRunnerDef( local
275 QueueRunnerDef queue_runner_def = local
289 QueueRunnerDef queue_runner_def = BuildQueueRunnerDef( local
336 QueueRunnerDef queue_runner_def = BuildQueueRunnerDef( local
371 QueueRunnerDef queue_runner_def = local
397 QueueRunnerDef queue_runner_def = BuildQueueRunnerDef( local
[all...]
H A Dqueue_runner.h43 static Status New(const QueueRunnerDef& queue_runner_def,
47 static Status New(const QueueRunnerDef& queue_runner_def, Coordinator* coord,
92 Status Init(const QueueRunnerDef& queue_runner_def);
/external/tensorflow/tensorflow/python/estimator/inputs/queues/
H A Dfeeding_queue_runner.py172 def _init_from_proto(self, queue_runner_def):

Completed in 202 milliseconds