- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for IsQueueClosed (0.46 sec)
-
tensorflow/cc/training/queue_runner.cc
thread_pool_.reset(); mutex_lock l(mu_); return status_; } void QueueRunner::UpdateStatus(const Status& status) { { mutex_lock l(mu_); if (!status_.ok() || status.ok() || IsQueueClosed(status)) { return; } status_ = status; } if (coord_) { coord_->ReportStatus(status); } mutex_lock l(cb_mu_); for (auto& cb : callbacks_) { cb(status); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.h
void Run(Session* sess, const string& enqueue_op); // Updates the internal status; it only keeps OK or the first unexpected error // status. void UpdateStatus(const Status& status); bool IsQueueClosed(Status status) const { return queue_closed_exception_types_.count( static_cast<int>(status.code())) > 0; } bool IsRunning() const override { return !stopped_; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 31 18:27:00 UTC 2022 - 5K bytes - Viewed (0)