| /unit/src/ |
| H A D | nxt_conn.c | 45 nxt_conn_t *c; in nxt_conn_create() local
93 nxt_conn_free(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_free()
105 nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_conn_timer()
122 nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq) in nxt_conn_work_queue_set()
132 nxt_conn_local_addr(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_local_addr()
|
| H A D | nxt_conn_connect.c | 16 nxt_conn_t *c; in nxt_conn_sys_socket() local
37 nxt_conn_t *c; in nxt_conn_io_connect() local
78 nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_socket()
125 nxt_conn_t *c; in nxt_conn_connect_test() local
152 nxt_conn_t *c; in nxt_conn_connect_error() local
188 nxt_conn_connect_test_error(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_connect_test_error()
|
| H A D | nxt_h1proto.c | 1746 nxt_conn_t *c; in nxt_h1p_conn_close() local
1761 nxt_conn_t *c; in nxt_h1p_conn_error() local
1863 nxt_conn_t *c; in nxt_h1p_idle_close() local
1878 nxt_conn_t *c; in nxt_h1p_idle_timeout() local
1963 nxt_conn_t *c; in nxt_h1p_idle_response_sent() local
1976 nxt_conn_t *c; in nxt_h1p_idle_response_error() local
2095 nxt_conn_t *c; in nxt_h1p_conn_closing() local
2414 nxt_conn_t *c; in nxt_h1p_peer_header_read() local
2639 nxt_conn_t *c; in nxt_h1p_peer_read() local
2828 nxt_conn_t *c; in nxt_h1p_peer_close() local
[all …]
|
| H A D | nxt_conn_read.c | 11 nxt_conn_wait(nxt_conn_t *c) in nxt_conn_wait()
41 nxt_conn_t *c; in nxt_conn_io_read() local
132 nxt_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_io_recvbuf()
198 nxt_conn_io_recv(nxt_conn_t *c, void *buf, size_t size, nxt_uint_t flags) in nxt_conn_io_recv()
|
| H A D | nxt_conn_close.c | 19 nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c) in nxt_conn_close()
77 nxt_conn_t *c; in nxt_conn_shutdown_handler() local
98 nxt_conn_t *c; in nxt_conn_close_handler() local
144 nxt_conn_t *c; in nxt_conn_close_timer_handler() local
|
| H A D | nxt_event_conn_job_sendfile.c | 30 nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_conn_t *c) in nxt_event_conn_job_sendfile()
42 nxt_conn_t *c; in nxt_event_conn_job_sendfile_start() local
101 nxt_conn_t *c; in nxt_event_conn_job_sendfile_handler() local
168 nxt_conn_t *c; in nxt_event_conn_job_sendfile_return() local
238 nxt_event_conn_job_sendfile_completion(nxt_task_t *task, nxt_conn_t *c, in nxt_event_conn_job_sendfile_completion()
|
| H A D | nxt_parse.c | 18 u_char c; in nxt_int_parse() local
64 u_char c; in nxt_size_t_parse() local
169 u_char c; in nxt_off_t_parse() local
215 u_char c, *p; in nxt_str_int_parse() local
268 u_char c; in nxt_number_parse() local
|
| H A D | nxt_gnutls.c | 255 nxt_event_conn_t *c) in nxt_gnutls_conn_init()
356 nxt_event_conn_t *c; in nxt_gnutls_pull() local
377 nxt_event_conn_t *c; in nxt_gnutls_push() local
403 nxt_event_conn_t *c; in nxt_gnutls_vec_push() local
430 nxt_event_conn_t *c; in nxt_gnutls_conn_handshake() local
474 nxt_event_conn_t *c; in nxt_gnutls_conn_io_read() local
526 nxt_gnutls_conn_io_write_chunk(nxt_thread_t *thr, nxt_event_conn_t *c, in nxt_gnutls_conn_io_write_chunk()
540 nxt_gnutls_conn_io_send(nxt_event_conn_t *c, void *buf, size_t size) in nxt_gnutls_conn_io_send()
575 nxt_event_conn_t *c; in nxt_gnutls_conn_io_shutdown() local
681 nxt_gnutls_conn_log_error(nxt_event_conn_t *c, ssize_t err, in nxt_gnutls_conn_log_error()
[all …]
|
| H A D | nxt_cyassl.c | 176 nxt_event_conn_t *c) in nxt_cyassl_conn_init()
247 nxt_event_conn_t *c; in nxt_cyassl_io_recv() local
275 nxt_event_conn_t *c; in nxt_cyassl_io_send() local
300 nxt_event_conn_t *c; in nxt_cyassl_conn_handshake() local
345 nxt_event_conn_t *c; in nxt_cyassl_conn_io_read() local
395 nxt_cyassl_conn_io_write_chunk(nxt_thread_t *thr, nxt_event_conn_t *c, in nxt_cyassl_conn_io_write_chunk()
409 nxt_cyassl_conn_io_send(nxt_event_conn_t *c, void *buf, size_t size) in nxt_cyassl_conn_io_send()
453 nxt_event_conn_t *c; in nxt_cyassl_conn_io_shutdown() local
476 nxt_cyassl_conn_test_error(nxt_thread_t *thr, nxt_event_conn_t *c, int ret, in nxt_cyassl_conn_test_error()
536 nxt_cyassl_conn_error(nxt_event_conn_t *c, nxt_err_t err, const char *fmt, ...) in nxt_cyassl_conn_error()
[all …]
|
| H A D | nxt_conn_write.c | 21 nxt_conn_t *c; in nxt_conn_io_write() local
149 nxt_conn_t *c; in nxt_conn_write_timer_handler() local
389 nxt_event_conn_write_limit(nxt_conn_t *c) in nxt_event_conn_write_limit()
422 nxt_event_conn_write_delayed(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_event_conn_write_delayed()
430 nxt_event_conn_io_sendbuf(nxt_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_event_conn_io_sendbuf()
454 nxt_event_conn_io_writev(nxt_conn_t *c, nxt_iobuf_t *iob, nxt_uint_t niob) in nxt_event_conn_io_writev()
499 nxt_event_conn_io_send(nxt_conn_t *c, void *buf, size_t size) in nxt_event_conn_io_send()
|
| H A D | nxt_conn_accept.c | 89 nxt_conn_t *c; in nxt_conn_accept_alloc() local
139 nxt_conn_t *c; in nxt_conn_io_accept() local
188 nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev, nxt_conn_t *c) in nxt_conn_accept()
237 nxt_conn_t *c; in nxt_conn_accept_next() local
275 nxt_conn_t *c; in nxt_conn_accept_close_idle_handler() local
359 nxt_conn_t *c; in nxt_conn_listen_timer_handler() local
|
| H A D | nxt_sha1.c | 125 #define F1(b, c, d) (((b) & (c)) | ((~(b)) & (d))) argument
126 #define F2(b, c, d) ((b) ^ (c) ^ (d)) argument
127 #define F3(b, c, d) (((b) & (c)) | ((b) & (d)) | ((c) & (d))) argument
129 #define STEP(f, a, b, c, d, e, w, t) \ argument
158 uint32_t a, b, c, d, e, temp; in nxt_sha1_body() local
|
| H A D | nxt_string.h | 11 #define nxt_lowcase(c) \ argument
14 #define nxt_upcase(c) \ argument
17 #define nxt_isdigit(c) \ argument
40 #define nxt_memset(buf, c, length) \ argument
143 #define nxt_strchr_eq(s, c) \ argument
147 #define nxt_strchr_start(s, c) \ argument
|
| H A D | nxt_linux_sendfile.c | 46 nxt_linux_event_conn_io_sendfile(nxt_event_conn_t *c, nxt_buf_t *b, in nxt_linux_event_conn_io_sendfile()
143 nxt_linux_send(nxt_event_conn_t *c, void *buf, size_t size, nxt_uint_t flags) in nxt_linux_send()
188 nxt_linux_sendmsg(nxt_event_conn_t *c, nxt_sendbuf_coalesce_t *sb, in nxt_linux_sendmsg()
|
| H A D | nxt_port_memory_int.h | 90 #define nxt_port_mmap_get_chunk_busy(m, c) \ argument
114 nxt_port_mmap_chunk_start(nxt_port_mmap_header_t *hdr, nxt_chunk_id_t c) in nxt_port_mmap_chunk_start()
125 nxt_port_mmap_get_free_chunk(nxt_free_map_t *m, nxt_chunk_id_t *c) in nxt_port_mmap_get_free_chunk()
161 nxt_port_mmap_set_chunk_busy(nxt_free_map_t *m, nxt_chunk_id_t c) in nxt_port_mmap_set_chunk_busy()
168 nxt_port_mmap_chk_set_chunk_busy(nxt_free_map_t *m, nxt_chunk_id_t c) in nxt_port_mmap_chk_set_chunk_busy()
190 nxt_port_mmap_set_chunk_free(nxt_free_map_t *m, nxt_chunk_id_t c) in nxt_port_mmap_set_chunk_free()
|
| H A D | nxt_utf8.h | 34 u_char c; in nxt_utf8_next() local
|
| H A D | nxt_h1proto_websocket.c | 76 nxt_conn_t *c; in nxt_h1p_websocket_first_frame_start() local
122 nxt_conn_t *c; in nxt_h1p_websocket_frame_start() local
221 nxt_conn_t *c; in nxt_h1p_conn_ws_frame_header_read() local
399 nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c, in nxt_h1p_conn_ws_frame_process()
462 nxt_h1p_ws_io_read_handler(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_ws_io_read_handler()
498 nxt_conn_t *c; in nxt_h1p_conn_ws_timeout() local
544 nxt_conn_t *c; in nxt_h1p_conn_ws_frame_payload_read() local
|
| H A D | nxt_controller.c | 715 nxt_conn_t *c; in nxt_controller_conn_init() local
778 nxt_conn_t *c; in nxt_controller_conn_read() local
861 nxt_conn_t *c; in nxt_controller_conn_read_error() local
875 nxt_conn_t *c; in nxt_controller_conn_read_timeout() local
908 nxt_conn_t *c; in nxt_controller_conn_body_read() local
946 nxt_conn_t *c; in nxt_controller_conn_write() local
968 nxt_conn_t *c; in nxt_controller_conn_write_error() local
981 nxt_conn_t *c; in nxt_controller_conn_write_timeout() local
1006 nxt_conn_t *c; in nxt_controller_conn_close() local
1023 nxt_conn_t *c; in nxt_controller_conn_free() local
[all …]
|
| H A D | nxt_djb_hash.c | 31 u_char c; in nxt_djb_hash_lowcase() local
|
| H A D | nxt_conn_proxy.c | 433 nxt_conn_proxy_write_add(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_proxy_write_add()
624 nxt_conn_proxy_read_add(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_proxy_read_add()
734 nxt_conn_t *c; in nxt_conn_proxy_error() local
749 nxt_conn_t *c; in nxt_conn_proxy_read_timeout() local
767 nxt_conn_t *c; in nxt_conn_proxy_write_timeout() local
783 nxt_conn_proxy_timeout_value(nxt_conn_t *c, uintptr_t data) in nxt_conn_proxy_timeout_value()
893 nxt_conn_t *c; in nxt_conn_proxy_read_error() local
|
| H A D | nxt_conn.h | 176 #define nxt_conn_timer_init(ev, c, wq) \ argument
194 #define nxt_conn_tcp_nodelay_on(task, c) \ argument
209 #define nxt_conn_tcp_nodelay_on(task, c) \ argument
271 #define nxt_conn_connect(engine, c) \ argument
276 #define nxt_conn_read(engine, c) \ argument
287 #define nxt_conn_write(engine, c) \ argument
298 #define nxt_conn_idle(engine, c) \ argument
309 #define nxt_conn_active(engine, c) \ argument
|
| H A D | nxt_aix_send_file.c | 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()
|
| H A D | nxt_openssl.c | 739 nxt_conn_t *c; local
1034 nxt_conn_t *c; local
1161 nxt_openssl_conn_init(nxt_task_t *task, nxt_tls_conf_t *conf, nxt_conn_t *c)
1221 nxt_openssl_conn_free(nxt_task_t *task, nxt_conn_t *c)
1243 nxt_conn_t *c; local
1332 nxt_openssl_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b)
1389 nxt_conn_t *c; local
1430 nxt_conn_t *c; local
1544 nxt_openssl_conn_test_error(nxt_task_t *task, nxt_conn_t *c, int ret,
1612 nxt_conn_t *c; local
|
| H A D | nxt_java.c | 207 nxt_java_app_conf_t *c; in nxt_java_start() local
616 nxt_java_app_conf_t *c; in nxt_java_ready_handler() local
688 nxt_java_init_threads(nxt_java_app_conf_t *c) in nxt_java_init_threads()
732 nxt_java_join_threads(nxt_unit_ctx_t *ctx, nxt_java_app_conf_t *c) in nxt_java_join_threads()
|
| H A D | nxt_port_memory.c | 27 int c; in nxt_port_mmap_handler_use() local
124 nxt_chunk_id_t c; in nxt_port_mmap_buf_completion() local
445 nxt_port_mmap_get(nxt_task_t *task, nxt_port_mmaps_t *mmaps, nxt_chunk_id_t *c, in nxt_port_mmap_get()
548 nxt_chunk_id_t c; in nxt_port_mmap_get_buf() local
602 nxt_chunk_id_t c, start; in nxt_port_mmap_increase_buf() local
|