/unit/src/ |
H A D | nxt_sendbuf.h | 39 nxt_buf_t *buf; 55 nxt_buf_t *buf; 72 ssize_t nxt_linux_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b, 78 ssize_t nxt_freebsd_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b, 90 ssize_t nxt_macosx_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b, 96 ssize_t nxt_aix_event_conn_io_send_file(nxt_conn_t *c, nxt_buf_t *b, 102 ssize_t nxt_hpux_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b, 106 ssize_t nxt_event_conn_io_sendbuf(nxt_conn_t *c, nxt_buf_t *b, 123 nxt_buf_t *b, size_t limit); 125 nxt_buf_t *nxt_sendbuf_update(nxt_buf_t *b, size_t sent); [all …]
|
H A D | nxt_buf.h | 76 nxt_buf_t *next; 105 #define NXT_BUF_MEM_SIZE offsetof(nxt_buf_t, file) 106 #define NXT_BUF_FILE_SIZE sizeof(nxt_buf_t) 227 NXT_EXPORT nxt_buf_t *nxt_buf_make_plain(nxt_mp_t *mp, nxt_buf_t *src, 230 nxt_inline nxt_buf_t * 244 NXT_EXPORT void nxt_buf_chain_add(nxt_buf_t **head, nxt_buf_t *in); 245 NXT_EXPORT size_t nxt_buf_chain_length(nxt_buf_t *b); 247 nxt_inline nxt_buf_t * 248 nxt_buf_cpy(nxt_buf_t *b, const void *src, size_t length) in nxt_buf_cpy() 256 nxt_inline nxt_buf_t * [all …]
|
H A D | nxt_buf.c | 30 nxt_buf_t * 33 nxt_buf_t *b; in nxt_buf_mem_alloc() 56 nxt_buf_t * 95 nxt_buf_t * 98 nxt_buf_t *b; in nxt_buf_file_alloc() 122 nxt_buf_t * 125 nxt_buf_t *b; in nxt_buf_mmap_alloc() 142 nxt_buf_t * 145 nxt_buf_t *b; in nxt_buf_sync_alloc() 164 nxt_buf_chain_add(nxt_buf_t **head, nxt_buf_t *in) in nxt_buf_chain_add() [all …]
|
H A D | nxt_http_chunk_parse.c | 20 nxt_buf_t ***tail, nxt_buf_t *in); 27 nxt_buf_t * 29 nxt_buf_t *in) in nxt_http_chunk_parse() 33 nxt_buf_t *b, *out, *next, **tail; in nxt_http_chunk_parse() 199 nxt_http_chunk_buffer(nxt_http_chunk_parse_t *hcp, nxt_buf_t ***tail, in nxt_http_chunk_buffer() 200 nxt_buf_t *in) in nxt_http_chunk_buffer() 204 nxt_buf_t *b; in nxt_http_chunk_buffer() 252 nxt_buf_t *b, *next, *parent; in nxt_http_chunk_buf_completion()
|
H A D | nxt_sendbuf.c | 10 static nxt_bool_t nxt_sendbuf_copy(nxt_buf_mem_t *bm, nxt_buf_t *b, 12 static nxt_buf_t *nxt_sendbuf_coalesce_completion(nxt_task_t *task, 13 nxt_work_queue_t *wq, nxt_buf_t *start); 22 nxt_buf_t *b; in nxt_sendbuf_mem_coalesce0() 92 nxt_buf_t *b; in nxt_sendbuf_mem_coalesce() 169 nxt_buf_t *b; in nxt_sendbuf_file_coalesce() 330 nxt_buf_t * 331 nxt_sendbuf_update(nxt_buf_t *b, size_t sent) in nxt_sendbuf_update() 380 nxt_buf_t * 405 static nxt_buf_t * [all …]
|
H A D | nxt_http.h | 123 nxt_buf_t *body; 138 nxt_buf_t *body; 139 nxt_buf_t *ws_frame; 140 nxt_buf_t *out; 184 nxt_buf_t *last; 283 nxt_buf_t *ws_frame); 332 nxt_buf_t *ws_frame); 334 nxt_buf_t *out); 423 nxt_buf_t *b); 432 nxt_http_request_t *r, nxt_buf_t *ws_frame); [all …]
|
H A D | nxt_port_memory.h | 23 nxt_buf_t * 26 nxt_int_t nxt_port_mmap_increase_buf(nxt_task_t *task, nxt_buf_t *b, 49 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b);
|
H A D | nxt_recvbuf.h | 12 nxt_buf_t *buf; 21 void nxt_recvbuf_update(nxt_buf_t *b, size_t sent);
|
H A D | nxt_buf_pool.h | 21 nxt_buf_t *current; 22 nxt_buf_t *free; 39 NXT_EXPORT void nxt_buf_pool_free(nxt_buf_pool_t *bp, nxt_buf_t *b);
|
H A D | nxt_event_conn_job_sendfile.c | 12 nxt_buf_t *out; 25 static nxt_buf_t *nxt_event_conn_job_sendfile_completion(nxt_task_t *task, 26 nxt_conn_t *c, nxt_buf_t *b); 99 nxt_buf_t *b; in nxt_event_conn_job_sendfile_handler() 166 nxt_buf_t *b; in nxt_event_conn_job_sendfile_return() 237 static nxt_buf_t * 239 nxt_buf_t *b) in nxt_event_conn_job_sendfile_completion()
|
H A D | nxt_buf_pool.c | 13 nxt_buf_t *b; in nxt_buf_pool_mem_alloc() 53 nxt_buf_t *b; in nxt_buf_pool_file_alloc() 93 nxt_buf_t *b; in nxt_buf_pool_mmap_alloc() 132 nxt_buf_pool_free(nxt_buf_pool_t *bp, nxt_buf_t *b) in nxt_buf_pool_free() 175 nxt_buf_t *b, *n; in nxt_buf_pool_destroy()
|
H A D | nxt_h1proto.h | 44 nxt_buf_t *buffers; 46 nxt_buf_t **conn_write_tail;
|
H A D | nxt_solaris_sendfilev.c | 18 ssize_t nxt_solaris_event_conn_io_sendfilev(nxt_event_conn_t *c, nxt_buf_t *b, 20 static size_t nxt_solaris_buf_coalesce(nxt_buf_t *b, sendfilevec_t *sfv, 25 nxt_solaris_event_conn_io_sendfilev(nxt_event_conn_t *c, nxt_buf_t *b, in nxt_solaris_event_conn_io_sendfilev() 90 nxt_solaris_buf_coalesce(nxt_buf_t *b, sendfilevec_t *sfv, int32_t *nsfv, in nxt_solaris_buf_coalesce()
|
H A D | nxt_conn.h | 54 ssize_t (*recvbuf)(nxt_conn_t *c, nxt_buf_t *b); 72 ssize_t (*old_sendbuf)(nxt_conn_t *c, nxt_buf_t *b, 125 nxt_buf_t *read; 130 nxt_buf_t *write; 249 ssize_t nxt_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b); 329 nxt_buf_t *client_buffer; 330 nxt_buf_t *peer_buffer;
|
H A D | nxt_hpux_sendfile.c | 12 ssize_t nxt_hpux_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, 34 nxt_hpux_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_hpux_event_conn_io_sendfile() 38 nxt_buf_t *fb; in nxt_hpux_event_conn_io_sendfile()
|
H A D | nxt_aix_send_file.c | 12 ssize_t nxt_aix_event_conn_io_send_file(nxt_event_conn_t *c, nxt_buf_t *b, 17 nxt_aix_event_conn_io_send_file(nxt_event_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_aix_event_conn_io_send_file() 20 nxt_buf_t *fb; in nxt_aix_event_conn_io_send_file()
|
H A D | nxt_macosx_sendfile.c | 14 ssize_t nxt_macosx_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, 29 nxt_macosx_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_macosx_event_conn_io_sendfile() 33 nxt_buf_t *fb; in nxt_macosx_event_conn_io_sendfile()
|
H A D | nxt_freebsd_sendfile.c | 18 ssize_t nxt_freebsd_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, 33 nxt_freebsd_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, in nxt_freebsd_event_conn_io_sendfile() 38 nxt_buf_t *fb; in nxt_freebsd_event_conn_io_sendfile()
|
H A D | nxt_recvbuf.c | 16 nxt_buf_t *b; in nxt_recvbuf_mem_coalesce() 59 nxt_recvbuf_update(nxt_buf_t *b, size_t sent) in nxt_recvbuf_update()
|
H A D | nxt_port_socket.c | 19 void *qbuf, nxt_buf_t *b); 162 nxt_buf_t *b) in nxt_port_socket_write2() 253 nxt_port_can_enqueue_buf(nxt_buf_t *b) in nxt_port_can_enqueue_buf() 270 nxt_buf_t *b) in nxt_port_enqueue_buf() 617 static nxt_buf_t * 622 nxt_buf_t *next; in nxt_port_buf_completion() 734 nxt_buf_t *b; in nxt_port_read_handler() 815 nxt_buf_t *b; in nxt_port_queue_read_handler() 1304 static nxt_buf_t * 1307 nxt_buf_t *b; in nxt_port_buf_alloc() [all …]
|
H A D | nxt_port.h | 196 nxt_buf_t *buf; 210 nxt_buf_t *buf; 266 nxt_buf_t *free_bufs; 314 nxt_buf_t buf; 338 nxt_port_id_t reply_port, nxt_buf_t *b); 343 nxt_buf_t *b) in nxt_port_socket_write()
|
H A D | nxt_router_request.h | 11 nxt_buf_t *buf;
|
H A D | nxt_conn_proxy.c | 22 static void nxt_conn_proxy_write_add(nxt_conn_t *c, nxt_buf_t *b); 146 nxt_buf_t *b; in nxt_conn_proxy_client_buffer_alloc() 295 nxt_buf_t *b; in nxt_conn_proxy_peer_read() 380 nxt_buf_t *rb, *wb; in nxt_conn_proxy_read_process() 433 nxt_conn_proxy_write_add(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_proxy_write_add() 435 nxt_buf_t *first, *second, *prev; in nxt_conn_proxy_write_add() 571 nxt_buf_t *rb, *wb; in nxt_conn_proxy_write_process() 624 nxt_conn_proxy_read_add(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_proxy_read_add() 626 nxt_buf_t *first, *second; in nxt_conn_proxy_read_add() 704 nxt_buf_t *b; in nxt_conn_proxy_close() [all …]
|
H A D | nxt_linux_sendfile.c | 25 ssize_t nxt_linux_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, 46 nxt_linux_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, in nxt_linux_event_conn_io_sendfile() 51 nxt_buf_t *fb; in nxt_linux_event_conn_io_sendfile()
|
H A D | nxt_http_proxy.c | 295 nxt_buf_t *out; in nxt_http_proxy_send_body() 319 nxt_buf_t * 323 nxt_buf_t *b; in nxt_http_proxy_buf_mem_alloc() 342 nxt_buf_t *b, *next; in nxt_http_proxy_buf_mem_completion() 367 nxt_buf_t *b) in nxt_http_proxy_buf_mem_free()
|