Lines Matching refs:rdb
75 static int rdbWriteRaw(rio *rdb, void *p, size_t len) { in rdbWriteRaw() argument
76 if (rdb && rioWrite(rdb,p,len) == 0) in rdbWriteRaw()
81 int rdbSaveType(rio *rdb, unsigned char type) { in rdbSaveType() argument
82 return rdbWriteRaw(rdb,&type,1); in rdbSaveType()
88 int rdbLoadType(rio *rdb) { in rdbLoadType() argument
90 if (rioRead(rdb,&type,1) == 0) return -1; in rdbLoadType()
94 time_t rdbLoadTime(rio *rdb) { in rdbLoadTime() argument
96 if (rioRead(rdb,&t32,4) == 0) return -1; in rdbLoadTime()
100 int rdbSaveMillisecondTime(rio *rdb, long long t) { in rdbSaveMillisecondTime() argument
102 return rdbWriteRaw(rdb,&t64,8); in rdbSaveMillisecondTime()
105 long long rdbLoadMillisecondTime(rio *rdb) { in rdbLoadMillisecondTime() argument
107 if (rioRead(rdb,&t64,8) == 0) return -1; in rdbLoadMillisecondTime()
114 int rdbSaveLen(rio *rdb, uint32_t len) { in rdbSaveLen() argument
121 if (rdbWriteRaw(rdb,buf,1) == -1) return -1; in rdbSaveLen()
127 if (rdbWriteRaw(rdb,buf,2) == -1) return -1; in rdbSaveLen()
132 if (rdbWriteRaw(rdb,buf,1) == -1) return -1; in rdbSaveLen()
134 if (rdbWriteRaw(rdb,&len,4) == -1) return -1; in rdbSaveLen()
143 uint32_t rdbLoadLen(rio *rdb, int *isencoded) { in rdbLoadLen() argument
149 if (rioRead(rdb,buf,1) == 0) return RDB_LENERR; in rdbLoadLen()
160 if (rioRead(rdb,buf+1,1) == 0) return RDB_LENERR; in rdbLoadLen()
164 if (rioRead(rdb,&len,4) == 0) return RDB_LENERR; in rdbLoadLen()
202 void *rdbLoadIntegerObject(rio *rdb, int enctype, int flags) { in rdbLoadIntegerObject() argument
209 if (rioRead(rdb,enc,1) == 0) return NULL; in rdbLoadIntegerObject()
213 if (rioRead(rdb,enc,2) == 0) return NULL; in rdbLoadIntegerObject()
218 if (rioRead(rdb,enc,4) == 0) return NULL; in rdbLoadIntegerObject()
257 ssize_t rdbSaveLzfBlob(rio *rdb, void *data, size_t compress_len, in rdbSaveLzfBlob() argument
264 if ((n = rdbWriteRaw(rdb,&byte,1)) == -1) goto writeerr; in rdbSaveLzfBlob()
267 if ((n = rdbSaveLen(rdb,compress_len)) == -1) goto writeerr; in rdbSaveLzfBlob()
270 if ((n = rdbSaveLen(rdb,original_len)) == -1) goto writeerr; in rdbSaveLzfBlob()
273 if ((n = rdbWriteRaw(rdb,data,compress_len)) == -1) goto writeerr; in rdbSaveLzfBlob()
282 ssize_t rdbSaveLzfStringObject(rio *rdb, unsigned char *s, size_t len) { in rdbSaveLzfStringObject() argument
295 ssize_t nwritten = rdbSaveLzfBlob(rdb, out, comprlen, len); in rdbSaveLzfStringObject()
303 void *rdbLoadLzfStringObject(rio *rdb, int flags) { in rdbLoadLzfStringObject() argument
309 if ((clen = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadLzfStringObject()
310 if ((len = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadLzfStringObject()
321 if (rioRead(rdb,c,clen) == 0) goto err; in rdbLoadLzfStringObject()
343 ssize_t rdbSaveRawString(rio *rdb, unsigned char *s, size_t len) { in rdbSaveRawString() argument
351 if (rdbWriteRaw(rdb,buf,enclen) == -1) return -1; in rdbSaveRawString()
359 n = rdbSaveLzfStringObject(rdb,s,len); in rdbSaveRawString()
366 if ((n = rdbSaveLen(rdb,len)) == -1) return -1; in rdbSaveRawString()
369 if (rdbWriteRaw(rdb,s,len) == -1) return -1; in rdbSaveRawString()
376 ssize_t rdbSaveLongLongAsStringObject(rio *rdb, long long value) { in rdbSaveLongLongAsStringObject() argument
381 return rdbWriteRaw(rdb,buf,enclen); in rdbSaveLongLongAsStringObject()
386 if ((n = rdbSaveLen(rdb,enclen)) == -1) return -1; in rdbSaveLongLongAsStringObject()
388 if ((n = rdbWriteRaw(rdb,buf,enclen)) == -1) return -1; in rdbSaveLongLongAsStringObject()
395 int rdbSaveStringObject(rio *rdb, robj *obj) { in rdbSaveStringObject() argument
399 return rdbSaveLongLongAsStringObject(rdb,(long)obj->ptr); in rdbSaveStringObject()
402 return rdbSaveRawString(rdb,obj->ptr,sdslen(obj->ptr)); in rdbSaveStringObject()
417 void *rdbGenericLoadStringObject(rio *rdb, int flags) { in rdbGenericLoadStringObject() argument
423 len = rdbLoadLen(rdb,&isencoded); in rdbGenericLoadStringObject()
429 return rdbLoadIntegerObject(rdb,len,flags); in rdbGenericLoadStringObject()
431 return rdbLoadLzfStringObject(rdb,flags); in rdbGenericLoadStringObject()
441 if (len && rioRead(rdb,o->ptr,len) == 0) { in rdbGenericLoadStringObject()
448 if (len && rioRead(rdb,buf,len) == 0) { in rdbGenericLoadStringObject()
456 robj *rdbLoadStringObject(rio *rdb) { in rdbLoadStringObject() argument
457 return rdbGenericLoadStringObject(rdb,RDB_LOAD_NONE); in rdbLoadStringObject()
460 robj *rdbLoadEncodedStringObject(rio *rdb) { in rdbLoadEncodedStringObject() argument
461 return rdbGenericLoadStringObject(rdb,RDB_LOAD_ENC); in rdbLoadEncodedStringObject()
472 int rdbSaveDoubleValue(rio *rdb, double val) { in rdbSaveDoubleValue() argument
503 return rdbWriteRaw(rdb,buf,len); in rdbSaveDoubleValue()
507 int rdbLoadDoubleValue(rio *rdb, double *val) { in rdbLoadDoubleValue() argument
511 if (rioRead(rdb,&len,1) == 0) return -1; in rdbLoadDoubleValue()
517 if (rioRead(rdb,buf,len) == 0) return -1; in rdbLoadDoubleValue()
525 int rdbSaveObjectType(rio *rdb, robj *o) { in rdbSaveObjectType() argument
528 return rdbSaveType(rdb,RDB_TYPE_STRING); in rdbSaveObjectType()
531 return rdbSaveType(rdb,RDB_TYPE_LIST_QUICKLIST); in rdbSaveObjectType()
536 return rdbSaveType(rdb,RDB_TYPE_SET_INTSET); in rdbSaveObjectType()
538 return rdbSaveType(rdb,RDB_TYPE_SET); in rdbSaveObjectType()
543 return rdbSaveType(rdb,RDB_TYPE_ZSET_ZIPLIST); in rdbSaveObjectType()
545 return rdbSaveType(rdb,RDB_TYPE_ZSET); in rdbSaveObjectType()
550 return rdbSaveType(rdb,RDB_TYPE_HASH_ZIPLIST); in rdbSaveObjectType()
552 return rdbSaveType(rdb,RDB_TYPE_HASH); in rdbSaveObjectType()
563 int rdbLoadObjectType(rio *rdb) { in rdbLoadObjectType() argument
565 if ((type = rdbLoadType(rdb)) == -1) return -1; in rdbLoadObjectType()
571 ssize_t rdbSaveObject(rio *rdb, robj *o) { in rdbSaveObject() argument
576 if ((n = rdbSaveStringObject(rdb,o)) == -1) return -1; in rdbSaveObject()
584 if ((n = rdbSaveLen(rdb,ql->len)) == -1) return -1; in rdbSaveObject()
591 if ((n = rdbSaveLzfBlob(rdb,data,compress_len,node->sz)) == -1) return -1; in rdbSaveObject()
594 if ((n = rdbSaveRawString(rdb,node->zl,node->sz)) == -1) return -1; in rdbSaveObject()
608 if ((n = rdbSaveLen(rdb,dictSize(set))) == -1) return -1; in rdbSaveObject()
613 if ((n = rdbSaveStringObject(rdb,eleobj)) == -1) return -1; in rdbSaveObject()
620 if ((n = rdbSaveRawString(rdb,o->ptr,l)) == -1) return -1; in rdbSaveObject()
630 if ((n = rdbSaveRawString(rdb,o->ptr,l)) == -1) return -1; in rdbSaveObject()
637 if ((n = rdbSaveLen(rdb,dictSize(zs->dict))) == -1) return -1; in rdbSaveObject()
644 if ((n = rdbSaveStringObject(rdb,eleobj)) == -1) return -1; in rdbSaveObject()
646 if ((n = rdbSaveDoubleValue(rdb,*score)) == -1) return -1; in rdbSaveObject()
658 if ((n = rdbSaveRawString(rdb,o->ptr,l)) == -1) return -1; in rdbSaveObject()
665 if ((n = rdbSaveLen(rdb,dictSize((dict*)o->ptr))) == -1) return -1; in rdbSaveObject()
672 if ((n = rdbSaveStringObject(rdb,key)) == -1) return -1; in rdbSaveObject()
674 if ((n = rdbSaveStringObject(rdb,val)) == -1) return -1; in rdbSaveObject()
703 int rdbSaveKeyValuePair(rio *rdb, robj *key, robj *val, in rdbSaveKeyValuePair() argument
710 if (rdbSaveType(rdb,RDB_OPCODE_EXPIRETIME_MS) == -1) return -1; in rdbSaveKeyValuePair()
711 if (rdbSaveMillisecondTime(rdb,expiretime) == -1) return -1; in rdbSaveKeyValuePair()
715 if (rdbSaveObjectType(rdb,val) == -1) return -1; in rdbSaveKeyValuePair()
716 if (rdbSaveStringObject(rdb,key) == -1) return -1; in rdbSaveKeyValuePair()
717 if (rdbSaveObject(rdb,val) == -1) return -1; in rdbSaveKeyValuePair()
722 int rdbSaveAuxField(rio *rdb, void *key, size_t keylen, void *val, size_t vallen) { in rdbSaveAuxField() argument
723 if (rdbSaveType(rdb,RDB_OPCODE_AUX) == -1) return -1; in rdbSaveAuxField()
724 if (rdbSaveRawString(rdb,key,keylen) == -1) return -1; in rdbSaveAuxField()
725 if (rdbSaveRawString(rdb,val,vallen) == -1) return -1; in rdbSaveAuxField()
731 int rdbSaveAuxFieldStrStr(rio *rdb, char *key, char *val) { in rdbSaveAuxFieldStrStr() argument
732 return rdbSaveAuxField(rdb,key,strlen(key),val,strlen(val)); in rdbSaveAuxFieldStrStr()
736 int rdbSaveAuxFieldStrInt(rio *rdb, char *key, long long val) { in rdbSaveAuxFieldStrInt() argument
739 return rdbSaveAuxField(rdb,key,strlen(key),buf,vlen); in rdbSaveAuxFieldStrInt()
743 int rdbSaveInfoAuxFields(rio *rdb) { in rdbSaveInfoAuxFields() argument
747 if (rdbSaveAuxFieldStrStr(rdb,"redis-ver",REDIS_VERSION) == -1) return -1; in rdbSaveInfoAuxFields()
748 if (rdbSaveAuxFieldStrInt(rdb,"redis-bits",redis_bits) == -1) return -1; in rdbSaveInfoAuxFields()
749 if (rdbSaveAuxFieldStrInt(rdb,"ctime",time(NULL)) == -1) return -1; in rdbSaveInfoAuxFields()
750 if (rdbSaveAuxFieldStrInt(rdb,"used-mem",zmalloc_used_memory()) == -1) return -1; in rdbSaveInfoAuxFields()
762 int rdbSaveRio(rio *rdb, int *error) { in rdbSaveRio() argument
771 rdb->update_cksum = rioGenericUpdateChecksum; in rdbSaveRio()
773 if (rdbWriteRaw(rdb,magic,9) == -1) goto werr; in rdbSaveRio()
774 if (rdbSaveInfoAuxFields(rdb) == -1) goto werr; in rdbSaveRio()
784 if (rdbSaveType(rdb,RDB_OPCODE_SELECTDB) == -1) goto werr; in rdbSaveRio()
785 if (rdbSaveLen(rdb,j) == -1) goto werr; in rdbSaveRio()
798 if (rdbSaveType(rdb,RDB_OPCODE_RESIZEDB) == -1) goto werr; in rdbSaveRio()
799 if (rdbSaveLen(rdb,db_size) == -1) goto werr; in rdbSaveRio()
800 if (rdbSaveLen(rdb,expires_size) == -1) goto werr; in rdbSaveRio()
810 if (rdbSaveKeyValuePair(rdb,&key,o,expire,now) == -1) goto werr; in rdbSaveRio()
817 if (rdbSaveType(rdb,RDB_OPCODE_EOF) == -1) goto werr; in rdbSaveRio()
821 cksum = rdb->cksum; in rdbSaveRio()
823 if (rioWrite(rdb,&cksum,8) == 0) goto werr; in rdbSaveRio()
840 int rdbSaveRioWithEOFMark(rio *rdb, int *error) { in rdbSaveRioWithEOFMark() argument
845 if (rioWrite(rdb,"$EOF:",5) == 0) goto werr; in rdbSaveRioWithEOFMark()
846 if (rioWrite(rdb,eofmark,RDB_EOF_MARK_SIZE) == 0) goto werr; in rdbSaveRioWithEOFMark()
847 if (rioWrite(rdb,"\r\n",2) == 0) goto werr; in rdbSaveRioWithEOFMark()
848 if (rdbSaveRio(rdb,error) == C_ERR) goto werr; in rdbSaveRioWithEOFMark()
849 if (rioWrite(rdb,eofmark,RDB_EOF_MARK_SIZE) == 0) goto werr; in rdbSaveRioWithEOFMark()
863 rio rdb; in rdbSave() local
879 rioInitWithFile(&rdb,fp); in rdbSave()
880 if (rdbSaveRio(&rdb,&error) == C_ERR) { in rdbSave()
975 robj *rdbLoadObject(int rdbtype, rio *rdb) { in rdbLoadObject() argument
982 if ((o = rdbLoadEncodedStringObject(rdb)) == NULL) return NULL; in rdbLoadObject()
986 if ((len = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadObject()
994 if ((ele = rdbLoadEncodedStringObject(rdb)) == NULL) return NULL; in rdbLoadObject()
1003 if ((len = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadObject()
1019 if ((ele = rdbLoadEncodedStringObject(rdb)) == NULL) return NULL; in rdbLoadObject()
1046 if ((zsetlen = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadObject()
1056 if ((ele = rdbLoadEncodedStringObject(rdb)) == NULL) return NULL; in rdbLoadObject()
1058 if (rdbLoadDoubleValue(rdb,&score) == -1) return NULL; in rdbLoadObject()
1077 len = rdbLoadLen(rdb, NULL); in rdbLoadObject()
1092 field = rdbLoadStringObject(rdb); in rdbLoadObject()
1095 value = rdbLoadStringObject(rdb); in rdbLoadObject()
1121 field = rdbLoadEncodedStringObject(rdb); in rdbLoadObject()
1123 value = rdbLoadEncodedStringObject(rdb); in rdbLoadObject()
1139 if ((len = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadObject()
1145 unsigned char *zl = rdbGenericLoadStringObject(rdb,RDB_LOAD_PLAIN); in rdbLoadObject()
1155 unsigned char *encoded = rdbGenericLoadStringObject(rdb,RDB_LOAD_PLAIN); in rdbLoadObject()
1282 rio rdb; in rdbLoad() local
1286 rioInitWithFile(&rdb,fp); in rdbLoad()
1287 rdb.update_cksum = rdbLoadProgressCallback; in rdbLoad()
1288 rdb.max_processing_chunk = server.loading_process_events_interval_bytes; in rdbLoad()
1289 if (rioRead(&rdb,buf,9) == 0) goto eoferr; in rdbLoad()
1311 if ((type = rdbLoadType(&rdb)) == -1) goto eoferr; in rdbLoad()
1318 if ((expiretime = rdbLoadTime(&rdb)) == -1) goto eoferr; in rdbLoad()
1320 if ((type = rdbLoadType(&rdb)) == -1) goto eoferr; in rdbLoad()
1327 if ((expiretime = rdbLoadMillisecondTime(&rdb)) == -1) goto eoferr; in rdbLoad()
1329 if ((type = rdbLoadType(&rdb)) == -1) goto eoferr; in rdbLoad()
1335 if ((dbid = rdbLoadLen(&rdb,NULL)) == RDB_LENERR) in rdbLoad()
1350 if ((db_size = rdbLoadLen(&rdb,NULL)) == RDB_LENERR) in rdbLoad()
1352 if ((expires_size = rdbLoadLen(&rdb,NULL)) == RDB_LENERR) in rdbLoad()
1364 if ((auxkey = rdbLoadStringObject(&rdb)) == NULL) goto eoferr; in rdbLoad()
1365 if ((auxval = rdbLoadStringObject(&rdb)) == NULL) goto eoferr; in rdbLoad()
1387 if ((key = rdbLoadStringObject(&rdb)) == NULL) goto eoferr; in rdbLoad()
1389 if ((val = rdbLoadObject(type,&rdb)) == NULL) goto eoferr; in rdbLoad()
1410 uint64_t cksum, expected = rdb.cksum; in rdbLoad()
1412 if (rioRead(&rdb,&cksum,8) == 0) goto eoferr; in rdbLoad()