Method ClearExpiredCache

core/ebpf/plugin/ProcessCache.cpp:102–138

}

void ProcessCache::ClearExpiredCache() {
    {
        std::lock_guard<std::mutex> lock(mCacheExpireQueueMutex);
        mCacheExpireQueueProcessing.swap(mCacheExpireQueue);
    }
    if (mCacheExpireQueueProcessing.empty()) {
        return;
    }
    size_t nextQueueSize = 0;
    for (auto& entry : mCacheExpireQueueProcessing) {
        if (entry.value->LifeStage() == ProcessCacheValue::LifeStage::kDeleted) {
            LOG_WARNING(sLogger, ("clear expired cache twice pid", entry.key.pid)("ktime", entry.key.time));
            continue;
        }
        if (entry.value->RefCount() > 0) {
            entry.value->SetLifeStage(ProcessCacheValue::LifeStage::kInUse);
            continue;
        }
        if (entry.value->LifeStage() == ProcessCacheValue::LifeStage::kDeletePending) {
            entry.value->SetLifeStage(ProcessCacheValue::LifeStage::kDeleteReady);
            mCacheExpireQueueProcessing[nextQueueSize++] = entry;
            continue;
        }
        if (entry.value->LifeStage() == ProcessCacheValue::LifeStage::kDeleteReady) {
            entry.value->SetLifeStage(ProcessCacheValue::LifeStage::kDeleted);
            LOG_DEBUG(sLogger, ("clear expired cache pid", entry.key.pid)("ktime", entry.key.time));
            removeCache(entry.key);
        }
    }
    if (nextQueueSize > 0) {
        mCacheExpireQueueProcessing.resize(nextQueueSize);
        mCacheExpireQueue.insert(mCacheExpireQueue.end(),
                                 std::make_move_iterator(mCacheExpireQueueProcessing.begin()),
                                 std::make_move_iterator(mCacheExpireQueueProcessing.end()));
    }
    mCacheExpireQueueProcessing.clear();
}

void ProcessCache::ForceShrink() {
    if (mLastForceShrinkTimeSec != 0 && mLastForceShrinkTimeSec > TimeKeeper::GetInstance()->NowSec() - 120) {