Function catAppendOnlyExpireMemberAtCommand

src/aof.cpp:633–680

}

sds catAppendOnlyExpireMemberAtCommand(sds buf, struct redisCommand *cmd, robj **argv, const size_t argc) {
    long long when = 0;
    int unit = UNIT_SECONDS;
    bool fAbsolute = false;
    
    if (cmd->proc == expireMemberCommand) {
        if (getLongLongFromObject(argv[3], &when) != C_OK)
            serverPanic("propogating invalid EXPIREMEMBER command");
        
        if (argc == 5) {
            unit = parseUnitString(szFromObj(argv[4]));
        }
    } else if (cmd->proc == expireMemberAtCommand) {
        if (getLongLongFromObject(argv[3], &when) != C_OK)
            serverPanic("propogating invalid EXPIREMEMBERAT command");
        fAbsolute = true;
    } else if (cmd->proc == pexpireMemberAtCommand) {
        if (getLongLongFromObject(argv[3], &when) != C_OK)
            serverPanic("propogating invalid PEXPIREMEMBERAT command");
        fAbsolute = true;
        unit = UNIT_MILLISECONDS;
    } else {
        serverPanic("Unknown expiremember command");
    }

    switch (unit)
    {
    case UNIT_SECONDS:
        when *= 1000;
        break;

    case UNIT_MILLISECONDS:
        break;
    }

    if (!fAbsolute)
        when += mstime();
    
    robj *argvNew[4];
    argvNew[0] = shared.pexpirememberat;
    argvNew[1] = argv[1];
    argvNew[2] = argv[2];
    argvNew[3] = createStringObjectFromLongLong(when);
    buf = catAppendOnlyGenericCommand(buf, 4, argvNew);
    decrRefCount(argvNew[0]);
    decrRefCount(argvNew[3]);
    return buf;
}

sds catCommandForAofAndActiveReplication(sds buf, struct redisCommand *cmd, robj **argv, int argc)
{