Home
last modified time | relevance | path

Searched refs:nxt_buf_t (Results 1 – 25 of 53) sorted by relevance

123

/unit/src/
H A Dnxt_sendbuf.h39 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 Dnxt_buf.h76 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 Dnxt_buf.c30 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 Dnxt_http_chunk_parse.c20 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 Dnxt_sendbuf.c10 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 Dnxt_http.h123 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 Dnxt_port_memory.h23 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 Dnxt_recvbuf.h12 nxt_buf_t *buf;
21 void nxt_recvbuf_update(nxt_buf_t *b, size_t sent);
H A Dnxt_buf_pool.h21 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 Dnxt_event_conn_job_sendfile.c12 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 Dnxt_buf_pool.c13 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 Dnxt_h1proto.h44 nxt_buf_t *buffers;
46 nxt_buf_t **conn_write_tail;
H A Dnxt_solaris_sendfilev.c18 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 Dnxt_conn.h54 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 Dnxt_hpux_sendfile.c12 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 Dnxt_aix_send_file.c12 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 Dnxt_macosx_sendfile.c14 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 Dnxt_freebsd_sendfile.c18 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 Dnxt_recvbuf.c16 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 Dnxt_port_socket.c19 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 Dnxt_port.h196 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 Dnxt_router_request.h11 nxt_buf_t *buf;
H A Dnxt_conn_proxy.c22 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 Dnxt_linux_sendfile.c25 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 Dnxt_http_proxy.c295 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()

123