Home
last modified time | relevance | path

Searched refs:nxt_buf_t (Results 1 – 25 of 62) sorted by path

123

/unit/src/
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_application.c43 static nxt_buf_t *nxt_discovery_modules(nxt_task_t *task, const char *path);
167 nxt_buf_t *b; in nxt_discovery_start()
205 static nxt_buf_t *
213 nxt_buf_t *b; in nxt_discovery_modules()
489 nxt_buf_t *b; in nxt_discovery_completion_handler()
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.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_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_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_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_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_cert.c956 nxt_buf_t *b;
1067 nxt_buf_t *b; in nxt_cert_store_get()
1112 nxt_buf_t *b; in nxt_cert_buf_completion()
1194 nxt_buf_t *b; in nxt_cert_store_delete()
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_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_conn_read.c132 nxt_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_io_recvbuf()
H A Dnxt_conn_write.c20 nxt_buf_t *b; in nxt_conn_io_write()
188 nxt_buf_t *b; in nxt_conn_io_sendfile()
430 nxt_event_conn_io_sendbuf(nxt_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_event_conn_io_sendbuf()
H A Dnxt_controller.c564 nxt_buf_t *b; in nxt_controller_conf_send()
674 nxt_buf_t *b; in nxt_controller_conn_init()
736 nxt_buf_t *b; in nxt_controller_conn_read()
867 nxt_buf_t *b; in nxt_controller_conn_body_read()
905 nxt_buf_t *b; in nxt_controller_conn_write()
1758 nxt_buf_t *b; in nxt_controller_process_control()
1909 nxt_buf_t *b; in nxt_controller_conf_store()
1960 nxt_buf_t *b, *body; in nxt_controller_response()
H A Dnxt_cyassl.c33 nxt_event_conn_t *c, nxt_buf_t *b, size_t limit);
342 nxt_buf_t *b; in nxt_cyassl_conn_io_read()
396 nxt_buf_t *b, size_t limit) in nxt_cyassl_conn_io_write_chunk()
H A Dnxt_epoll_engine.c96 static ssize_t nxt_epoll_edge_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b);
1161 nxt_epoll_edge_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b) in nxt_epoll_edge_conn_io_recvbuf()
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_event_engine.c682 nxt_buf_t *b; in nxt_event_engine_buf_mem_alloc()
710 nxt_event_engine_buf_mem_free(nxt_event_engine_t *engine, nxt_buf_t *b) in nxt_event_engine_buf_mem_free()
723 nxt_buf_t *b, *next, *parent; in nxt_event_engine_buf_mem_completion()
H A Dnxt_event_engine.h512 void nxt_event_engine_buf_mem_free(nxt_event_engine_t *engine, 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_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_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_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_gnutls.c48 nxt_event_conn_t *c, nxt_buf_t *b, size_t limit);
472 nxt_buf_t *b; in nxt_gnutls_conn_io_read()
527 nxt_buf_t *b, size_t limit) in nxt_gnutls_conn_io_write_chunk()
H A Dnxt_h1proto.c51 nxt_buf_t *out);
53 nxt_buf_t *out);
57 nxt_buf_t *last);
708 nxt_buf_t *in, *b; in nxt_h1p_header_buffer_test()
1019 nxt_buf_t *b; in nxt_h1p_conn_request_body_read()
1491 static nxt_buf_t *
1559 nxt_buf_t *last) in nxt_h1p_request_discard()
1561 nxt_buf_t *b; in nxt_h1p_request_discard()
1896 nxt_buf_t *out, *last; in nxt_h1p_idle_response()
2658 nxt_buf_t *out; in nxt_h1p_peer_read_done()
[all …]

123