Function deserializeStoredObject

src/object.cpp:1630–1665

}

robj *deserializeStoredObject(const void *data, size_t cb)
{
    switch (((char*)data)[0])
    {
        case RDB_TYPE_STRING:
            return deserializeStoredStringObject(((char*)data)+1, cb-1);

        default:
            rio payload;
            int type;
            robj *obj;
            rioInitWithConstBuffer(&payload,data,cb);
            if (((type = rdbLoadObjectType(&payload)) == -1) ||
                ((obj = rdbLoadObject(type,&payload,nullptr,NULL,OBJ_MVCC_INVALID)) == nullptr))
            {
                serverPanic("Bad data format");
            }
            if (rdbLoadType(&payload) == RDB_OPCODE_AUX)
            {
                robj *auxkey, *auxval;
                if ((auxkey = rdbLoadStringObject(&payload)) == NULL) goto eoferr;
                if ((auxval = rdbLoadStringObject(&payload)) == NULL) {
                    decrRefCount(auxkey);
                    goto eoferr;
                }
                if (strcasecmp(szFromObj(auxkey), "mvcc-tstamp") == 0) {
                    setMvccTstamp(obj, strtoull(szFromObj(auxval), nullptr, 10));
                }
                decrRefCount(auxkey);
                decrRefCount(auxval);
            }
        eoferr:
            return obj;
    }
    serverPanic("Unknown object type loading from storage");
}

sds serializeStoredObject(robj_roptr o, sds sdsPrefix)
{