Lines Matching refs:len
57 int len; in rdbCheckThenExit() local
59 len = snprintf(msg,sizeof(msg), in rdbCheckThenExit()
62 vsnprintf(msg+len,sizeof(msg)-len,reason,ap); in rdbCheckThenExit()
75 static int rdbWriteRaw(rio *rdb, void *p, size_t len) { in rdbWriteRaw() argument
76 if (rdb && rioWrite(rdb,p,len) == 0) in rdbWriteRaw()
78 return len; in rdbWriteRaw()
114 int rdbSaveLen(rio *rdb, uint32_t len) { in rdbSaveLen() argument
118 if (len < (1<<6)) { in rdbSaveLen()
120 buf[0] = (len&0xFF)|(RDB_6BITLEN<<6); in rdbSaveLen()
123 } else if (len < (1<<14)) { in rdbSaveLen()
125 buf[0] = ((len>>8)&0xFF)|(RDB_14BITLEN<<6); in rdbSaveLen()
126 buf[1] = len&0xFF; in rdbSaveLen()
133 len = htonl(len); in rdbSaveLen()
134 if (rdbWriteRaw(rdb,&len,4) == -1) return -1; in rdbSaveLen()
145 uint32_t len; in rdbLoadLen() local
164 if (rioRead(rdb,&len,4) == 0) return RDB_LENERR; in rdbLoadLen()
165 return ntohl(len); in rdbLoadLen()
227 int len = ll2string(buf,sizeof(buf),val); in rdbLoadIntegerObject() local
228 p = zmalloc(len); in rdbLoadIntegerObject()
229 memcpy(p,buf,len); in rdbLoadIntegerObject()
241 int rdbTryIntegerEncoding(char *s, size_t len, unsigned char *enc) { in rdbTryIntegerEncoding() argument
252 if (strlen(buf) != len || memcmp(buf,s,len)) return 0; in rdbTryIntegerEncoding()
282 ssize_t rdbSaveLzfStringObject(rio *rdb, unsigned char *s, size_t len) { in rdbSaveLzfStringObject() argument
287 if (len <= 4) return 0; in rdbSaveLzfStringObject()
288 outlen = len-4; in rdbSaveLzfStringObject()
290 comprlen = lzf_compress(s, len, out, outlen); in rdbSaveLzfStringObject()
295 ssize_t nwritten = rdbSaveLzfBlob(rdb, out, comprlen, len); in rdbSaveLzfStringObject()
305 unsigned int len, clen; in rdbLoadLzfStringObject() local
310 if ((len = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadLzfStringObject()
315 val = zmalloc(len); in rdbLoadLzfStringObject()
317 if ((val = sdsnewlen(NULL,len)) == NULL) goto err; in rdbLoadLzfStringObject()
322 if (lzf_decompress(c,clen,val,len) == 0) { in rdbLoadLzfStringObject()
343 ssize_t rdbSaveRawString(rio *rdb, unsigned char *s, size_t len) { in rdbSaveRawString() argument
348 if (len <= 11) { in rdbSaveRawString()
350 if ((enclen = rdbTryIntegerEncoding((char*)s,len,buf)) > 0) { in rdbSaveRawString()
358 if (server.rdb_compression && len > 20) { in rdbSaveRawString()
359 n = rdbSaveLzfStringObject(rdb,s,len); in rdbSaveRawString()
366 if ((n = rdbSaveLen(rdb,len)) == -1) return -1; in rdbSaveRawString()
368 if (len > 0) { in rdbSaveRawString()
369 if (rdbWriteRaw(rdb,s,len) == -1) return -1; in rdbSaveRawString()
370 nwritten += len; in rdbSaveRawString()
421 uint32_t len; in rdbGenericLoadStringObject() local
423 len = rdbLoadLen(rdb,&isencoded); in rdbGenericLoadStringObject()
425 switch(len) { in rdbGenericLoadStringObject()
429 return rdbLoadIntegerObject(rdb,len,flags); in rdbGenericLoadStringObject()
433 rdbExitReportCorruptRDB("Unknown RDB string encoding type %d",len); in rdbGenericLoadStringObject()
437 if (len == RDB_LENERR) return NULL; in rdbGenericLoadStringObject()
439 robj *o = encode ? createStringObject(NULL,len) : in rdbGenericLoadStringObject()
440 createRawStringObject(NULL,len); in rdbGenericLoadStringObject()
441 if (len && rioRead(rdb,o->ptr,len) == 0) { in rdbGenericLoadStringObject()
447 void *buf = zmalloc(len); in rdbGenericLoadStringObject()
448 if (len && rioRead(rdb,buf,len) == 0) { in rdbGenericLoadStringObject()
474 int len; in rdbSaveDoubleValue() local
478 len = 1; in rdbSaveDoubleValue()
480 len = 1; in rdbSaveDoubleValue()
501 len = buf[0]+1; in rdbSaveDoubleValue()
503 return rdbWriteRaw(rdb,buf,len); in rdbSaveDoubleValue()
509 unsigned char len; in rdbLoadDoubleValue() local
511 if (rioRead(rdb,&len,1) == 0) return -1; in rdbLoadDoubleValue()
512 switch(len) { in rdbLoadDoubleValue()
517 if (rioRead(rdb,buf,len) == 0) return -1; in rdbLoadDoubleValue()
518 buf[len] = '\0'; in rdbLoadDoubleValue()
584 if ((n = rdbSaveLen(rdb,ql->len)) == -1) return -1; in rdbSaveObject()
694 ssize_t len = rdbSaveObject(NULL,o); in rdbSavedObjectLen() local
695 serverAssertWithInfo(NULL,o,len != -1); in rdbSavedObjectLen()
696 return len; in rdbSavedObjectLen()
977 size_t len; in rdbLoadObject() local
986 if ((len = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadObject()
993 while(len--) { in rdbLoadObject()
996 size_t len = sdslen(dec->ptr); in rdbLoadObject() local
997 quicklistPushTail(o->ptr, dec->ptr, len); in rdbLoadObject()
1003 if ((len = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadObject()
1006 if (len > server.set_max_intset_entries) { in rdbLoadObject()
1010 if (len > DICT_HT_INITIAL_SIZE) in rdbLoadObject()
1011 dictExpand(o->ptr,len); in rdbLoadObject()
1017 for (i = 0; i < len; i++) { in rdbLoadObject()
1028 dictExpand(o->ptr,len); in rdbLoadObject()
1074 size_t len; in rdbLoadObject() local
1077 len = rdbLoadLen(rdb, NULL); in rdbLoadObject()
1078 if (len == RDB_LENERR) return NULL; in rdbLoadObject()
1083 if (len > server.hash_max_ziplist_entries) in rdbLoadObject()
1087 while (o->encoding == OBJ_ENCODING_ZIPLIST && len > 0) { in rdbLoadObject()
1090 len--; in rdbLoadObject()
1116 while (o->encoding == OBJ_ENCODING_HT && len > 0) { in rdbLoadObject()
1119 len--; in rdbLoadObject()
1137 serverAssert(len == 0); in rdbLoadObject()
1139 if ((len = rdbLoadLen(rdb,NULL)) == RDB_LENERR) return NULL; in rdbLoadObject()
1144 while (len--) { in rdbLoadObject()
1258 void rdbLoadProgressCallback(rio *r, const void *buf, size_t len) { in rdbLoadProgressCallback() argument
1260 rioGenericUpdateChecksum(r, buf, len); in rdbLoadProgressCallback()
1262 …(r->processed_bytes + len)/server.loading_process_events_interval_bytes > r->processed_bytes/serve… in rdbLoadProgressCallback()
1665 uint64_t *len = msg; in rdbSaveToSlavesSockets() local
1666 uint64_t *ids = len+1; in rdbSaveToSlavesSockets()
1669 *len = numfds; in rdbSaveToSlavesSockets()
1680 if (*len == 0 || in rdbSaveToSlavesSockets()