Function activeExpireCycleExpire

src/expire.cpp:75–179

int activeExpireCycleExpire(redisDb *db, const char *key, expireEntry &e, long long now, size_t &tried) {
    if (!e.FFat())
    {
        activeExpireCycleExpireFullKey(db, key);
        ++tried;
        return 1;
    }

    expireEntryFat *pfat = e.pfatentry();
    robj *val = db->find(key);
    int deleted = 0;

    redisObjectStack objKey;
    initStaticStringObject(objKey, (char*)key);

    while (!pfat->FEmpty())
    {
        ++tried;
        if (pfat->nextExpireEntry().when > now)
            break;

        // Is it the full key expiration?
        if (pfat->nextExpireEntry().spsubkey == nullptr)
        {
            activeExpireCycleExpireFullKey(db, key);
            return ++deleted;
        }

        switch (val->type)
        {
        case OBJ_SET:
            if (setTypeRemove(val,pfat->nextExpireEntry().spsubkey.get())) {
                deleted++;
                if (setTypeSize(val) == 0) {
                    activeExpireCycleExpireFullKey(db, key);
                    return deleted;
                }
            }
            break;

        case OBJ_HASH:
            if (hashTypeDelete(val,(sds)pfat->nextExpireEntry().spsubkey.get())) {
                deleted++;
                if (hashTypeLength(val) == 0) {
                    activeExpireCycleExpireFullKey(db, key);
                    return deleted;
                }
            }
            break;

        case OBJ_ZSET:
            if (zsetDel(val,(sds)pfat->nextExpireEntry().spsubkey.get())) {
                deleted++;
                if (zsetLength(val) == 0) {
                    activeExpireCycleExpireFullKey(db, key);
                    return deleted;
                }
            }