Method work

cachelib/cachebench/runner/ProgressTracker.cpp:44–81

}

void ProgressTracker::work() {
  auto now = std::chrono::system_clock::now();
  auto nowTimeT = std::chrono::system_clock::to_time_t(now);
  char buf[16];
  struct tm time;
  ::localtime_r(&nowTimeT, &time);
  ::strftime(buf, sizeof(buf), "%H:%M:%S", &time);
  auto throughputStats = stressor_.aggregateThroughputStats();
  auto mOpsPerSec = throughputStats.ops / 1e6;

  auto currCacheStats = stressor_.getCacheStats();
  auto thStr = fmt::format("Instance {:>3}: {} {:>10.2f}M ops completed. {}",
                           instanceId_,
                           buf,
                           mOpsPerSec,
                           currCacheStats->progress(*prevStats_));

  // additionally log into the stats file
  if (statsFile_.is_open()) {
    statsFile_ << thStr << std::endl;
    statsFile_ << "== Allocator Stats ==" << std::endl;
    currCacheStats->render(statsFile_);

    statsFile_ << "== Hit Ratio Stats Since Last ==" << std::endl;
    currCacheStats->render(*prevStats_, statsFile_);

    statsFile_ << "== Throughput Stats ==" << std::endl;
    auto elapsedTimeNs = stressor_.getTestDurationNs();
    throughputStats.render(elapsedTimeNs, statsFile_);

    stressor_.renderWorkloadGeneratorStats(elapsedTimeNs, statsFile_);
    statsFile_ << std::endl;
  } else {
    std::cout << thStr << std::endl;
  }

  prevStats_ = std::move(currCacheStats);
}
} // namespace cachebench
} // namespace cachelib
} // namespace facebook