Method WorkerPauser

core/worker.cc:414–424

}

WorkerPauser::WorkerPauser() {
  if (is_any_worker_running()) {
    for (int wid = 0; wid < Worker::kMaxWorkers; wid++) {
      if (is_worker_running(wid)) {
        workers_paused_.push_back(wid);
        VLOG(1) << "*** Pausing Worker " << wid << " ***";
        pause_worker(wid);
      }
    }
  }
}

WorkerPauser::~WorkerPauser() {
  attach_orphans();  // All workers should be paused at this point.