Method createCombinedEntryManager

cachelib/navy/block_cache/BlockCache.cpp:186–211

BlockCache::~BlockCache() { regionManager_.drain(); }

std::unique_ptr<CombinedEntryManager> BlockCache::createCombinedEntryManager(
    const Config& config) {
  if (config.useCombinedEntryBlock &&
      config.indexConfig.isFixedSizeIndexEnabled()) {
    // Let's use one stream per each mutex for the index
    uint64_t numStreams = FixedSizeIndex::getTotalShardCount(
        FixedSizeIndex::getTotalBucketCount(
            config.indexConfig.getNumChunks(),
            config.indexConfig.getNumBucketsPerChunkPower()),
        config.indexConfig.getNumBucketsPerMutex());

    // Currently, FixedSizeIndex and CombinedEntryManager will support shm
    // persistence only
    return std::make_unique<CombinedEntryManager>(
        numStreams, CombinedEntryBlock::kDefaultSize - sizeof(EntryDesc),
        (config.persistParams.useShm)
            ? (config.persistParams.shmManager.has_value()
                   ? &(config.persistParams.shmManager.value().get())
                   : nullptr)
            : nullptr,
        config.name, bindThis(&BlockCache::onWriteCombinedEntryBlock, *this),
        bindThis(&BlockCache::onReadCombinedEntryBlock, *this));
  } else {
    return nullptr;
  }
}

BlockCache::BlockCache(Config&& config)
    : BlockCache{std::move(config.validate()), ValidConfigTag{}} {}