| /external/tensorflow/tensorflow/cc/training/ |
| D | coordinator.cc | 20 Coordinator::Coordinator() : Coordinator(std::vector<error::Code>()) {} in Coordinator() function in tensorflow::Coordinator
22 Coordinator::Coordinator(const std::vector<error::Code>& clean_stop_errors) in Coordinator() function in tensorflow::Coordinator
33 Coordinator::~Coordinator() { in ~Coordinator()
38 Status Coordinator::RegisterRunner(std::unique_ptr<RunnerInterface> runner) { in RegisterRunner()
51 bool Coordinator::AllRunnersStopped() { in AllRunnersStopped()
61 Status Coordinator::RequestStop() { in RequestStop()
72 bool Coordinator::ShouldStop() { in ShouldStop()
77 Status Coordinator::Join() { in Join()
97 void Coordinator::ReportStatus(const Status& status) { in ReportStatus()
106 Status Coordinator::GetStatus() { in GetStatus()
[all …]
|
| D | coordinator_test.cc | 32 void WaitForStopThread(Coordinator* coord, Notification* about_to_wait, in WaitForStopThread()
40 Coordinator coord; in TEST()
58 explicit MockQueueRunner(Coordinator* coord) { in MockQueueRunner()
65 MockQueueRunner(Coordinator* coord, int* join_counter) in MockQueueRunner()
115 Coordinator* coord_;
122 Coordinator coord; in TEST()
144 Coordinator coord; in TEST()
162 Coordinator coord; in TEST()
177 Coordinator coord({Code::CANCELLED, Code::OUT_OF_RANGE}); in TEST()
200 Coordinator coord; in TEST()
[all …]
|
| D | coordinator.h | 70 class Coordinator {
72 Coordinator();
76 Coordinator(const std::vector<error::Code>& clean_stop_errors);
79 ~Coordinator();
126 TF_DISALLOW_COPY_AND_ASSIGN(Coordinator);
|
| D | queue_runner.h | 47 static Status New(const QueueRunnerDef& queue_runner_def, Coordinator* coord,
126 Coordinator* coord_;
|
| D | queue_runner.cc | 29 Coordinator* coord, in New()
|
| D | queue_runner_test.cc | 313 Coordinator coord; in TEST()
|
| /external/tensorflow/tensorflow/python/training/ |
| D | coordinator_test.py | 75 coord = coordinator.Coordinator()
83 coord = coordinator.Coordinator()
99 coord = coordinator.Coordinator()
112 coord = coordinator.Coordinator()
126 coord = coordinator.Coordinator()
143 coord = coordinator.Coordinator()
165 coord = coordinator.Coordinator()
181 coord = coordinator.Coordinator()
201 coord = coordinator.Coordinator()
220 coord = coordinator.Coordinator()
[all …]
|
| D | queue_runner_test.py | 143 coord = coordinator.Coordinator()
160 coord = coordinator.Coordinator()
175 coord = coordinator.Coordinator()
193 coord = coordinator.Coordinator()
208 coord = coordinator.Coordinator()
|
| D | coordinator.py | 34 class Coordinator(object): class
444 if not isinstance(coord, Coordinator):
|
| D | monitored_session_test.py | 648 coord = coordinator.Coordinator()
658 coord = coordinator.Coordinator()
665 coord = coordinator.Coordinator()
674 coord = coordinator.Coordinator()
685 coord = coordinator.Coordinator()
700 coord = coordinator.Coordinator()
728 coord = coordinator.Coordinator()
747 coord = coordinator.Coordinator(clean_stop_exception_types=())
|
| D | training.py | 48 from tensorflow.python.training.coordinator import Coordinator
|
| D | input_test.py | 227 coord = coordinator.Coordinator()
253 coord = coordinator.Coordinator()
514 coord = coordinator.Coordinator()
526 coord = coordinator.Coordinator()
986 coord = coordinator.Coordinator()
1610 coord = coordinator.Coordinator()
|
| /external/tensorflow/tensorflow/tools/api/golden/v1/ |
| D | tensorflow.train.-coordinator.pbtxt | 1 path: "tensorflow.train.Coordinator"
3 is_instance: "<class \'tensorflow.python.training.coordinator.Coordinator\'>"
|
| /external/tensorflow/tensorflow/tools/api/golden/v2/ |
| D | tensorflow.train.-coordinator.pbtxt | 1 path: "tensorflow.train.Coordinator"
3 is_instance: "<class \'tensorflow.python.training.coordinator.Coordinator\'>"
|
| D | tensorflow.train.pbtxt | 28 name: "Coordinator"
|
| /external/tensorflow/tensorflow/core/grappler/clusters/ |
| D | single_machine.h | 76 std::unique_ptr<Coordinator> coordinator_;
|
| D | single_machine.cc | 366 coordinator_.reset(new Coordinator()); in ResetSession()
|
| /external/tensorflow/tensorflow/python/eager/ |
| D | remote_cluster_test.py | 310 self._coord = coordinator.Coordinator()
412 self._coord = coordinator.Coordinator()
543 self._coord = coordinator.Coordinator()
593 self._coord = coordinator.Coordinator()
|
| /external/tensorflow/tensorflow/python/distribute/coordinator/ |
| D | fault_tolerance_test.py | 126 self.thread_coord = thread_coordinator.Coordinator(
468 self.thread_coord = thread_coordinator.Coordinator(
472 self.thread_coord = thread_coordinator.Coordinator(
|
| D | cluster_coordinator_test.py | 72 coord = coordinator.Coordinator(clean_stop_exception_types=[])
120 coord = coordinator.Coordinator(clean_stop_exception_types=[])
141 coord = coordinator.Coordinator(clean_stop_exception_types=[])
169 coord = coordinator.Coordinator(clean_stop_exception_types=[])
|
| /external/ltp/testcases/open_posix_testsuite/Documentation/ |
| D | HOWTO_Tagging | 19 Release Coordinator Tagging
|
| /external/tensorflow/tensorflow/python/distribute/ |
| D | distribute_coordinator.py | 457 coord = coordinator.Coordinator()
500 coord = coordinator.Coordinator()
|
| D | multi_worker_test_base.py | 465 self._coord = coordinator.Coordinator()
671 self._coord = coordinator.Coordinator()
|
| D | mirrored_run.py | 148 coord = coordinator.Coordinator(clean_stop_exception_types=(_RequestedStop,))
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | reader_ops_test.py | 793 coord = coordinator.Coordinator()
829 coord = coordinator.Coordinator()
|