Home
last modified time | relevance | path

Searched refs:nxt_task_t (Results 1 – 25 of 124) sorted by relevance

12345

/unit/src/
H A Dnxt_http.h165 nxt_task_t task;
262 void (*close)(nxt_task_t *task, nxt_http_proto_t proto,
309 nxt_int_t nxt_http_init(nxt_task_t *task);
310 nxt_int_t nxt_h1p_init(nxt_task_t *task);
311 nxt_int_t nxt_http_response_hash_init(nxt_task_t *task);
314 nxt_http_request_t *nxt_http_request_create(nxt_task_t *task);
343 nxt_http_routes_t *nxt_http_routes_create(nxt_task_t *task,
345 nxt_http_action_t *nxt_http_action_create(nxt_task_t *task,
347 nxt_int_t nxt_http_routes_resolve(nxt_task_t *task,
354 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
[all …]
H A Dnxt_process.h64 typedef void (*nxt_isolation_cleanup_t)(nxt_task_t *task,
128 typedef nxt_int_t (*nxt_process_prefork_t)(nxt_task_t *task,
130 typedef nxt_int_t (*nxt_process_postfork_t)(nxt_task_t *task,
132 typedef nxt_int_t (*nxt_process_setup_t)(nxt_task_t *task,
134 typedef nxt_int_t (*nxt_process_start_t)(nxt_task_t *task,
158 NXT_EXPORT nxt_pid_t nxt_process_execute(nxt_task_t *task, char *name,
160 NXT_EXPORT nxt_int_t nxt_process_daemon(nxt_task_t *task);
185 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
187 nxt_int_t nxt_process_start(nxt_task_t *task, nxt_process_t *process);
190 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
[all …]
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_port_memory.h24 nxt_port_mmap_get_buf(nxt_task_t *task, nxt_port_mmaps_t *mmaps, size_t size);
26 nxt_int_t nxt_port_mmap_increase_buf(nxt_task_t *task, nxt_buf_t *b,
30 nxt_port_incoming_port_mmap(nxt_task_t *task, nxt_process_t *process,
34 nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port,
38 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg);
49 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b);
51 nxt_int_t nxt_shm_open(nxt_task_t *task, size_t size);
53 void nxt_process_broadcast_shm_ack(nxt_task_t *task, nxt_process_t *process);
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_socket.h94 NXT_EXPORT nxt_socket_t nxt_socket_create(nxt_task_t *task, nxt_uint_t family,
96 NXT_EXPORT void nxt_socket_defer_accept(nxt_task_t *task, nxt_socket_t s,
98 NXT_EXPORT nxt_int_t nxt_socket_getsockopt(nxt_task_t *task, nxt_socket_t s,
100 NXT_EXPORT nxt_int_t nxt_socket_setsockopt(nxt_task_t *task, nxt_socket_t s,
102 NXT_EXPORT nxt_int_t nxt_socket_bind(nxt_task_t *task, nxt_socket_t s,
104 NXT_EXPORT nxt_int_t nxt_socket_connect(nxt_task_t *task, nxt_socket_t s,
106 NXT_EXPORT void nxt_socket_shutdown(nxt_task_t *task, nxt_socket_t s,
108 NXT_EXPORT void nxt_socket_close(nxt_task_t *task, nxt_socket_t s);
112 NXT_EXPORT nxt_int_t nxt_socketpair_create(nxt_task_t *task,
114 NXT_EXPORT void nxt_socketpair_close(nxt_task_t *task, nxt_socket_t *pair);
H A Dnxt_http_variables.c10 static nxt_int_t nxt_http_var_method(nxt_task_t *task, nxt_str_t *str,
12 static nxt_int_t nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str,
14 static nxt_int_t nxt_http_var_uri(nxt_task_t *task, nxt_str_t *str, void *ctx);
15 static nxt_int_t nxt_http_var_host(nxt_task_t *task, nxt_str_t *str, void *ctx);
45 nxt_http_var_method(nxt_task_t *task, nxt_str_t *str, void *ctx) in nxt_http_var_method()
58 nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str, void *ctx) in nxt_http_var_request_uri()
71 nxt_http_var_uri(nxt_task_t *task, nxt_str_t *str, void *ctx) in nxt_http_var_uri()
84 nxt_http_var_host(nxt_task_t *task, nxt_str_t *str, void *ctx) in nxt_http_var_host()
H A Dnxt_signal_handlers.c14 static void nxt_signal_handler(nxt_task_t *task, void *obj, void *data);
15 static void nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data);
16 static void nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data);
32 nxt_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_handler()
40 nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_signal_quit_handler()
47 nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigterm_handler()
59 nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigquit_handler()
H A Dnxt_conn.h11 typedef ssize_t (*nxt_conn_io_read_t)(nxt_task_t *task, nxt_conn_t *c);
66 ssize_t (*sendbuf)(nxt_task_t *task,
99 nxt_task_t task;
151 nxt_task_t task;
222 NXT_EXPORT void nxt_conn_free(nxt_task_t *task, nxt_conn_t *c);
228 NXT_EXPORT nxt_sockaddr_t *nxt_conn_local_addr(nxt_task_t *task,
233 nxt_int_t nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c);
247 void nxt_conn_io_read(nxt_task_t *task, void *obj, void *data);
252 void nxt_conn_io_write(nxt_task_t *task, void *obj, void *data);
254 ssize_t nxt_conn_io_writev(nxt_task_t *task, nxt_sendbuf_t *sb,
[all …]
H A Dnxt_runtime.h12 typedef void (*nxt_runtime_cont_t)(nxt_task_t *task, nxt_uint_t status);
89 nxt_int_t nxt_runtime_create(nxt_task_t *task);
90 void nxt_runtime_quit(nxt_task_t *task, nxt_uint_t status);
98 void nxt_runtime_process_add(nxt_task_t *task, nxt_process_t *process);
111 nxt_port_t *nxt_runtime_process_port_create(nxt_task_t *task, nxt_runtime_t *rt,
114 void nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port);
115 void nxt_runtime_stop_app_processes(nxt_task_t *task, nxt_runtime_t *rt);
122 nxt_int_t nxt_runtime_controller_socket(nxt_task_t *task, nxt_runtime_t *rt);
128 nxt_int_t nxt_runtime_listen_sockets_create(nxt_task_t *task,
130 nxt_int_t nxt_runtime_listen_sockets_enable(nxt_task_t *task,
[all …]
H A Dnxt_port.h314 nxt_int_t nxt_port_socket_init(nxt_task_t *task, nxt_port_t *port,
317 void nxt_port_close(nxt_task_t *task, nxt_port_t *port);
318 void nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port);
320 void nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port);
327 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write()
335 void nxt_port_enable(nxt_task_t *task, nxt_port_t *port,
337 nxt_int_t nxt_port_send_port(nxt_task_t *task, nxt_port_t *port,
339 void nxt_port_change_log_file(nxt_task_t *task, nxt_runtime_t *rt,
346 void nxt_port_change_log_file_handler(nxt_task_t *task,
353 nxt_int_t nxt_port_post(nxt_task_t *task, nxt_port_t *port,
[all …]
H A Dnxt_http_proxy.c18 static void nxt_http_proxy_server_get(nxt_task_t *task,
20 static void nxt_http_proxy_upstream_ready(nxt_task_t *task,
22 static void nxt_http_proxy_upstream_error(nxt_task_t *task,
24 static nxt_http_action_t *nxt_http_proxy(nxt_task_t *task,
104 nxt_http_proxy(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy()
118 nxt_upstream_proxy_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_upstream_proxy_handler()
203 nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_send()
225 nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_sent()
247 nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_read()
293 nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_send_body()
[all …]
H A Dnxt_tls.h36 nxt_int_t (*library_init)(nxt_task_t *task);
37 void (*library_free)(nxt_task_t *task);
39 nxt_int_t (*server_init)(nxt_task_t *task, nxt_mp_t *mp,
42 void (*server_free)(nxt_task_t *task,
70 void (*conn_init)(nxt_task_t *task,
98 void nxt_cdecl nxt_openssl_log_error(nxt_task_t *task, nxt_uint_t level,
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_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_stream_source.c10 static void nxt_stream_source_connected(nxt_task_t *task, void *obj,
12 static void nxt_stream_source_write_ready(nxt_task_t *task, void *obj,
14 static void nxt_stream_source_read_ready(nxt_task_t *task, void *obj,
18 static void nxt_stream_source_buf_completion(nxt_task_t *task, void *obj,
20 static void nxt_stream_source_read_done(nxt_task_t *task, void *obj,
25 static void nxt_stream_source_close(nxt_task_t *task,
92 nxt_stream_source_connected(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_connected()
396 nxt_stream_source_refused(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_refused()
417 nxt_stream_source_closed(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_closed()
443 nxt_stream_source_error(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_error()
[all …]
H A Dnxt_h1proto.c32 static nxt_int_t nxt_h1p_header_buffer_test(nxt_task_t *task,
48 static void nxt_h1p_request_header_send(nxt_task_t *task,
83 static void nxt_h1p_shutdown(nxt_task_t *task, nxt_conn_t *c);
84 static void nxt_h1p_closing(nxt_task_t *task, nxt_conn_t *c);
194 nxt_h1p_init(nxt_task_t *task) in nxt_h1p_init()
212 nxt_http_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_init()
309 nxt_http_conn_test(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_test()
1714 nxt_h1p_conn_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_sent()
1892 nxt_h1p_idle_response(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_idle_response()
2000 nxt_h1p_shutdown(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_shutdown()
[all …]
H A Dnxt_conn_accept.c21 static nxt_conn_t *nxt_conn_accept_alloc(nxt_task_t *task,
23 static void nxt_conn_listen_handler(nxt_task_t *task, void *obj,
25 static nxt_conn_t *nxt_conn_accept_next(nxt_task_t *task,
27 static void nxt_conn_accept_close_idle(nxt_task_t *task,
31 static void nxt_conn_listen_event_error(nxt_task_t *task, void *obj,
38 nxt_listen_event(nxt_task_t *task, nxt_listen_socket_t *ls) in nxt_listen_event()
86 nxt_conn_accept_alloc(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_alloc()
124 nxt_conn_listen_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_handler()
136 nxt_conn_io_accept(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_accept()
230 nxt_conn_accept_next(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_next()
[all …]
H A Dnxt_isolation.h9 nxt_int_t nxt_isolation_main_prefork(nxt_task_t *task, nxt_process_t *process,
13 nxt_int_t nxt_isolation_prepare_rootfs(nxt_task_t *task,
15 nxt_int_t nxt_isolation_change_root(nxt_task_t *task, nxt_process_t *process);
H A Dnxt_process.c33 static nxt_int_t nxt_process_child_fixup(nxt_task_t *task,
39 static nxt_int_t nxt_process_send_created(nxt_task_t *task,
41 static nxt_int_t nxt_process_send_ready(nxt_task_t *task,
45 static void nxt_process_created_error(nxt_task_t *task,
121 nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i) in nxt_process_use()
164 nxt_process_start(nxt_task_t *task, nxt_process_t *process) in nxt_process_start()
304 nxt_process_create(nxt_task_t *task, nxt_process_t *process) in nxt_process_create()
362 nxt_process_setup(nxt_task_t *task, nxt_process_t *process) in nxt_process_setup()
479 nxt_process_whoami(nxt_task_t *task, nxt_process_t *process) in nxt_process_whoami()
885 nxt_process_daemon(nxt_task_t *task) in nxt_process_daemon()
[all …]
H A Dnxt_port.c17 static void nxt_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
23 nxt_port_mp_cleanup(nxt_task_t *task, void *obj, void *data) in nxt_port_mp_cleanup()
49 nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid, in nxt_port_new()
88 nxt_port_close(nxt_task_t *task, nxt_port_t *port) in nxt_port_close()
127 nxt_port_release(nxt_task_t *task, nxt_port_t *port) in nxt_port_release()
161 nxt_port_enable(nxt_task_t *task, nxt_port_t *port, in nxt_port_enable()
173 nxt_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_handler()
203 nxt_port_send_new_port(nxt_task_t *task, nxt_runtime_t *rt, in nxt_port_send_new_port()
555 nxt_port_post_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_post_handler()
574 nxt_port_post(nxt_task_t *task, nxt_port_t *port, in nxt_port_post()
[all …]
H A Dnxt_conn_close.c10 static void nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data);
11 static void nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data);
12 static void nxt_conn_close_timer_handler(nxt_task_t *task, void *obj,
14 static void nxt_conn_close_error_ignore(nxt_task_t *task, void *obj,
75 nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_shutdown_handler()
95 nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_handler()
138 nxt_conn_close_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_timer_handler()
161 nxt_conn_close_error_ignore(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_error_ignore()
H A Dnxt_upstream.h17 typedef void (*nxt_upstream_peer_ready_t)(nxt_task_t *task,
19 typedef void (*nxt_upstream_peer_error_t)(nxt_task_t *task,
31 typedef void (*nxt_upstream_server_get_t)(nxt_task_t *task,
76 nxt_int_t nxt_upstream_round_robin_create(nxt_task_t *task,
H A Dnxt_job.h36 nxt_task_t *task;
61 NXT_EXPORT void nxt_job_destroy(nxt_task_t *task, void *data);
64 NXT_EXPORT void nxt_job_start(nxt_task_t *task, nxt_job_t *job,
66 NXT_EXPORT void nxt_job_return(nxt_task_t *task, nxt_job_t *job,
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,

12345