Searched refs:coord_ (Results 1 – 3 of 3) sorted by relevance
32 (*result)->coord_ = coord; in New()72 if (coord_) { in Init()102 if (coord_) { in Start()130 if (coord_ != nullptr) { in Stop()131 coord_->WaitForStop(); in Stop()153 if (coord_) { in UpdateStatus()154 coord_->ReportStatus(status); in UpdateStatus()166 if (coord_ && coord_->ShouldStop()) { in Run()188 if (IsQueueClosed(status) && (!coord_ || !coord_->ShouldStop())) { in Run()196 if (coord_) { in Run()[all …]
59 coord_ = coord; in MockQueueRunner()101 while (!coord_->ShouldStop() && counter->load() < until) { in CountThread()105 coord_->RequestStop().IgnoreError(); in CountThread()115 Coordinator* coord_; member in tensorflow::__anon7bc84bb50111::MockQueueRunner
89 QueueRunner() : coord_(nullptr), stopped_(false), cg_mu_(nullptr) {} in QueueRunner()126 Coordinator* coord_; variable