Method CleanupThreadState

be/src/util/cache/lirs-cache.cc:1093–1119

}

void LIRSCacheShard::CleanupThreadState(LIRSThreadState* tstate) {
  // evict things that need to be evicted
  for (LIRSHandle* e : tstate->handles_to_evict) {
    DCHECK_EQ(e->residency(), EVICTING);
    DCHECK_EQ(e->num_references(), 0);
    if (e->eviction_callback_) {
      e->eviction_callback_->EvictedEntry(e->key(), e->value());
    }
    UpdateMemTracker(-static_cast<int64_t>(e->charge()));
    // The eviction is done, set the residency back to NOT_RESIDENT
    auto state_transition = e->modify_atomic_state([] (AtomicState& cur_state) {
        DCHECK_EQ(cur_state.residency, EVICTING);
        DCHECK_EQ(cur_state.ref_count, 0);
        cur_state.residency = NOT_RESIDENT;
      });
    // If the handle transitioned to UNINITIALIZED before we set it to NOT_RESIDENT,
    // then we are responsible for freeing it.
    if (state_transition.before.state == UNINITIALIZED) {
      Free(e);
    }
  }
  tstate->handles_to_evict.clear();
  for (LIRSHandle* e : tstate->handles_to_free) {
    Free(e);
  }
  tstate->handles_to_free.clear();
}

void LIRSCacheShard::Erase(const Slice& key, uint32_t hash) {
  DCHECK(initialized_);