Home
last modified time | relevance | path

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

12

/memcached-1.6.32/t/
Dmultiversioning.t26 my $buf;
30 my $read_bytes = $sock->sysread($buf,
38 like($buf, qr/VALUE big/, "buf has big value header in it");
39 like($buf, qr/abcdef/, "buf has some data in it");
40 unlike($buf, qr/abcde\]/, "buf doesn't yet close");
51 $buf .= <$sock>;
52 $buf .= <$sock>;
53 like($buf, qr/abcde\]/, "buf now closes");
Dbinary-sasl.t320 my $buf = sprintf("%c%s@%s%c%s", 0, $user, $sasl_realm, 0, $pass);
321 my ($status, $rv, undef) = $self->_do_command(::CMD_SASL_AUTH, $mech, $buf, '');
327 my $buf = sprintf("%c%s@%s%c%s", 0, $user, $sasl_realm, 0, $pass);
328 my ($status, $rv, undef) = $self->_do_command(::CMD_SASL_STEP, $mech, $buf, '');
421 $self->{socket}->recv(my $buf, $remaining - length($rv));
422 $rv .= $buf;
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c154 const char *p = buf+6; in _mcmc_parse_value_line()
232 int statlen = l - (p - buf) - 2; in _mcmc_parse_stat_line()
246 const char *cur = buf; in _mcmc_parse_response()
260 rlen = cur - buf; in _mcmc_parse_response()
265 if (buf[0] >= '0' && buf[0] <= '9') { in _mcmc_parse_response()
290 switch (buf[0]) { in _mcmc_parse_response()
292 if (buf[1] == 'N') { in _mcmc_parse_response()
299 if (buf[1] == 'D') { in _mcmc_parse_response()
305 if (buf[1] == 'N') { in _mcmc_parse_response()
740 el = memchr(buf, '\n', read); in mcmc_parse_buf()
[all …]
Dexample.c44 char *buf = val + resp.vlen_read; in show_response_buffer() local
47 int read = recv(mcmc_fd(c), buf, toread, 0); in show_response_buffer()
/memcached-1.6.32/
Dtestapp.c310 char *buf; in test_stats_prefix_dump() local
320 free(buf); in test_stats_prefix_dump()
325 free(buf); in test_stats_prefix_dump()
330 free(buf); in test_stats_prefix_dump()
335 free(buf); in test_stats_prefix_dump()
341 free(buf); in test_stats_prefix_dump()
348 free(buf); in test_stats_prefix_dump()
368 free(buf); in test_stats_prefix_dump()
766 char *prv = fgets(buf, sizeof(buf), efile); in test_vperror()
1049 char *ptr = buf; in safe_recv_packet()
[all …]
Dcrc32c.c52 uint32_t crc32c_sw_little(uint32_t crc, void const *buf, size_t len);
53 uint32_t crc32c_sw_big(uint32_t crc, void const *buf, size_t len);
161 static uint32_t crc32c_hw(uint32_t crc, void const *buf, size_t len) { in crc32c_hw() argument
171 unsigned char const *next = buf; in crc32c_hw()
301 unsigned char const *next = buf; in crc32c_hw()
394 unsigned char const *next = buf; in crc32c_sw_little()
467 uint32_t crc32c_sw_big(uint32_t crc, void const *buf, size_t len) { in crc32c_sw_big() argument
468 unsigned char const *next = buf; in crc32c_sw_big()
507 uint32_t crc32c_sw(uint32_t crc, void const *buf, size_t len) { in crc32c_sw() argument
510 return crc32c_sw_little(crc, buf, len); in crc32c_sw()
[all …]
Dstats_prefix.c128 char *buf; in stats_prefix_dump() local
145 buf = malloc(size); in stats_prefix_dump()
146 if (NULL == buf) { in stats_prefix_dump()
155 written = snprintf(buf + pos, size-pos, format, in stats_prefix_dump()
167 memcpy(buf + pos, "END\r\n", 6); in stats_prefix_dump()
170 return buf; in stats_prefix_dump()
Dutil.c225 char buf[1024]; in vperror() local
229 if (vsnprintf(buf, sizeof(buf), fmt, ap) == -1) { in vperror()
230 buf[sizeof(buf) - 1] = '\0'; in vperror()
236 perror(buf); in vperror()
Dcrawler.c34 char *buf; /* output buffer */ member
135 free(c->buf); in lru_crawler_close_client()
136 c->buf = NULL; in lru_crawler_close_client()
143 free(c->buf); in lru_crawler_release_client()
144 c->buf = NULL; in lru_crawler_release_client()
149 char *nb = realloc(c->buf, c->buflen); in lru_crawler_expand_buf()
153 c->buf = nb; in lru_crawler_expand_buf()
366 memcpy(cm->c.buf, "EN\r\n", 4); in crawler_mgdump_finalize()
397 char buf[1]; in lru_crawler_write() local
747 crawlc->buf = malloc(size); in lru_crawler_set_client()
[all …]
Dcrc32c.h15 typedef uint32_t (*crc_func)(uint32_t crc, const void *buf, size_t len);
21 uint32_t crc32c_sw(uint32_t crc, void const *buf, size_t len);
Dproxy_result.c90 mcmc_parse_buf(r->buf, r->blen, &reresp); in mcplib_response_flag_blank()
125 if (r->buf != NULL) { in mcp_response_cleanup()
130 free(r->buf); in mcp_response_cleanup()
131 r->buf = NULL; in mcp_response_cleanup()
Dlogger.c696 bipbuf_push(w->buf, total); in logger_thread_write_entry()
715 bipbuf_free(w->buf); in logger_thread_close_watcher()
730 data = bipbuf_peek_all(l->buf, &size); in logger_thread_read()
755 data = bipbuf_poll(l->buf, size); in logger_thread_read()
791 data = bipbuf_peek_all(w->buf, &data_size); in logger_thread_poll_watchers()
829 char buf[1]; in logger_thread_poll_watchers() local
865 bipbuf_poll(w->buf, total); in logger_thread_poll_watchers()
1001 l->buf = bipbuf_new(settings.logger_buf_size); in logger_create()
1002 if (l->buf == NULL) { in logger_create()
1022 bipbuf_t *buf = l->buf; in logger_log() local
[all …]
Dextstore.c47 char *buf; member
131 b->buf = calloc(size, sizeof(char)); in wbuf_new()
132 if (b->buf == NULL) { in wbuf_new()
136 b->buf_pos = b->buf; in wbuf_new()
513 wbuf->buf_pos = wbuf->buf; in _allocate_wbuf()
567 memset(w->buf + (w->size - w->free), 0, w->free); in _submit_wbuf()
575 io->buf = w->buf; in _submit_wbuf()
638 io->buf = p->wbuf->buf_pos; in extstore_write_request()
819 memcpy(io->buf, wbuf->buf + (io->offset - wbuf->offset), io->len); in _read_from_wbuf()
826 memcpy(iov->iov_base, wbuf->buf + off, iov->iov_len); in _read_from_wbuf()
[all …]
Dproxy_config.c16 char *buf; member
27 char *nb = realloc(db->buf, db->size); in _dump_helper()
31 db->buf = nb; in _dump_helper()
33 memcpy(db->buf + db->used, (const char *)p, sz); in _dump_helper()
47 return db->buf; in _load_helper()
423 db->buf = calloc(db->size, 1); in proxy_init_startfiles()
425 if (db->buf == NULL || db->fname == NULL) { in proxy_init_startfiles()
455 memset(db->buf, 0, db->size); in proxy_load_files()
Dtls.c20 static ssize_t ssl_read(conn *c, void *buf, size_t count);
22 static ssize_t ssl_write(conn *c, void *buf, size_t count);
161 static ssize_t ssl_read(conn *c, void *buf, size_t count) { in ssl_read() argument
167 ssize_t ret = SSL_read(c->ssl, buf, count); in ssl_read()
200 static ssize_t ssl_write(conn *c, void *buf, size_t count) { in ssl_write() argument
203 ssize_t ret = SSL_write(c->ssl, buf, count); in ssl_write()
Dthread.c345 char buf[1] = "c"; in notify_worker() local
346 if (write(t->n.notify_send_fd, buf, 1) != 1) { in notify_worker()
559 char buf[MAX_PIPE_EVENTS]; in thread_libevent_ionotify() local
561 ev_count = read(fd, buf, MAX_PIPE_EVENTS); in thread_libevent_ionotify()
602 char buf[MAX_PIPE_EVENTS]; in thread_libevent_process() local
604 ev_count = read(fd, buf, MAX_PIPE_EVENTS); in thread_libevent_process()
842 char buf[1] = "c"; in return_io_pending()
843 if (write(t->ion.notify_send_fd, buf, 1) != 1) { in return_io_pending()
947 const int64_t delta, char *buf, in add_delta() argument
954 ret = do_add_delta(t, key, nkey, incr, delta, buf, cas, hv, NULL); in add_delta()
Dproxy_mutator.c450 mcmc_tokenize_res(srs->buf, srs->resp.reslen, &srs->tok); in mut_step_n()
456 p->src = mcmc_token_get(srs->buf, &srs->tok, 0, &len); in mut_step_n()
687 mcmc_tokenize_res(srs->buf, srs->resp.reslen, &srs->tok); in mut_step_n()
694 const char *tok = mcmc_token_get_flag(srs->buf, &srs->tok, c->f, &len); in mut_step_n()
1039 rs->buf = malloc(total); in mcp_mut_run()
1040 if (rs->buf == NULL) { in mcp_mut_run()
1044 run->d_pos = rs->buf; in mcp_mut_run()
1049 if (mcmc_parse_buf(rs->buf, run->d_pos - rs->buf, &rs->resp) != MCMC_OK) { in mcp_mut_run()
1060 rs->blen = run->d_pos - rs->buf; in mcp_mut_run()
Dmd5.h70 md5_byte_t buf[64]; /* accumulate block */ member
Dmemcached.c1331 memcpy(buf, key, klen); in append_bin_stats()
1332 buf += klen; in append_bin_stats()
1741 if (buf) { in write_and_free()
2323 itoa_u64(value, buf);
2324 res = strlen(buf);
2434 c->request_id = buf[0] * 256 + buf[1];
2437 if (buf[4] != 0 || buf[5] != 1) {
4725 char *buf; local
5172 unit = buf[strlen(buf)-1];
5175 buf[strlen(buf)-1] = '\0';
[all …]
Dlogger.h193 bipbuf_t *buf; member
211 bipbuf_t *buf; /* per-watcher output buffer */ member
Dmemcached.h905 ssize_t (*read)(conn *c, void *buf, size_t count);
907 ssize_t (*write)(conn *c, void *buf, size_t count);
952 const int64_t delta, char *buf,
999 const int64_t delta, char *buf,
1053 void resp_add_iov(mc_resp *resp, const void *buf, int len);
1054 void resp_add_chunked_iov(mc_resp *resp, const void *buf, int len);
1065 void write_and_free(conn *c, char *buf, int bytes);
Dproxy_network.c260 char buf[1]; in proxy_event_beconn() local
261 if (read(fd, buf, 1) != 1) { in proxy_event_beconn()
372 char buf[1]; in proxy_event_handler() local
380 if (read(fd, buf, 1) != 1) { in proxy_event_handler()
583 r->buf = malloc(r->blen + extra_space); in proxy_backend_drive_machine()
584 if (r->buf == NULL) { in proxy_backend_drive_machine()
603 memcpy(r->buf, be->rbuf, r->resp.reslen + r->resp.vlen_read); in proxy_backend_drive_machine()
613 memcpy(r->buf, be->rbuf, r->resp.reslen+r->resp.vlen_read); in proxy_backend_drive_machine()
639 memcpy(r->buf+r->blen, ENDSTR, ENDLEN); in proxy_backend_drive_machine()
669 memcpy(r->buf+r->bread, be->rbuf, tocopy); in proxy_backend_drive_machine()
Dstorage.c150 item *read_it = (item *)io->buf; in _storage_get_item_cb()
347 eio->buf = (void *)new_it; in storage_get_item()
400 item *it = (item *)io->buf; in recache_or_free()
458 p->io_ctx.buf = NULL; in recache_or_free()
533 item *buf_it = (item *) io.buf; in storage_write()
544 … memcpy((char *)io.buf+STORE_OFFSET, (char *)it+STORE_OFFSET, hdrtotal - STORE_OFFSET); in storage_write()
549 memcpy((char *)io.buf+copied, sch->data, sch->used); in storage_write()
556 … memcpy((char *)io.buf+STORE_OFFSET, (char *)it+STORE_OFFSET, io.len-STORE_OFFSET); in storage_write()
560 buf_it->exptime = crc32c(0, (char*)io.buf+STORE_OFFSET, orig_ntotal-STORE_OFFSET); in storage_write()
962 memcpy(io.buf, it, io.len); in storage_compact_readback()
[all …]
Dmd5.c343 memcpy(pms->buf + offset, p, copy); in md5_append()
348 md5_process(pms, pms->buf); in md5_append()
357 memcpy(pms->buf, p, left); in md5_append()
Dextstore.h81 char *buf; /* buffer of data to read or write to */ member

12