115     unsigned char buf[2];  in rdbSaveLen()  local
120         buf[0] = (len&0xFF)|(RDB_6BITLEN<<6);  in rdbSaveLen()
121         if (rdbWriteRaw(rdb,buf,1) == -1) return -1;  in rdbSaveLen()
125         buf[0] = ((len>>8)&0xFF)|(RDB_14BITLEN<<6);  in rdbSaveLen()
126         buf[1] = len&0xFF;  in rdbSaveLen()
127         if (rdbWriteRaw(rdb,buf,2) == -1) return -1;  in rdbSaveLen()
131         buf[0] = (RDB_32BITLEN<<6);  in rdbSaveLen()
132         if (rdbWriteRaw(rdb,buf,1) == -1) return -1;  in rdbSaveLen()
144     unsigned char buf[2];  in rdbLoadLen()  local
149     if (rioRead(rdb,buf,1) == 0) return RDB_LENERR;  in rdbLoadLen()
150     type = (buf[0]&0xC0)>>6;  in rdbLoadLen()
154         return buf[0]&0x3F;  in rdbLoadLen()
157         return buf[0]&0x3F;  in rdbLoadLen()
160         if (rioRead(rdb,buf+1,1) == 0) return RDB_LENERR;  in rdbLoadLen()
161         return ((buf[0]&0x3F)<<8)|buf[1];  in rdbLoadLen()
226         char buf[LONG_STR_SIZE], *p;  in rdbLoadIntegerObject()  local
227         int len = ll2string(buf,sizeof(buf),val);  in rdbLoadIntegerObject()
229         memcpy(p,buf,len);  in rdbLoadIntegerObject()
243     char *endptr, buf[32];  in rdbTryIntegerEncoding()  local
248     ll2string(buf,32,value);  in rdbTryIntegerEncoding()
252     if (strlen(buf) != len || memcmp(buf,s,len)) return 0;  in rdbTryIntegerEncoding()
349         unsigned char buf[5];  in rdbSaveRawString()  local
350         if ((enclen = rdbTryIntegerEncoding((char*)s,len,buf)) > 0) {  in rdbSaveRawString()
351             if (rdbWriteRaw(rdb,buf,enclen) == -1) return -1;  in rdbSaveRawString()
377     unsigned char buf[32];  in rdbSaveLongLongAsStringObject()  local
379     int enclen = rdbEncodeInteger(value,buf);  in rdbSaveLongLongAsStringObject()
381         return rdbWriteRaw(rdb,buf,enclen);  in rdbSaveLongLongAsStringObject()
384         enclen = ll2string((char*)buf,32,value);  in rdbSaveLongLongAsStringObject()
388         if ((n = rdbWriteRaw(rdb,buf,enclen)) == -1) return -1;  in rdbSaveLongLongAsStringObject()
447         void *buf = zmalloc(len);  in rdbGenericLoadStringObject()  local
448         if (len && rioRead(rdb,buf,len) == 0) {  in rdbGenericLoadStringObject()
449             zfree(buf);  in rdbGenericLoadStringObject()
452         return buf;  in rdbGenericLoadStringObject()
473     unsigned char buf[128];  in rdbSaveDoubleValue()  local
477         buf[0] = 253;  in rdbSaveDoubleValue()
481         buf[0] = (val < 0) ? 255 : 254;  in rdbSaveDoubleValue()
496             ll2string((char*)buf+1,sizeof(buf)-1,(long long)val);  in rdbSaveDoubleValue()
499             snprintf((char*)buf+1,sizeof(buf)-1,"%.17g",val);  in rdbSaveDoubleValue()
500         buf[0] = strlen((char*)buf+1);  in rdbSaveDoubleValue()
501         len = buf[0]+1;  in rdbSaveDoubleValue()
503     return rdbWriteRaw(rdb,buf,len);  in rdbSaveDoubleValue()
508     char buf[256];  in rdbLoadDoubleValue()  local
517         if (rioRead(rdb,buf,len) == 0) return -1;  in rdbLoadDoubleValue()
518         buf[len] = '\0';  in rdbLoadDoubleValue()
519         sscanf(buf, "%lg", val);  in rdbLoadDoubleValue()
737     char buf[LONG_STR_SIZE];  in rdbSaveAuxFieldStrInt()  local
738     int vlen = ll2string(buf,sizeof(buf),val);  in rdbSaveAuxFieldStrInt()
739     return rdbSaveAuxField(rdb,key,strlen(key),buf,vlen);  in rdbSaveAuxFieldStrInt()
1258 void rdbLoadProgressCallback(rio *r, const void *buf, size_t len) {  in rdbLoadProgressCallback()  argument
1260         rioGenericUpdateChecksum(r, buf, len);  in rdbLoadProgressCallback()
1279     char buf[1024];  in rdbLoad()  local
1289     if (rioRead(&rdb,buf,9) == 0) goto eoferr;  in rdbLoad()
1290     buf[9] = '\0';  in rdbLoad()
1291     if (memcmp(buf,"REDIS",5) != 0) {  in rdbLoad()
1297     rdbver = atoi(buf+5);  in rdbLoad()