Method EvictedEntry

be/src/runtime/tuple-cache-mgr.cc:575–619

}

void TupleCacheMgr::EvictedEntry(Slice key, Slice value) {
  const TupleCacheEntry* entry = reinterpret_cast<const TupleCacheEntry*>(value.data());
  if (TupleCacheState::TOMBSTONE != entry->state) {
    DCHECK(tuple_cache_entries_evicted_ != nullptr);
    DCHECK(tuple_cache_entries_in_use_ != nullptr);
    DCHECK(tuple_cache_entries_in_use_bytes_ != nullptr);
    tuple_cache_entries_evicted_->Increment(1);
    tuple_cache_entries_in_use_->Increment(-1);
    DCHECK_GE(tuple_cache_entries_in_use_->GetValue(), 0);
    // entries_in_use_bytes is incremented only when the entry reaches the
    // COMPLETE_UNSYNCED state
    if (TupleCacheState::COMPLETE_UNSYNCED == entry->state ||
        TupleCacheState::COMPLETE == entry->state) {
      tuple_cache_entries_in_use_bytes_->Increment(-entry->charge);
      DCHECK_GE(tuple_cache_entries_in_use_bytes_->GetValue(), 0);
    }
    // Outstanding write bytes are accumulated during IN_PROGRESS, and remain set until
    // the transition from COMPLETE_UNSYNCED to COMPLETE.
    if (TupleCacheState::COMPLETE_UNSYNCED == entry->state ||
        TupleCacheState::IN_PROGRESS == entry->state) {
      DCHECK(tuple_cache_outstanding_writes_bytes_ != nullptr);
      DCHECK_GE(tuple_cache_outstanding_writes_bytes_->GetValue(), entry->charge);
      tuple_cache_outstanding_writes_bytes_->Increment(-entry->charge);
    }
  } else {
    DCHECK(tuple_cache_tombstones_in_use_ != nullptr);
    tuple_cache_tombstones_in_use_->Increment(-1);
    DCHECK_GE(tuple_cache_tombstones_in_use_->GetValue(), 0);
  }
  // Retrieve the path following TupleCacheEntry.
  value.remove_prefix(sizeof(TupleCacheEntry));
  value.truncate(value.size() - 1);
  VLOG_FILE << "Tuple Cache: Evict " << key << " at " << value.ToString();
  // Delete file on disk.
  kudu::Status status = kudu::Env::Default()->DeleteFile(value.ToString());
  if (!status.ok()) {
    LOG(WARNING) <<
        Substitute("Failed to unlink $0: $1", value.ToString(), status.ToString());
  }
  // If correctness checking is enabled, remove the associated metadata as well.
  if (DebugDumpEnabled()) {
    string key_str(reinterpret_cast<const char*>(key.data()), key.size());
    RemoveMetadataForTupleCache(key_str);
  }
}

Status TupleCacheMgr::DeleteExistingFiles() const {
  vector<string> entries;