Function mvccrestoreCommand

src/cluster.cpp:5206–5249

KEYDB.MVCCRESTORE key mvcc expire serialized-value */

/* KEYDB.MVCCRESTORE key mvcc expire serialized-value */
void mvccrestoreCommand(client *c) {
    long long expire;
    uint64_t mvcc;
    robj *key = c->argv[1], *obj = nullptr;
    int type;
    
    if (getUnsignedLongLongFromObjectOrReply(c, c->argv[2], &mvcc, "Invalid MVCC Tstamp") != C_OK)
        return;

    if (getLongLongFromObjectOrReply(c, c->argv[3], &expire, "Invalid expire") != C_OK)
        return;

    /* Verify RDB version and data checksum unles the client is already a replica or master */
    if (!(c->flags & (CLIENT_SLAVE | CLIENT_MASTER))) {
        if (verifyDumpPayload((unsigned char*)ptrFromObj(c->argv[4]),sdslen(szFromObj(c->argv[4]))) == C_ERR)
        {
            addReplyError(c,"DUMP payload version or checksum are wrong");
            return;
        }
    }

    rio payload;
    rioInitWithBuffer(&payload,szFromObj(c->argv[4]));
    if (((type = rdbLoadObjectType(&payload)) == -1) ||
        ((obj = rdbLoadObject(type,&payload,szFromObj(key),NULL,OBJ_MVCC_INVALID)) == NULL))
    {
        addReplyError(c,"Bad data format");
        return;
    }
    setMvccTstamp(obj, mvcc);

    /* Create the key and set the TTL if any */
    if (dbMerge(c->db,szFromObj(key),obj,true)) {
        if (expire >= 0) {
            setExpire(c,c->db,key,nullptr,expire);
        }
        signalModifiedKey(c,c->db,key);
        notifyKeyspaceEvent(NOTIFY_GENERIC,"restore",key,c->db->id);
    } else {
        decrRefCount(obj);
    }
    addReply(c,shared.ok);
    g_pserver->dirty++;
}

/* RESTORE key ttl serialized-value [REPLACE] */
void restoreCommand(client *c) {