Method optimizeCompactCacheSizes

cachelib/allocator/PoolOptimizer.cpp:51–76

}

void PoolOptimizer::optimizeCompactCacheSizes() {
  try {
    auto strategy = cache_.getPoolOptimizeStrategy();
    if (!strategy) {
      strategy = strategy_;
    }
    const auto context = strategy->pickVictimAndReceiverCompactCaches(cache_);
    if (context.victimPoolId == Slab::kInvalidPoolId ||
        context.receiverPoolId == Slab::kInvalidPoolId) {
      XLOG(DBG, "Cannot find victim and receiver for pool optimization");
    } else {
      const auto memoryToMove =
          cache_.getCompactCache(context.victimPoolId).getConfiguredSize() *
          ccacheStepSizePercent_ / 100;
      cache_.resizePools(context.victimPoolId, context.receiverPoolId,
                         memoryToMove);
      cache_.resizeCompactCaches();
      XLOG(DBG, "Moving a slab from Pool {} to Pool {}",
           static_cast<int>(context.victimPoolId),
           static_cast<int>(context.receiverPoolId));
    }
  } catch (const std::exception& ex) {
    XLOGF(CRITICAL, "Optimization interrupted due to exception: {}", ex.what());
    XDCHECK(false);
  }
}

void PoolOptimizer::work() {
  progress_++;