Lines Matching refs:buf
87 static void conn_to_str(const conn *c, char *buf);
100 static void write_and_free(conn *c, char *buf, int bytes);
102 static int add_iov(conn *c, const void *buf, int len);
308 char buf[TIMEOUT_MSG_SIZE]; in conn_timeout_thread() local
339 buf[0] = 't'; in conn_timeout_thread()
340 memcpy(&buf[1], &i, sizeof(int)); in conn_timeout_thread()
341 if (write(c->thread->notify_send_fd, buf, TIMEOUT_MSG_SIZE) in conn_timeout_thread()
834 static int add_iov(conn *c, const void *buf, int len) { in add_iov() argument
869 m->msg_iov[m->msg_iovlen].iov_base = (void *)buf; in add_iov()
876 buf = ((char *)buf) + len; in add_iov()
1022 char buf[2]; in complete_nread_ascii() local
1030 buf[0] = ch->data[ch->used - 2]; in complete_nread_ascii()
1031 buf[1] = ch->data[ch->used - 1]; in complete_nread_ascii()
1035 buf[0] = ch->prev->data[ch->prev->used - 1]; in complete_nread_ascii()
1036 buf[1] = ch->data[ch->used - 1]; in complete_nread_ascii()
1038 if (strncmp(buf, "\r\n", 2) == 0) { in complete_nread_ascii()
1560 char *buf = c->stats.buffer + c->stats.offset; in append_bin_stats() local
1571 memcpy(buf, header.bytes, sizeof(header.response)); in append_bin_stats()
1572 buf += sizeof(header.response); in append_bin_stats()
1575 memcpy(buf, key, klen); in append_bin_stats()
1576 buf += klen; in append_bin_stats()
1579 memcpy(buf, val, vlen); in append_bin_stats()
2741 static void write_and_free(conn *c, char *buf, int bytes) { in write_and_free() argument
2742 if (buf) { in write_and_free()
2743 c->write_and_free = buf; in write_and_free()
2744 c->wcurr = buf; in write_and_free()
2957 static void conn_to_str(const conn *c, char *buf) { in conn_to_str() argument
2961 strcpy(buf, "<null>"); in conn_to_str()
2963 strcpy(buf, "<closed>"); in conn_to_str()
3028 sprintf(buf, "%s:%s:%u", protoname, addr_text, port); in conn_to_str()
3030 sprintf(buf, "%s:%s", protoname, addr_text); in conn_to_str()
3091 char *buf; in process_stat() local
3110 buf = item_cachedump(id, limit, &bytes); in process_stat()
3111 write_and_free(c, buf, bytes); in process_stat()
3533 char *buf, uint64_t *cas, in do_add_delta() argument
3583 snprintf(buf, INCR_MAX_STORAGE_LEN, "%llu", (unsigned long long)value); in do_add_delta()
3584 res = strlen(buf); in do_add_delta()
3597 memcpy(ITEM_data(it), buf, res); in do_add_delta()
3608 memcpy(ITEM_data(new_it), buf, res); in do_add_delta()
4184 unsigned char *buf = (unsigned char *)c->rbuf; in try_read_udp() local
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
5859 buf = strdup(optarg); in main()
5860 unit = buf[strlen(buf)-1]; in main()
5863 buf[strlen(buf)-1] = '\0'; in main()
5864 size_max = atoi(buf); in main()
5871 settings.item_size_max = atoi(buf); in main()
5873 free(buf); in main()