Home
last modified time | relevance | path

Searched refs:nxt_task_t (Results 101 – 123 of 123) sorted by last modified time

12345

/unit/src/
H A Dnxt_sendbuf.h110 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 Dnxt_port_rpc.h11 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 Dnxt_process_title.c46 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 Dnxt_log_moderation.c10 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 Dnxt_mp.h110 nxt_task_t *task, void *obj, void *data);
H A Dnxt_lib.c12 nxt_task_t nxt_main_task;
H A Dnxt_listen_socket.h54 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 Dnxt_http_error.c11 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 Dnxt_http_response.c37 nxt_http_response_hash_init(nxt_task_t *task) in nxt_http_response_hash_init()
H A Dnxt_http_websocket.c15 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 Dnxt_eventport_engine.c39 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 Dnxt_fd_event.c11 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 Dnxt_fiber.h30 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 Dnxt_file_event.h14 nxt_task_t *task;
H A Dnxt_epoll_engine.c71 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 Dnxt_credential.h22 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 Dnxt_conn_proxy.c10 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 Dnxt_conn_read.c38 nxt_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_read()
H A Dnxt_event_conn_job_sendfile.c19 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 Dnxt_capability.h15 NXT_EXPORT nxt_int_t nxt_capability_set(nxt_task_t *task,
H A Dnxt_cert.h13 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 Dnxt_conn.c43 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 Dnxt_conn_connect.c10 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()

12345