Function cronCommand

src/cron.cpp:10–77

CRON [name] [single shot] [optional: start] [delay] [script] [numkeys] [key N] [arg N]

// CRON [name] [single shot] [optional: start] [delay] [script] [numkeys] [key N] [arg N]
void cronCommand(client *c)
{
    int arg_offset = 0;
    static const int ARG_NAME = 1;
    static const int ARG_SINGLESHOT = 2;
    static const int ARG_EXPIRE = 3;
    #define ARG_SCRIPT (4+arg_offset)
    #define ARG_NUMKEYS (5+arg_offset)
    #define ARG_KEYSTART (6+arg_offset)

    bool fSingleShot = false;
    if (strcasecmp("single", szFromObj(c->argv[ARG_SINGLESHOT])) == 0) {
        fSingleShot = true;
    } else {
        if (strcasecmp("repeat", szFromObj(c->argv[ARG_SINGLESHOT])) != 0) {
            addReply(c, shared.syntaxerr);
            return;
        }
    }

    long long interval;
    if (getLongLongFromObjectOrReply(c, c->argv[ARG_EXPIRE], &interval, "missing expire time") != C_OK)
        return;

    long long base;
    __atomic_load(&g_pserver->mstime, &base, __ATOMIC_ACQUIRE);
    if (getLongLongFromObject(c->argv[ARG_EXPIRE+1], &base) == C_OK) {
        arg_offset++;
        std::swap(base, interval);
    }

    if (interval <= 0)
    {
        addReplyError(c, "interval must be positive");
        return;
    }

    long numkeys = 0;
    if (c->argc > ARG_NUMKEYS)
    {
        if (getLongFromObjectOrReply(c, c->argv[ARG_NUMKEYS], &numkeys, NULL) != C_OK)
            return;
        
        if (c->argc < (6 + numkeys)) {
            addReplyError(c, "Missing arguments or numkeys is too big");
            return;
        }
    }

    std::unique_ptr<cronjob> spjob = std::make_unique<cronjob>();
    spjob->script = sdsstring(sdsdup(szFromObj(c->argv[ARG_SCRIPT])));
    spjob->interval = (uint64_t)interval;
    spjob->startTime = (uint64_t)base;
    spjob->fSingleShot = fSingleShot;
    spjob->dbNum = dbnumFromDb(c->db);
    for (long i = 0; i < numkeys; ++i)
        spjob->veckeys.emplace_back(sdsdup(szFromObj(c->argv[ARG_KEYSTART+i])));
    for (long i = ARG_KEYSTART + numkeys; i < c->argc; ++i)