/unit/src/ |
H A D | nxt_sendbuf.h | 110 nxt_uint_t nxt_sendbuf_mem_coalesce0(nxt_task_t *task, nxt_sendbuf_t *sb, 112 nxt_uint_t nxt_sendbuf_mem_coalesce(nxt_task_t *task, 126 nxt_buf_t *nxt_sendbuf_completion(nxt_task_t *task, nxt_work_queue_t *wq, 128 void nxt_sendbuf_drain(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b);
|
H A D | nxt_port_rpc.h | 11 typedef void (*nxt_port_rpc_handler_t)(nxt_task_t *task, 16 uint32_t nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port, 19 void *nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port, 24 void nxt_port_rpc_ex_set_peer(nxt_task_t *task, nxt_port_t *port, 27 void nxt_port_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg); 28 void nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port, 30 void nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream); 31 void nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port);
|
H A D | nxt_process_title.c | 46 nxt_process_arguments(nxt_task_t *task, char **orig_argv, char ***orig_envp) in nxt_process_arguments() 190 nxt_process_title(nxt_task_t *task, const char *fmt, ...) in nxt_process_title() 250 nxt_process_arguments(nxt_task_t *task, char **orig_argv, char ***orig_envp) in nxt_process_arguments()
|
H A D | nxt_log_moderation.c | 10 static void nxt_log_moderate_timer_handler(nxt_task_t *task, void *obj, 74 nxt_log_moderate_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_log_moderate_timer_handler()
|
H A D | nxt_mp.h | 110 nxt_task_t *task, void *obj, void *data);
|
H A D | nxt_lib.c | 12 nxt_task_t nxt_main_task;
|
H A D | nxt_listen_socket.h | 54 NXT_EXPORT nxt_int_t nxt_listen_socket(nxt_task_t *task, nxt_socket_t s, 57 NXT_EXPORT nxt_int_t nxt_listen_socket_create(nxt_task_t *task, nxt_mp_t *mp, 59 NXT_EXPORT nxt_int_t nxt_listen_socket_update(nxt_task_t *task,
|
H A D | nxt_http_error.c | 11 static void nxt_http_request_send_error_body(nxt_task_t *task, void *r, 28 nxt_http_request_error(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_error() 78 nxt_http_request_send_error_body(nxt_task_t *task, void *obj, void *data) in nxt_http_request_send_error_body()
|
H A D | nxt_http_response.c | 37 nxt_http_response_hash_init(nxt_task_t *task) in nxt_http_response_hash_init()
|
H A D | nxt_http_websocket.c | 15 static void nxt_http_websocket_client(nxt_task_t *task, void *obj, void *data); 16 static void nxt_http_websocket_error_handler(nxt_task_t *task, void *obj, 29 nxt_http_websocket_client(nxt_task_t *task, void *obj, void *data) in nxt_http_websocket_client() 127 nxt_http_websocket_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_http_websocket_error_handler()
|
H A D | nxt_eventport_engine.c | 39 static void nxt_eventport_error_handler(nxt_task_t *task, void *obj, 363 nxt_eventport_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_eventport_error_handler()
|
H A D | nxt_fd_event.c | 11 static void nxt_fd_event_hash_error(nxt_task_t *task, nxt_fd_t fd); 56 nxt_fd_event_hash_get(nxt_task_t *task, nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd) in nxt_fd_event_hash_get() 77 nxt_fd_event_hash_delete(nxt_task_t *task, nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd, in nxt_fd_event_hash_delete() 109 nxt_fd_event_hash_error(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_event_hash_error()
|
H A D | nxt_fiber.h | 30 nxt_task_t task; 50 void nxt_fiber_yield(nxt_task_t *task); 51 void nxt_fiber_sleep(nxt_task_t *task, nxt_msec_t timeout); 52 void nxt_fiber_wait(nxt_task_t *task); 53 void nxt_fiber_exit(nxt_task_t *task, nxt_fiber_t *next, void *data);
|
H A D | nxt_file_event.h | 14 nxt_task_t *task;
|
H A D | nxt_epoll_engine.c | 71 static void nxt_epoll_error_handler(nxt_task_t *task, void *obj, void *data); 79 static void nxt_epoll_eventfd_handler(nxt_task_t *task, void *obj, void *data); 85 static void nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj, 92 static void nxt_epoll_edge_conn_io_connect(nxt_task_t *task, void *obj, 94 static void nxt_epoll_edge_conn_connected(nxt_task_t *task, void *obj, 650 nxt_epoll_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_error_handler() 722 nxt_epoll_signalfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_signalfd_handler() 809 nxt_epoll_eventfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_eventfd_handler() 1008 nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj, void *data) in nxt_epoll_conn_io_accept4() 1058 nxt_epoll_edge_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_epoll_edge_conn_io_connect() [all …]
|
H A D | nxt_credential.h | 22 NXT_EXPORT nxt_int_t nxt_credential_get(nxt_task_t *task, nxt_mp_t *mp, 24 NXT_EXPORT nxt_int_t nxt_credential_setuid(nxt_task_t *task, 26 NXT_EXPORT nxt_int_t nxt_credential_setgids(nxt_task_t *task,
|
H A D | nxt_conn_proxy.c | 10 static void nxt_conn_proxy_client_buffer_alloc(nxt_task_t *task, void *obj, 12 static void nxt_conn_proxy_peer_connect(nxt_task_t *task, void *obj, 16 static void nxt_conn_proxy_client_read_ready(nxt_task_t *task, void *obj, 18 static void nxt_conn_proxy_peer_read_ready(nxt_task_t *task, void *obj, 33 static void nxt_conn_proxy_read_timeout(nxt_task_t *task, void *obj, 100 nxt_conn_proxy(nxt_task_t *task, nxt_conn_proxy_t *p) in nxt_conn_proxy() 491 nxt_conn_proxy_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read() 702 nxt_conn_proxy_close(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_close() 732 nxt_conn_proxy_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_error() 851 nxt_conn_proxy_shutdown(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_shutdown() [all …]
|
H A D | nxt_conn_read.c | 38 nxt_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_read()
|
H A D | nxt_event_conn_job_sendfile.c | 19 static void nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj, 21 static void nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj, 23 static void nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, 25 static nxt_buf_t *nxt_event_conn_job_sendfile_completion(nxt_task_t *task, 30 nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_conn_t *c) in nxt_event_conn_job_sendfile() 40 nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_start() 96 nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_handler() 163 nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_return() 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_capability.h | 15 NXT_EXPORT nxt_int_t nxt_capability_set(nxt_task_t *task,
|
H A D | nxt_cert.h | 13 nxt_cert_t *nxt_cert_mem(nxt_task_t *task, nxt_buf_mem_t *mbuf); 16 void nxt_cert_info_init(nxt_task_t *task, nxt_array_t *certs); 22 nxt_array_t *nxt_cert_store_load(nxt_task_t *task, nxt_mp_t *mem_pool); 25 void nxt_cert_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp, 27 void nxt_cert_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp); 29 void nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg); 30 void nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
|
H A D | nxt_conn.c | 43 nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task) in nxt_conn_create() 93 nxt_conn_free(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_free() 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 | 10 static nxt_err_t nxt_conn_connect_test_error(nxt_task_t *task, nxt_conn_t *c); 14 nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data) in nxt_conn_sys_socket() 35 nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_connect() 78 nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_socket() 122 nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_test() 149 nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_error() 188 nxt_conn_connect_test_error(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_connect_test_error()
|