Lines Matching refs:size

44     nxt_int_t     sndbuf, rcvbuf, size;  in nxt_port_socket_init()  local
90 size = sndbuf * 4; in nxt_port_socket_init()
92 if (rcvbuf < size) { in nxt_port_socket_init()
94 size); in nxt_port_socket_init()
272 ssize_t size; in nxt_port_enqueue_buf() local
277 size = nxt_buf_mem_used_size(&b->mem); in nxt_port_enqueue_buf()
279 if (size <= NXT_PORT_MAX_ENQUEUE_BUF_SIZE) { in nxt_port_enqueue_buf()
280 nxt_memcpy(qbuf, b->mem.pos, size); in nxt_port_enqueue_buf()
282 return size; in nxt_port_enqueue_buf()
291 mm->size = nxt_buf_mem_used_size(&b->mem); in nxt_port_enqueue_buf()
296 mm->size); in nxt_port_enqueue_buf()
412 sb.size = 0; in nxt_port_write_handler()
430 plain_size = sb.size; in nxt_port_write_handler()
449 if (nxt_slow_path((size_t) n != sb.size + iov[0].iov_len)) { in nxt_port_write_handler()
451 port->socket.fd, n, sb.size + iov[0].iov_len); in nxt_port_write_handler()
621 size_t size; in nxt_port_buf_completion() local
630 size = nxt_buf_used_size(b); in nxt_port_buf_completion()
632 if (size != 0) { in nxt_port_buf_completion()
646 if (sent < size) { in nxt_port_buf_completion()
666 sent -= size; in nxt_port_buf_completion()
776 msg.size = n; in nxt_port_read_handler()
863 if ((smsg = port->socket_msg) != NULL && smsg->size != 0) { in nxt_port_queue_read_handler()
866 n = smsg->size; in nxt_port_queue_read_handler()
870 smsg->size = 0; in nxt_port_queue_read_handler()
968 if (nxt_slow_path(smsg->size != 0)) { in nxt_port_queue_read_handler()
980 smsg->size = n; in nxt_port_queue_read_handler()
995 msg.size = n; in nxt_port_queue_read_handler()
1054 nxt_port_lvlhsh_frag_alloc(void *ctx, size_t size) in nxt_port_lvlhsh_frag_alloc() argument
1056 return nxt_mp_align(ctx, size, size); in nxt_port_lvlhsh_frag_alloc()
1177 if (nxt_slow_path(msg->size < sizeof(nxt_port_msg_t))) { in nxt_port_read_msg_process()
1179 port->socket.fd, msg->size); in nxt_port_read_msg_process()
1187 msg->size -= sizeof(nxt_port_msg_t); in nxt_port_read_msg_process()
1190 b->mem.free += msg->size; in nxt_port_read_msg_process()
1210 fmsg->size += msg->size; in nxt_port_read_msg_process()