Method removeFileEntries

bolt/common/caching/AsyncDataCache.cpp:589–635

}

bool CacheShard::removeFileEntries(
    const folly::F14FastSet<uint64_t>& filesToRemove,
    folly::F14FastSet<uint64_t>& filesRetained) {
  if (filesToRemove.empty()) {
    BOLT_CACHE_LOG(INFO) << "Removed 0 AsyncDataCache entry.";
    return true;
  }

  int64_t pagesRemoved = 0;
  std::vector<memory::Allocation> toFree;
  {
    std::lock_guard<std::mutex> l(mutex_);

    auto entryIndex = -1;
    for (auto& cacheEntry : entries_) {
      entryIndex++;
      if (!cacheEntry || !cacheEntry->key_.fileNum.hasValue()) {
        continue;
      }
      if (filesToRemove.count(cacheEntry->key_.fileNum.id()) == 0) {
        continue;
      }
      if (cacheEntry->isExclusive() || cacheEntry->isShared()) {
        filesRetained.insert(cacheEntry->key_.fileNum.id());
        continue;
      }

      numAgedOut_++;
      pagesRemoved += (int64_t)cacheEntry->data().numPages();

      toFree.push_back(std::move(cacheEntry->data()));
      removeEntryLocked(cacheEntry.get());
      emptySlots_.push_back(entryIndex);
      tryAddFreeEntry(std::move(cacheEntry));
      cacheEntry = nullptr;
    }
  }
  BOLT_CACHE_LOG(INFO) << "Removed " << toFree.size()
                       << " AsyncDataCache entries.";

  // Free the memory allocation out of the cache shard lock.
  ClockTimer t(allocClocks_);
  freeAllocations(toFree);
  cache_->incrementCachedPages(-pagesRemoved);

  return true;
}

AsyncDataCache::AsyncDataCache(
    memory::MemoryAllocator* allocator,