Home
last modified time | relevance | path

Searched refs:nxt_buf_t (Results 1 – 25 of 62) sorted by last modified time

123

/unit/src/
H A Dnxt_main.h107 typedef struct nxt_buf_s nxt_buf_t; typedef
H A Dnxt_process.c507 nxt_buf_t *buf; in nxt_process_whoami()
559 nxt_buf_t *buf; in nxt_process_whoami_ok()
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_router_access_log.c201 nxt_buf_t *b; in nxt_router_access_log_open()
331 nxt_buf_t *b; in nxt_router_access_log_reopen_handler()
400 nxt_buf_t *b; in nxt_router_access_log_reopen_completion()
H A Dnxt_router.c375 nxt_buf_t *b; in nxt_router_start_app_process_handler()
516 nxt_buf_t *b, *next; in nxt_router_msg_cancel()
2540 nxt_buf_t *b; in nxt_router_listen_socket_rpc_create()
2645 nxt_buf_t *in, *out; in nxt_router_listen_socket_error()
2770 nxt_buf_t *b; in nxt_router_app_rpc_create()
3754 nxt_buf_t *b, *next; in nxt_router_response_ready_handler()
3942 nxt_buf_t *b; in nxt_router_req_headers_ack_handler()
4085 nxt_buf_t *out; in nxt_http_request_send_body()
4948 nxt_buf_t *buf, *body; in nxt_router_app_prepare_request()
5094 static nxt_buf_t *
[all …]
H A Dnxt_http_static.c302 nxt_buf_t *fb; in nxt_http_static_send_ready()
786 nxt_buf_t *fb, *b, **next, *out; in nxt_http_static_body_handler()
848 nxt_buf_t *b, *fb, *next; in nxt_http_static_buf_completion()
H A Dnxt_http_request.c247 nxt_buf_t *last; in nxt_http_request_create()
691 nxt_buf_t *ws_frame) in nxt_http_request_ws_frame_start()
700 nxt_http_request_send(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out) in nxt_http_request_send()
708 nxt_buf_t *
711 nxt_buf_t *b; in nxt_http_buf_mem()
730 nxt_buf_t *b, *next; in nxt_http_request_mem_buf_completion()
747 nxt_buf_t *
750 nxt_buf_t *last; in nxt_http_buf_last()
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);
404 nxt_buf_t *b);
413 nxt_http_request_t *r, nxt_buf_t *ws_frame);
[all …]
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_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_http_parse.h129 nxt_buf_t *nxt_http_chunk_parse(nxt_task_t *task, nxt_http_chunk_parse_t *hcp,
130 nxt_buf_t *in);
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 …]
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_port_rpc.c372 nxt_buf_t buf; in nxt_port_rpc_remove_peer()
490 static nxt_buf_t nxt_port_close_dummy_buf;
H A Dnxt_port_memory.c122 nxt_buf_t *b, *next; in nxt_port_mmap_buf_completion()
542 nxt_buf_t *
546 nxt_buf_t *b; in nxt_port_mmap_get_buf()
598 nxt_port_mmap_increase_buf(nxt_task_t *task, nxt_buf_t *b, size_t size, in nxt_port_mmap_increase_buf()
663 static nxt_buf_t *
668 nxt_buf_t *b; in nxt_port_mmap_get_incoming_buf()
715 nxt_buf_t *bmem; in nxt_port_mmap_write()
767 nxt_buf_t *b, **pb; in nxt_port_mmap_read()
804 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b) in nxt_port_mmap_get_method()
H A Dnxt_port.h182 nxt_buf_t *buf;
196 nxt_buf_t *buf;
252 nxt_buf_t *free_bufs;
300 nxt_buf_t buf;
324 nxt_port_id_t reply_port, nxt_buf_t *b);
329 nxt_buf_t *b) in nxt_port_socket_write()
H A Dnxt_openssl.c93 static ssize_t nxt_openssl_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b);
1332 nxt_openssl_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b)
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_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_event_engine.h512 void nxt_event_engine_buf_mem_free(nxt_event_engine_t *engine, nxt_buf_t *b);
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_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_main_process.c371 nxt_buf_t *b; in nxt_main_start_process_handler()
617 nxt_buf_t *buf; in nxt_main_process_whoami_handler()
1030 nxt_buf_t *b, *out; in nxt_main_port_socket_handler()
1280 nxt_buf_t *b; in nxt_main_port_modules_handler()
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_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()

123