Lines Matching refs:o
439 robj *o = encode ? createStringObject(NULL,len) : in rdbGenericLoadStringObject() local
441 if (len && rioRead(rdb,o->ptr,len) == 0) { in rdbGenericLoadStringObject()
442 decrRefCount(o); in rdbGenericLoadStringObject()
445 return o; in rdbGenericLoadStringObject()
525 int rdbSaveObjectType(rio *rdb, robj *o) { in rdbSaveObjectType() argument
526 switch (o->type) { in rdbSaveObjectType()
530 if (o->encoding == OBJ_ENCODING_QUICKLIST) in rdbSaveObjectType()
535 if (o->encoding == OBJ_ENCODING_INTSET) in rdbSaveObjectType()
537 else if (o->encoding == OBJ_ENCODING_HT) in rdbSaveObjectType()
542 if (o->encoding == OBJ_ENCODING_ZIPLIST) in rdbSaveObjectType()
544 else if (o->encoding == OBJ_ENCODING_SKIPLIST) in rdbSaveObjectType()
549 if (o->encoding == OBJ_ENCODING_ZIPLIST) in rdbSaveObjectType()
551 else if (o->encoding == OBJ_ENCODING_HT) in rdbSaveObjectType()
571 ssize_t rdbSaveObject(rio *rdb, robj *o) { in rdbSaveObject() argument
574 if (o->type == OBJ_STRING) { in rdbSaveObject()
576 if ((n = rdbSaveStringObject(rdb,o)) == -1) return -1; in rdbSaveObject()
578 } else if (o->type == OBJ_LIST) { in rdbSaveObject()
580 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in rdbSaveObject()
581 quicklist *ql = o->ptr; in rdbSaveObject()
601 } else if (o->type == OBJ_SET) { in rdbSaveObject()
603 if (o->encoding == OBJ_ENCODING_HT) { in rdbSaveObject()
604 dict *set = o->ptr; in rdbSaveObject()
617 } else if (o->encoding == OBJ_ENCODING_INTSET) { in rdbSaveObject()
618 size_t l = intsetBlobLen((intset*)o->ptr); in rdbSaveObject()
620 if ((n = rdbSaveRawString(rdb,o->ptr,l)) == -1) return -1; in rdbSaveObject()
625 } else if (o->type == OBJ_ZSET) { in rdbSaveObject()
627 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in rdbSaveObject()
628 size_t l = ziplistBlobLen((unsigned char*)o->ptr); in rdbSaveObject()
630 if ((n = rdbSaveRawString(rdb,o->ptr,l)) == -1) return -1; in rdbSaveObject()
632 } else if (o->encoding == OBJ_ENCODING_SKIPLIST) { in rdbSaveObject()
633 zset *zs = o->ptr; in rdbSaveObject()
653 } else if (o->type == OBJ_HASH) { in rdbSaveObject()
655 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in rdbSaveObject()
656 size_t l = ziplistBlobLen((unsigned char*)o->ptr); in rdbSaveObject()
658 if ((n = rdbSaveRawString(rdb,o->ptr,l)) == -1) return -1; in rdbSaveObject()
661 } else if (o->encoding == OBJ_ENCODING_HT) { in rdbSaveObject()
662 dictIterator *di = dictGetIterator(o->ptr); in rdbSaveObject()
665 if ((n = rdbSaveLen(rdb,dictSize((dict*)o->ptr))) == -1) return -1; in rdbSaveObject()
693 size_t rdbSavedObjectLen(robj *o) { in rdbSavedObjectLen() argument
694 ssize_t len = rdbSaveObject(NULL,o); in rdbSavedObjectLen()
695 serverAssertWithInfo(NULL,o,len != -1); in rdbSavedObjectLen()
805 robj key, *o = dictGetVal(de); in rdbSaveRio() local
810 if (rdbSaveKeyValuePair(rdb,&key,o,expire,now) == -1) goto werr; in rdbSaveRio()
976 robj *o = NULL, *ele, *dec; in rdbLoadObject() local
982 if ((o = rdbLoadEncodedStringObject(rdb)) == NULL) return NULL; in rdbLoadObject()
983 o = tryObjectEncoding(o); in rdbLoadObject()
988 o = createQuicklistObject(); in rdbLoadObject()
989 quicklistSetOptions(o->ptr, server.list_max_ziplist_size, in rdbLoadObject()
997 quicklistPushTail(o->ptr, dec->ptr, len); in rdbLoadObject()
1007 o = createSetObject(); in rdbLoadObject()
1011 dictExpand(o->ptr,len); in rdbLoadObject()
1013 o = createIntsetObject(); in rdbLoadObject()
1022 if (o->encoding == OBJ_ENCODING_INTSET) { in rdbLoadObject()
1025 o->ptr = intsetAdd(o->ptr,llval,NULL); in rdbLoadObject()
1027 setTypeConvert(o,OBJ_ENCODING_HT); in rdbLoadObject()
1028 dictExpand(o->ptr,len); in rdbLoadObject()
1034 if (o->encoding == OBJ_ENCODING_HT) { in rdbLoadObject()
1035 dictAdd((dict*)o->ptr,ele,NULL); in rdbLoadObject()
1047 o = createZsetObject(); in rdbLoadObject()
1048 zs = o->ptr; in rdbLoadObject()
1070 if (zsetLength(o) <= server.zset_max_ziplist_entries && in rdbLoadObject()
1072 zsetConvert(o,OBJ_ENCODING_ZIPLIST); in rdbLoadObject()
1080 o = createHashObject(); in rdbLoadObject()
1084 hashTypeConvert(o, OBJ_ENCODING_HT); in rdbLoadObject()
1087 while (o->encoding == OBJ_ENCODING_ZIPLIST && len > 0) { in rdbLoadObject()
1100 o->ptr = ziplistPush(o->ptr, field->ptr, sdslen(field->ptr), ZIPLIST_TAIL); in rdbLoadObject()
1101 o->ptr = ziplistPush(o->ptr, value->ptr, sdslen(value->ptr), ZIPLIST_TAIL); in rdbLoadObject()
1108 hashTypeConvert(o, OBJ_ENCODING_HT); in rdbLoadObject()
1116 while (o->encoding == OBJ_ENCODING_HT && len > 0) { in rdbLoadObject()
1130 ret = dictAdd((dict*)o->ptr, field, value); in rdbLoadObject()
1140 o = createQuicklistObject(); in rdbLoadObject()
1141 quicklistSetOptions(o->ptr, server.list_max_ziplist_size, in rdbLoadObject()
1147 quicklistAppendZiplist(o->ptr, zl); in rdbLoadObject()
1157 o = createObject(OBJ_STRING,encoded); /* Obj type fixed below. */ in rdbLoadObject()
1171 unsigned char *zi = zipmapRewind(o->ptr); in rdbLoadObject()
1183 zfree(o->ptr); in rdbLoadObject()
1184 o->ptr = zl; in rdbLoadObject()
1185 o->type = OBJ_HASH; in rdbLoadObject()
1186 o->encoding = OBJ_ENCODING_ZIPLIST; in rdbLoadObject()
1188 if (hashTypeLength(o) > server.hash_max_ziplist_entries || in rdbLoadObject()
1191 hashTypeConvert(o, OBJ_ENCODING_HT); in rdbLoadObject()
1196 o->type = OBJ_LIST; in rdbLoadObject()
1197 o->encoding = OBJ_ENCODING_ZIPLIST; in rdbLoadObject()
1198 listTypeConvert(o,OBJ_ENCODING_QUICKLIST); in rdbLoadObject()
1201 o->type = OBJ_SET; in rdbLoadObject()
1202 o->encoding = OBJ_ENCODING_INTSET; in rdbLoadObject()
1203 if (intsetLen(o->ptr) > server.set_max_intset_entries) in rdbLoadObject()
1204 setTypeConvert(o,OBJ_ENCODING_HT); in rdbLoadObject()
1207 o->type = OBJ_ZSET; in rdbLoadObject()
1208 o->encoding = OBJ_ENCODING_ZIPLIST; in rdbLoadObject()
1209 if (zsetLength(o) > server.zset_max_ziplist_entries) in rdbLoadObject()
1210 zsetConvert(o,OBJ_ENCODING_SKIPLIST); in rdbLoadObject()
1213 o->type = OBJ_HASH; in rdbLoadObject()
1214 o->encoding = OBJ_ENCODING_ZIPLIST; in rdbLoadObject()
1215 if (hashTypeLength(o) > server.hash_max_ziplist_entries) in rdbLoadObject()
1216 hashTypeConvert(o, OBJ_ENCODING_HT); in rdbLoadObject()
1225 return o; in rdbLoadObject()