Home
last modified time | relevance | path

Searched refs:buf (Results 1 – 25 of 77) sorted by relevance

1234

/redis-3.2.3/src/
H A Dutil.c653 assert(string2l(buf,strlen(buf),&v) == 0); in test_string2l()
657 assert(string2l(buf,strlen(buf),&v) == 0); in test_string2l()
660 assert(string2l(buf,strlen(buf),&v) == 1); in test_string2l()
664 assert(string2l(buf,strlen(buf),&v) == 1); in test_string2l()
702 sz = ll2string(buf, sizeof buf, v); in test_ll2string()
707 sz = ll2string(buf, sizeof buf, v); in test_ll2string()
712 sz = ll2string(buf, sizeof buf, v); in test_ll2string()
717 sz = ll2string(buf, sizeof buf, v); in test_ll2string()
722 sz = ll2string(buf, sizeof buf, v); in test_ll2string()
727 sz = ll2string(buf, sizeof buf, v); in test_ll2string()
[all …]
H A Drio.h43 size_t (*read)(struct _rio *, void *buf, size_t len);
44 size_t (*write)(struct _rio *, const void *buf, size_t len);
82 sds buf; member
96 if (r->update_cksum) r->update_cksum(r,buf,bytes_to_write); in rioWrite()
97 if (r->write(r,buf,bytes_to_write) == 0) in rioWrite()
99 buf = (char*)buf + bytes_to_write; in rioWrite()
106 static inline size_t rioRead(rio *r, void *buf, size_t len) { in rioRead() argument
109 if (r->read(r,buf,bytes_to_read) == 0) in rioRead()
111 if (r->update_cksum) r->update_cksum(r,buf,bytes_to_read); in rioRead()
112 buf = (char*)buf + bytes_to_read; in rioRead()
[all …]
H A Drio.c112 retval = fwrite(buf,len,1,r->io.file.fp); in rioFileWrite()
127 return fread(buf,len,1,r->io.file.fp); in rioFileRead()
172 unsigned char *p = (unsigned char*) buf; in rioFdsetWrite()
173 int doflush = (buf == NULL && len == 0); in rioFdsetWrite()
178 r->io.fdset.buf = sdscatlen(r->io.fdset.buf,buf,len); in rioFdsetWrite()
185 len = sdslen(r->io.fdset.buf); in rioFdsetWrite()
229 if (doflush) sdsclear(r->io.fdset.buf); in rioFdsetWrite()
236 UNUSED(buf); in rioFdsetRead()
276 r->io.fdset.buf = sdsempty(); in rioInitWithFdset()
283 sdsfree(r->io.fdset.buf); in rioFreeFdset()
[all …]
H A Dendianconv.c109 char buf[32]; in endianconvTest() local
114 sprintf(buf,"ciaoroma"); in endianconvTest()
115 memrev16(buf); in endianconvTest()
116 printf("%s\n", buf); in endianconvTest()
118 sprintf(buf,"ciaoroma"); in endianconvTest()
119 memrev32(buf); in endianconvTest()
120 printf("%s\n", buf); in endianconvTest()
122 sprintf(buf,"ciaoroma"); in endianconvTest()
123 memrev64(buf); in endianconvTest()
124 printf("%s\n", buf); in endianconvTest()
H A Dredis-check-aof.c48 int consumeNewline(char *buf) { in consumeNewline() argument
49 if (strncmp(buf,"\r\n",2) != 0) { in consumeNewline()
50 ERROR("Expected \\r\\n, got: %02x%02x",buf[0],buf[1]); in consumeNewline()
57 char buf[128], *eptr; in readLong() local
59 if (fgets(buf,sizeof(buf),fp) == NULL) { in readLong()
62 if (buf[0] != prefix) { in readLong()
63 ERROR("Expected prefix '%c', got: '%c'",buf[0],prefix); in readLong()
66 *target = strtol(buf+1,&eptr,10); in readLong()
194 char buf[2]; in main() local
197 if (fgets(buf,sizeof(buf),stdin) == NULL || in main()
[all …]
H A Daof.c450 char buf[32]; in catAppendOnlyGenericCommand() local
454 buf[0] = '*'; in catAppendOnlyGenericCommand()
455 len = 1+ll2string(buf+1,sizeof(buf)-1,argc); in catAppendOnlyGenericCommand()
463 len = 1+ll2string(buf+1,sizeof(buf)-1,sdslen(o->ptr)); in catAppendOnlyGenericCommand()
505 buf = catAppendOnlyGenericCommand(buf, 3, argv); in catAppendOnlyExpireAtCommand()
508 return buf; in catAppendOnlyExpireAtCommand()
535 buf = catAppendOnlyGenericCommand(buf,3,tmpargv); in feedAppendOnlyFile()
542 buf = catAppendOnlyGenericCommand(buf,argc,argv); in feedAppendOnlyFile()
556 aofRewriteBufferAppend((unsigned char*)buf,sdslen(buf)); in feedAppendOnlyFile()
653 if (fgets(buf,sizeof(buf),fp) == NULL) { in loadAppendOnlyFile()
[all …]
H A Drdb.c161 return ((buf[0]&0x3F)<<8)|buf[1]; in rdbLoadLen()
227 int len = ll2string(buf,sizeof(buf),val); in rdbLoadIntegerObject()
252 if (strlen(buf) != len || memcmp(buf,s,len)) return 0; in rdbTryIntegerEncoding()
452 return buf; in rdbGenericLoadStringObject()
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()
508 char buf[256]; in rdbLoadDoubleValue() local
738 int vlen = ll2string(buf,sizeof(buf),val); in rdbSaveAuxFieldStrInt()
1279 char buf[1024]; in rdbLoad() local
[all …]
H A Dnotify.c99 char buf[24]; in notifyKeyspaceEvent() local
109 len = ll2string(buf,sizeof(buf),dbid); in notifyKeyspaceEvent()
110 chan = sdscatlen(chan, buf, len); in notifyKeyspaceEvent()
121 if (len == -1) len = ll2string(buf,sizeof(buf),dbid); in notifyKeyspaceEvent()
122 chan = sdscatlen(chan, buf, len); in notifyKeyspaceEvent()
H A Dziplist.c228 memcpy(p,buf,len); in zipEncodeLength()
1096 char buf[32]; in createIntList() local
1099 zl = ziplistPush(zl, (unsigned char*)buf, strlen(buf), ZIPLIST_TAIL); in createIntList()
1101 zl = ziplistPush(zl, (unsigned char*)buf, strlen(buf), ZIPLIST_TAIL); in createIntList()
1103 zl = ziplistPush(zl, (unsigned char*)buf, strlen(buf), ZIPLIST_HEAD); in createIntList()
1105 zl = ziplistPush(zl, (unsigned char*)buf, strlen(buf), ZIPLIST_HEAD); in createIntList()
1107 zl = ziplistPush(zl, (unsigned char*)buf, strlen(buf), ZIPLIST_TAIL); in createIntList()
1109 zl = ziplistPush(zl, (unsigned char*)buf, strlen(buf), ZIPLIST_TAIL); in createIntList()
1557 char buf[32]; in ziplistTest() local
1681 char buf[1024]; in ziplistTest() local
[all …]
H A Dsetproctitle.c217 char buf[SPT_MAXTITLE + 1]; /* use buffer in case argv[0] is passed */ in setproctitle() local
227 len = vsnprintf(buf, sizeof buf, fmt, ap); in setproctitle()
230 len = snprintf(buf, sizeof buf, "%s", SPT.arg0); in setproctitle()
240 memset(SPT.base, 0, spt_min(sizeof buf, SPT.end - SPT.base)); in setproctitle()
243 len = spt_min(len, spt_min(sizeof buf, SPT.end - SPT.base) - 1); in setproctitle()
244 memcpy(SPT.base, buf, len); in setproctitle()
H A Ddebug.c115 char buf[128]; in computeDatasetDigest() local
196 ll2string(buf,sizeof(buf),vll); in computeDatasetDigest()
200 snprintf(buf,sizeof(buf),"%.17g",score); in computeDatasetDigest()
201 mixDigest(eledigest,buf,strlen(buf)); in computeDatasetDigest()
217 mixDigest(eledigest,buf,strlen(buf)); in computeDatasetDigest()
441 snprintf(buf,sizeof(buf),"%s:%lu", in debugCommand()
443 key = createStringObject(buf,strlen(buf)); in debugCommand()
448 snprintf(buf,sizeof(buf),"value:%lu",j); in debugCommand()
449 val = createStringObject(buf,strlen(buf)); in debugCommand()
515 dictGetStats(buf,sizeof(buf),server.db[dbid].dict); in debugCommand()
[all …]
H A Dobject.c74 memcpy(sh->buf,ptr,len); in createEmbeddedStringObject()
75 sh->buf[len] = '\0'; in createEmbeddedStringObject()
77 memset(sh->buf,0,len+1); in createEmbeddedStringObject()
120 char buf[256]; in createStringObjectFromLongDouble() local
127 memcpy(buf,"inf",3); in createStringObjectFromLongDouble()
130 memcpy(buf,"-inf",4); in createStringObjectFromLongDouble()
139 len = snprintf(buf,sizeof(buf),"%.17Lf", value); in createStringObjectFromLongDouble()
142 char *p = buf+len-1; in createStringObjectFromLongDouble()
150 len = snprintf(buf,sizeof(buf),"%.17Lg", value); in createStringObjectFromLongDouble()
450 char buf[32]; in getDecodedObject() local
[all …]
H A Dreplication.c57 buf[0] = '\0'; in replicationGetSlaveName()
65 anetFormatAddr(buf,sizeof(buf),ip,c->slave_listening_port); in replicationGetSlaveName()
67 snprintf(buf,sizeof(buf),"%s:<unknown-slave-port>",ip); in replicationGetSlaveName()
69 snprintf(buf,sizeof(buf),"client id #%llu", in replicationGetSlaveName()
72 return buf; in replicationGetSlaveName()
388 char buf[128]; in replicationSetupSlaveForFullResync() local
401 buflen = snprintf(buf,sizeof(buf),"+FULLRESYNC %s %lld\r\n", in replicationSetupSlaveForFullResync()
419 char buf[128]; in masterTryPartialResynchronization() local
466 buflen = snprintf(buf,sizeof(buf),"+CONTINUE\r\n"); in masterTryPartialResynchronization()
985 char buf[4096]; in readSyncBulkPayload() local
[all …]
/redis-3.2.3/deps/lua/src/
H A Dfpconv.c54 char buf[8]; in fpconv_update_locale() local
56 snprintf(buf, sizeof(buf), "%g", 0.5); in fpconv_update_locale()
60 if (buf[0] != '0' || buf[2] != '5' || buf[3] != 0) { in fpconv_update_locale()
109 char *buf, *endbuf, *dp; in fpconv_strtod() local
128 if (!buf) { in fpconv_strtod()
134 buf = localbuf; in fpconv_strtod()
136 memcpy(buf, nptr, buflen); in fpconv_strtod()
137 buf[buflen] = 0; in fpconv_strtod()
140 dp = strchr(buf, '.'); in fpconv_strtod()
147 free(buf); in fpconv_strtod()
[all …]
H A Dlua_cmsgpack.c111 buf = (mp_buf*)mp_realloc(L, NULL, 0, sizeof(*buf)); in mp_buf_new()
113 buf->b = NULL; in mp_buf_new()
114 buf->len = buf->free = 0; in mp_buf_new()
115 return buf; in mp_buf_new()
122 buf->b = (unsigned char*)mp_realloc(L, buf->b, buf->len + buf->free, newsize); in mp_buf_append()
123 buf->free = newsize - buf->len; in mp_buf_append()
125 memcpy(buf->b+buf->len,s,len); in mp_buf_append()
131 mp_realloc(L, buf->b, buf->len + buf->free, 0); /* realloc to 0 = free */ in mp_buf_free()
132 mp_realloc(L, buf, sizeof(*buf), 0); in mp_buf_free()
526 lua_pushlstring(L,(char*)buf->b,buf->len); in mp_pack()
[all …]
H A Dstrbuf.c53 s->buf = NULL; in strbuf_init()
61 s->buf = malloc(size); in strbuf_init()
62 if (!s->buf) in strbuf_init()
108 if (s->buf) { in strbuf_free()
109 free(s->buf); in strbuf_free()
110 s->buf = NULL; in strbuf_free()
118 char *buf; in strbuf_free_to_string() local
124 buf = s->buf; in strbuf_free_to_string()
131 return buf; in strbuf_free_to_string()
176 s->buf = realloc(s->buf, s->size); in strbuf_resize()
[all …]
H A Dstrbuf.h35 char *buf; member
85 return s->buf != NULL; in strbuf_allocated()
103 return s->buf + s->length; in strbuf_empty_ptr()
119 s->buf[s->length++] = c; in strbuf_append_char()
124 s->buf[s->length++] = c; in strbuf_append_char_unsafe()
130 memcpy(s->buf + s->length, c, len); in strbuf_append_mem()
136 memcpy(s->buf + s->length, c, len); in strbuf_append_mem_unsafe()
142 s->buf[s->length] = 0; in strbuf_ensure_null()
150 return s->buf; in strbuf_string()
/redis-3.2.3/deps/jemalloc/test/integration/
H A Dthread_arena.c21 char buf[BUFERROR_BUF]; in thd_start() local
23 buferror(err, buf, sizeof(buf)); in thd_start()
24 test_fail("Error in mallctl(): %s", buf); in thd_start()
29 char buf[BUFERROR_BUF]; in thd_start() local
31 buferror(err, buf, sizeof(buf)); in thd_start()
32 test_fail("Error in mallctl(): %s", buf); in thd_start()
54 char buf[BUFERROR_BUF]; in TEST_BEGIN() local
56 buferror(err, buf, sizeof(buf)); in TEST_BEGIN()
57 test_fail("Error in mallctl(): %s", buf); in TEST_BEGIN()
/redis-3.2.3/deps/linenoise/
H A Dlinenoise.c263 char buf[32]; in getCursorPosition() local
276 buf[i] = '\0'; in getCursorPosition()
279 if (buf[0] != ESC || buf[1] != '[') return -1; in getCursorPosition()
371 ls->buf = saved.buf; in completeLine()
506 char *buf = l->buf; in refreshSingleLine() local
512 buf++; in refreshSingleLine()
726 memmove(l->buf+l->pos,l->buf+l->pos+1,l->len-l->pos-1); in linenoiseEditDelete()
736 memmove(l->buf+l->pos-1,l->buf+l->pos,l->len-l->pos); in linenoiseEditBackspace()
755 memmove(l->buf+l->pos,l->buf+old_pos,l->len-old_pos+1); in linenoiseEditDeletePrevWord()
776 l.buf = buf; in linenoiseEdit()
[all …]
H A Dexample.c7 void completion(const char *buf, linenoiseCompletions *lc) { in completion() argument
8 if (buf[0] == 'h') { in completion()
14 char *hints(const char *buf, int *color, int *bold) { in hints() argument
15 if (!strcasecmp(buf,"hello")) { in hints()
/redis-3.2.3/deps/jemalloc/src/
H A Dutil.c89 if (b != buf) { in buferror()
90 strncpy(buf, b, buflen); in buferror()
91 buf[buflen-1] = '\0'; in buferror()
502 char buf[D2S_BUFSIZE]; in malloc_vsnprintf() local
512 char buf[O2S_BUFSIZE]; in malloc_vsnprintf() local
521 char buf[U2S_BUFSIZE]; in malloc_vsnprintf() local
539 char buf[2]; in malloc_vsnprintf() local
544 buf[0] = val; in malloc_vsnprintf()
545 buf[1] = '\0'; in malloc_vsnprintf()
620 malloc_vsnprintf(buf, sizeof(buf), format, ap); in malloc_vcprintf()
[all …]
/redis-3.2.3/tests/support/
H A Dredis.tcl130 proc ::redis::__method__write {id fd buf} { argument
131 ::redis::redis_write $fd $buf
159 proc ::redis::redis_write {fd buf} { argument
160 puts -nonewline $fd $buf
163 proc ::redis::redis_writenl {fd buf} { argument
164 redis_write $fd $buf
170 set buf [read $fd $len]
172 return $buf
178 set buf [redis_readnl $fd $count]
179 return $buf
[all …]
/redis-3.2.3/deps/hiredis/
H A Dnet.c65 char buf[128] = { 0 }; in __redisSetErrorFromErrno() local
69 len = snprintf(buf,sizeof(buf),"%s: ",prefix); in __redisSetErrorFromErrno()
70 strerror_r(errno,buf+len,sizeof(buf)-len); in __redisSetErrorFromErrno()
71 __redisSetError(c,type,buf); in __redisSetErrorFromErrno()
292 char buf[128]; in _redisContextConnectTcp() local
293 snprintf(buf,sizeof(buf),"Can't get addr: %s",gai_strerror(rv)); in _redisContextConnectTcp()
305 char buf[128]; in _redisContextConnectTcp() local
306 snprintf(buf,sizeof(buf),"Can't bind socket: %s",strerror(errno)); in _redisContextConnectTcp()
332 char buf[128]; in _redisContextConnectTcp() local
333 snprintf(buf,sizeof(buf),"Can't create socket: %s",strerror(errno)); in _redisContextConnectTcp()
[all …]
H A Dhiredis.c99 char *buf; in createStringObject() local
105 buf = malloc(len+1); in createStringObject()
106 if (buf == NULL) { in createStringObject()
116 memcpy(buf,str,len); in createStringObject()
117 buf[len] = '\0'; in createStringObject()
118 r->str = buf; in createStringObject()
197 r->buf = NULL; in __redisReaderSetError()
319 p = r->buf+r->pos; in readLine()
397 p = r->buf+r->pos; in processBulkItem()
604 newbuf = sdscatlen(r->buf,buf,len); in redisReaderFeed()
[all …]
/redis-3.2.3/deps/jemalloc/test/unit/
H A Dutil.c141 char buf[BUFLEN]; in TEST_BEGIN() local
145 result = malloc_snprintf(buf, len, __VA_ARGS__); \ in TEST_BEGIN()
146 assert_d_eq(strncmp(buf, expected_str_untruncated, len-1), 0, \ in TEST_BEGIN()
148 buf, expected_str_untruncated); \ in TEST_BEGIN()
174 char buf[BUFLEN]; in TEST_BEGIN() local
177 result = malloc_snprintf(buf, sizeof(buf), __VA_ARGS__); \ in TEST_BEGIN()
178 assert_str_eq(buf, expected_str, "Unexpected output"); \ in TEST_BEGIN()

1234