Lines Matching refs:size

265     size_t                   size;  in nxt_http_idle_io_read_handler()  local
281 size = joint->socket_conf->header_buffer_size; in nxt_http_idle_io_read_handler()
283 b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size); in nxt_http_idle_io_read_handler()
401 size_t size; in nxt_h1p_idle_io_read_handler() local
420 size = joint->socket_conf->header_buffer_size; in nxt_h1p_idle_io_read_handler()
422 b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size); in nxt_h1p_idle_io_read_handler()
707 size_t size, used; in nxt_h1p_header_buffer_test() local
713 size = skcf->large_header_buffer_size; in nxt_h1p_header_buffer_test()
716 if (size <= used || h1p->nbuffers >= skcf->large_header_buffers) { in nxt_h1p_header_buffer_test()
720 b = nxt_buf_mem_alloc(c->mem_pool, size, 0); in nxt_h1p_header_buffer_test()
843 size_t size, body_length, body_buffer_size, body_rest; in nxt_h1p_request_body_read() local
917 b->file->size = body_length; in nxt_h1p_request_body_read()
941 size = nxt_buf_mem_used_size(&in->mem); in nxt_h1p_request_body_read()
943 if (size != 0) { in nxt_h1p_request_body_read()
944 size = nxt_min(size, body_length); in nxt_h1p_request_body_read()
947 res = nxt_fd_write(b->file->fd, in->mem.pos, size); in nxt_h1p_request_body_read()
948 if (nxt_slow_path(res < (ssize_t) size)) { in nxt_h1p_request_body_read()
953 b->file_end += size; in nxt_h1p_request_body_read()
956 size = nxt_min(body_buffer_size, size); in nxt_h1p_request_body_read()
957 b->mem.free = nxt_cpymem(b->mem.free, in->mem.pos, size); in nxt_h1p_request_body_read()
960 in->mem.pos += size; in nxt_h1p_request_body_read()
961 body_rest -= size; in nxt_h1p_request_body_read()
1017 size_t size, body_rest; in nxt_h1p_conn_request_body_read() local
1037 body_rest = b->file->size - b->file_end; in nxt_h1p_conn_request_body_read()
1039 size = nxt_buf_mem_used_size(&b->mem); in nxt_h1p_conn_request_body_read()
1040 size = nxt_min(size, body_rest); in nxt_h1p_conn_request_body_read()
1042 res = nxt_fd_write(b->file->fd, b->mem.pos, size); in nxt_h1p_conn_request_body_read()
1043 if (nxt_slow_path(res < (ssize_t) size)) { in nxt_h1p_conn_request_body_read()
1048 b->file_end += size; in nxt_h1p_conn_request_body_read()
1051 b->mem.pos += size; in nxt_h1p_conn_request_body_read()
1201 size_t size; in nxt_h1p_request_header_send() local
1264 size = status->length; in nxt_h1p_request_header_send()
1266 size += nxt_length("\r\n"); in nxt_h1p_request_header_send()
1274 size += NXT_WEBSOCKET_ACCEPT_SIZE + 2; in nxt_h1p_request_header_send()
1288 size += nxt_length(chunked); in nxt_h1p_request_header_send()
1290 size -= nxt_length("\r\n"); in nxt_h1p_request_header_send()
1304 size += connection[conn].length; in nxt_h1p_request_header_send()
1310 size += field->name_length + field->value_length; in nxt_h1p_request_header_send()
1311 size += nxt_length(": \r\n"); in nxt_h1p_request_header_send()
1317 size += nxt_length(websocket_version); in nxt_h1p_request_header_send()
1320 header = nxt_http_buf_mem(task, r, size); in nxt_h1p_request_header_send()
1396 size_t size; in nxt_h1p_complete_buffers() local
1430 size = nxt_buf_mem_used_size(&in->mem); in nxt_h1p_complete_buffers()
1432 if (size == 0 || all) { in nxt_h1p_complete_buffers()
1494 nxt_off_t size; in nxt_h1p_chunk_create() local
1500 size = 0; in nxt_h1p_chunk_create()
1523 size += nxt_buf_used_size(b); in nxt_h1p_chunk_create()
1527 if (size == 0) { in nxt_h1p_chunk_create()
1538 "\r\n%xO\r\n", size); in nxt_h1p_chunk_create()
1785 size_t size; in nxt_h1p_keepalive() local
1813 size = nxt_buf_mem_used_size(&in->mem); in nxt_h1p_keepalive()
1817 nxt_memmove(in->mem.start, in->mem.pos, size); in nxt_h1p_keepalive()
1820 in->mem.free = in->mem.start + size; in nxt_h1p_keepalive()
1896 size_t size; in nxt_h1p_idle_response() local
1899 size = nxt_length(NXT_H1P_IDLE_TIMEOUT) in nxt_h1p_idle_response()
1900 + nxt_http_date_cache.size in nxt_h1p_idle_response()
1903 out = nxt_buf_mem_alloc(c->mem_pool, size, 0); in nxt_h1p_idle_response()
2255 size_t size; in nxt_h1p_peer_header_send() local
2265 size = r->method->length + sizeof(" ") + r->target.length in nxt_h1p_peer_header_send()
2273 size += field->name_length + field->value_length; in nxt_h1p_peer_header_send()
2274 size += nxt_length(": \r\n"); in nxt_h1p_peer_header_send()
2279 header = nxt_http_buf_mem(task, r, size); in nxt_h1p_peer_header_send()
2306 size = p - header->mem.pos; in nxt_h1p_peer_header_send()
2335 size += nxt_buf_used_size(body); in nxt_h1p_peer_header_send()
2340 if (size > 16384) { in nxt_h1p_peer_header_send()
2450 size_t size; in nxt_h1p_peer_io_read_handler() local
2464 size = (peer->header_received) ? skcf->proxy_buffer_size in nxt_h1p_peer_io_read_handler()
2467 nxt_debug(task, "h1p peer io read: %z", size); in nxt_h1p_peer_io_read_handler()
2469 b = nxt_http_proxy_buf_mem_alloc(task, r, size); in nxt_h1p_peer_io_read_handler()