Lines Matching refs:len
102 static int add_iov(conn *c, const void *buf, int len);
103 static int add_chunked_item_iovs(conn *c, item *it, int len);
834 static int add_iov(conn *c, const void *buf, int len) { in add_iov() argument
861 if (limit_to_mtu && len + c->msgbytes > UDP_MAX_PAYLOAD_SIZE) { in add_iov()
862 leftover = len + c->msgbytes - UDP_MAX_PAYLOAD_SIZE; in add_iov()
863 len -= leftover; in add_iov()
870 m->msg_iov[m->msg_iovlen].iov_len = len; in add_iov()
872 c->msgbytes += len; in add_iov()
876 buf = ((char *)buf) + len; in add_iov()
877 len = leftover; in add_iov()
883 static int add_chunked_item_iovs(conn *c, item *it, int len) { in add_chunked_item_iovs() argument
887 int todo = (len > ch->used) ? ch->used : len; in add_chunked_item_iovs()
892 len -= todo; in add_chunked_item_iovs()
944 size_t len; in out_string() local
965 len = strlen(str); in out_string()
966 if ((len + 2) > c->wsize) { in out_string()
969 len = strlen(str); in out_string()
972 memcpy(c->wbuf, str, len); in out_string()
973 memcpy(c->wbuf + len, "\r\n", 2); in out_string()
974 c->wbytes = len + 2; in out_string()
1174 size_t len; in write_bin_error() local
1216 len = strlen(errstr); in write_bin_error()
1217 add_bin_header(c, err, 0, 0, len); in write_bin_error()
1218 if (len > 0) { in write_bin_error()
1219 add_iov(c, errstr, len); in write_bin_error()
1690 int len; in process_bin_stat() local
1691 char *dump_buf = stats_prefix_dump(&len); in process_bin_stat()
1692 if (dump_buf == NULL || len <= 0) { in process_bin_stat()
1696 append_stats("detailed", strlen("detailed"), dump_buf, len, c); in process_bin_stat()
2478 static void _store_item_copy_chunks(item *d_it, item *s_it, const int len) { in _store_item_copy_chunks() argument
2486 int remain = len; in _store_item_copy_chunks()
2517 while (len > done && dch) { in _store_item_copy_chunks()
2518 int todo = (dch->size - dch->used < len - done) in _store_item_copy_chunks()
2519 ? dch->size - dch->used : len - done; in _store_item_copy_chunks()
2528 assert(len == done); in _store_item_copy_chunks()
2699 size_t len = strlen(command); in tokenize_command() local
2705 for (i = 0; i < len; i++) { in tokenize_command()
2801 int len; in process_stats_detail() local
2802 char *stats = stats_prefix_dump(&len); in process_stats_detail()
2803 write_and_free(c, stats, len); in process_stats_detail()
4993 socklen_t len = sizeof(my_sockaddr); in server_socket() local
4994 if (getsockname(sfd, (struct sockaddr*)&my_sockaddr, &len)==0) { in server_socket()
5758 size_t len = strlen(settings.inter) + strlen(optarg) + 2; in main() local
5759 char *p = malloc(len); in main()
5764 snprintf(p, len, "%s,%s", settings.inter, optarg); in main()
6294 size_t len; in main() local
6298 len = strlen(portnumber_filename)+4+1; in main()
6299 temp_portnumber_filename = malloc(len); in main()
6301 len, in main()