Home
last modified time | relevance | path

Searched refs:nxt_buf_t (Results 1 – 25 of 61) 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_buf_filter.h89 nxt_buf_t *current;
90 nxt_buf_t *input;
91 nxt_buf_t *output;
92 nxt_buf_t *last;
110 nxt_buf_t *b);
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_fastcgi_source.h36 nxt_buf_t *out[2];
38 nxt_buf_t *(*last_buf)(nxt_fastcgi_parse_t *fp);
72 nxt_buf_t *rest;
90 nxt_buf_t *in);
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;
179 nxt_buf_t *last;
272 nxt_buf_t *ws_frame);
321 nxt_buf_t *ws_frame);
323 nxt_buf_t *out);
401 nxt_buf_t *b);
410 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_fastcgi_record_parse.c15 static nxt_int_t nxt_fastcgi_buffer(nxt_fastcgi_parse_t *fp, nxt_buf_t ***tail,
16 nxt_buf_t *in);
21 nxt_buf_t *in) in nxt_fastcgi_record_parse()
25 nxt_buf_t *b, *nb, **tail[2]; in nxt_fastcgi_record_parse()
250 nxt_fastcgi_buffer(nxt_fastcgi_parse_t *fp, nxt_buf_t ***tail, nxt_buf_t *in) in nxt_fastcgi_buffer()
254 nxt_buf_t *b; in nxt_fastcgi_buffer()
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_h1proto.h44 nxt_buf_t *buffers;
46 nxt_buf_t **conn_write_tail;
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_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_fastcgi_source.c47 static nxt_buf_t *nxt_fastcgi_request_create(nxt_fastcgi_source_t *fs);
58 nxt_fastcgi_source_t *fs, nxt_buf_t *b);
68 nxt_buf_t *b);
194 static nxt_buf_t *
200 nxt_buf_t *b, *req, **prev; in nxt_fastcgi_request_create()
390 nxt_buf_t *b, *in; in nxt_fastcgi_source_record_filter()
466 nxt_buf_t *b; in nxt_fastcgi_source_header_filter()
525 nxt_buf_t *b) in nxt_fastcgi_source_sync_buffer()
684 nxt_buf_t *b, *in; in nxt_fastcgi_source_body_filter()
710 static nxt_buf_t *
[all …]
H A Dnxt_http_source.c30 nxt_http_source_t *hs, nxt_buf_t *rest);
39 nxt_buf_t *b);
132 static nxt_buf_t *
136 nxt_buf_t *b, *req, **prev; in nxt_http_source_request_create()
190 nxt_buf_t *b; in nxt_http_source_status_filter()
263 nxt_buf_t *b; in nxt_http_source_header_filter()
429 nxt_buf_t *rest) in nxt_http_source_header_ready()
431 nxt_buf_t *b; in nxt_http_source_header_ready()
500 nxt_buf_t *b; in nxt_http_source_chunk_filter()
551 nxt_buf_t *b, *in; in nxt_http_source_body_filter()
[all …]
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;
248 ssize_t nxt_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b);
307 nxt_buf_t *client_buffer;
308 nxt_buf_t *peer_buffer;
H A Dnxt_buf_filter.c24 nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f, nxt_buf_t *b) in nxt_buf_filter_add()
36 nxt_buf_t *b; in nxt_buf_filter()
176 nxt_buf_t *b; in nxt_buf_filter_nobuf()
259 nxt_buf_t *b; in nxt_buf_filter_file_read()
327 nxt_buf_t *buf;
334 nxt_buf_t *b; in nxt_buf_filter_file_job_completion()
369 b->parent = (nxt_buf_t *) ctx; in nxt_buf_filter_file_job_completion()
402 nxt_buf_t *fb, *b; in nxt_buf_filter_buf_completion()
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()

123