| /memcached-1.4.29/t/ |
| H A D | multiversioning.t | 26 my $buf;
27 is(read($sock, $buf, $size / 2), $size / 2, "read half the answer back");
28 like($buf, qr/VALUE big/, "buf has big value header in it");
29 like($buf, qr/abcdef/, "buf has some data in it");
30 unlike($buf, qr/abcde\]/, "buf doesn't yet close");
41 $buf .= <$sock>;
42 $buf .= <$sock>;
43 like($buf, qr/abcde\]/, "buf now closes");
|
| H A D | binary-sasl.t | 312 my $buf = sprintf("%c%s%c%s", 0, $user, 0, $pass);
313 my ($status, $rv, undef) = $self->_do_command(::CMD_SASL_AUTH, $mech, $buf, '');
406 $self->{socket}->recv(my $buf, $remaining - length($rv));
407 $rv .= $buf;
|
| H A D | binary.t | 624 $self->{socket}->recv(my $buf, $remaining - length($rv));
625 $rv .= $buf;
|
| /memcached-1.4.29/ |
| H A D | util.c | 104 char buf[1024]; in vperror() local
108 if (vsnprintf(buf, sizeof(buf), fmt, ap) == -1) { in vperror()
109 buf[sizeof(buf) - 1] = '\0'; in vperror()
115 perror(buf); in vperror()
|
| H A D | logger.c | 297 bipbuf_push(w->buf, total + 1); in logger_thread_write_entry()
316 bipbuf_free(w->buf); in logger_thread_close_watcher()
331 data = bipbuf_peek_all(l->buf, &size); in logger_thread_read()
356 data = bipbuf_poll(l->buf, size); in logger_thread_read()
430 char buf[1]; in logger_thread_poll_watchers() local
431 int res = read(w->sfd, buf, 1); in logger_thread_poll_watchers()
465 bipbuf_poll(w->buf, total); in logger_thread_poll_watchers()
584 l->buf = bipbuf_new(settings.logger_buf_size); in logger_create()
585 if (l->buf == NULL) { in logger_create()
641 bipbuf_t *buf = l->buf; in logger_log() local
[all …]
|
| H A D | thread.c | 159 char buf[1]; in pause_threads() local
162 buf[0] = 0; in pause_threads()
169 buf[0] = 'p'; in pause_threads()
186 if (buf[0] == 0) { in pause_threads()
393 char buf[1]; in thread_libevent_process() local
396 if (read(fd, buf, 1) != 1) { in thread_libevent_process()
402 switch (buf[0]) { in thread_libevent_process()
454 char buf[1]; in dispatch_conn_new() local
477 buf[0] = 'c'; in dispatch_conn_new()
478 if (write(thread->notify_send_fd, buf, 1) != 1) { in dispatch_conn_new()
[all …]
|
| H A D | testapp.c | 496 char buf[80] = { 0 }; in test_vperror() local
499 char *prv = fgets(buf, sizeof(buf), efile); in test_vperror()
520 const char* ptr = buf; in send_ascii_command()
521 size_t len = strlen(buf); in send_ascii_command()
670 const char* ptr = buf; in safe_send()
745 char *ptr = buf; in safe_recv_packet()
753 ptr = buf; in safe_recv_packet()
770 static off_t storage_command(char*buf, in storage_command() argument
803 static off_t ext_command(char* buf, in ext_command() argument
840 static off_t raw_command(char* buf, in raw_command() argument
[all …]
|
| H A D | stats.c | 171 char *buf; in stats_prefix_dump() local
186 buf = malloc(size); in stats_prefix_dump()
187 if (NULL == buf) { in stats_prefix_dump()
196 written = snprintf(buf + pos, size-pos, format, in stats_prefix_dump()
206 memcpy(buf + pos, "END\r\n", 6); in stats_prefix_dump()
209 return buf; in stats_prefix_dump()
|
| H A D | logger.h | 101 bipbuf_t *buf; member
118 bipbuf_t *buf; /* per-watcher output buffer */ member
|
| H A D | memcached.c | 876 buf = ((char *)buf) + len; in add_iov()
1022 char buf[2]; in complete_nread_ascii() local
1576 buf += klen; in append_bin_stats()
2742 if (buf) { in write_and_free()
3091 char *buf; in process_stat() local
3584 res = strlen(buf); in do_add_delta()
4190 c->request_id = buf[0] * 256 + buf[1]; in try_read_udp()
4193 if (buf[4] != 0 || buf[5] != 1) { in try_read_udp()
5584 char *buf; in main() local
5860 unit = buf[strlen(buf)-1]; in main()
[all …]
|
| H A D | configure.ac | 489 char *buf = malloc(32);
491 uint64_t *ptr = (uint64_t*)(buf+2);
501 *(buf + 0) = 1;
502 *(buf + 1) = 2;
503 *(buf + 2) = 3;
504 *(buf + 3) = 4;
505 *(buf + 4) = 5;
506 int* i = (int*)(buf+1);
|
| H A D | memcached.h | 594 const int64_t delta, char *buf,
626 const int64_t delta, char *buf,
|
| /memcached-1.4.29/doc/ |
| H A D | protocol.txt | 669 | log_worker_dropped | 64u | Logs a worker never wrote due to full buf |
|