Method runJob

cachelib/navy/scheduler/ThreadPoolJobQueue.cpp:112–147

}

JobExitCode JobQueue::runJob(QueueEntry& entry) {
  auto safeJob = [&entry] {
    try {
      return entry.job();
    } catch (const std::exception& ex) {
      XLOGF(ERR, "Exception thrown from the job: {}", ex.what());
      util::printExceptionStackTraces();
      throw;
    } catch (...) {
      XLOG(ERR, "Unknown exception thrown from the job");
      util::printExceptionStackTraces();
      throw;
    }
  };

  auto exitCode = safeJob();
  switch (exitCode) {
  case JobExitCode::Reschedule: {
    entry.rescheduleCount++;
    if (entry.rescheduleCount >= kHighRescheduleCount &&
        entry.rescheduleCount % kHighRescheduleReportRate == 0) {
      XLOGF(DBG,
            "Job '{}' rescheduled {} times",
            entry.name,
            entry.rescheduleCount);
    }
    break;
  }
  case JobExitCode::Done: {
    // Deallocate outside the lock:
    entry.job = Job{};
    break;
  }
  }
  return exitCode;
}

uint64_t JobQueue::finish() {
  // Busy wait, but used only in tests