Method StoreInternal

be/src/runtime/io/data-cache.cc:1488–1508

}

bool DataCache::StoreInternal(const CacheKey& key, const uint8_t* buffer,
    int64_t buffer_len) {
  // Here, a shared lock is acquired with try_to_lock, while a unique lock is acquired in
  // SetDataCacheReadOnly(). Therefore, when setting the read-only status, the lock
  // acquisition here can quickly fail, then return.
  kudu::shared_lock<shared_mutex> lock(readonly_lock_, std::try_to_lock);
  if (UNLIKELY(!lock.owns_lock() || readonly_.Load())) return false;

  int idx = key.Hash() % partitions_.size();
  bool start_reclaim;
  bool stored = partitions_[idx]->Store(key, buffer, buffer_len, &start_reclaim);
  if (VLOG_IS_ON(3)) {
    stringstream ss;
    ss << std::hex << reinterpret_cast<int64_t>(buffer);
    LOG(INFO) << Substitute("Storing $0 mtime: $1 offset: $2 bytes_to_read: $3 "
        "buffer: 0x$4 stored: $5", key.filename().ToString(), key.mtime(), key.offset(),
        buffer_len, ss.str(), stored);
  }
  if (start_reclaim) file_deleter_pool_->Offer(idx);
  return stored;
}

void DataCache::Partition::Trace(
    const trace::EventType& type, const DataCache::CacheKey& key,