Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 99) sorted by relevance

1234

/unit/src/
H A Dnxt_port.c23 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()
195 nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_quit_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_accept.c38 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()
188 nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev, nxt_conn_t *c) in nxt_conn_accept()
230 nxt_conn_accept_next(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_next()
249 nxt_conn_accept_close_idle(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_close_idle()
267 nxt_conn_accept_close_idle_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_accept_close_idle_handler()
312 nxt_conn_accept_error(nxt_task_t *task, nxt_listen_event_t *lev, in nxt_conn_accept_error()
352 nxt_conn_listen_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_timer_handler()
[all …]
H A Dnxt_process.c121 nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i) in nxt_process_use()
132 nxt_process_init_start(nxt_task_t *task, nxt_process_init_t init) in nxt_process_init_start()
164 nxt_process_start(nxt_task_t *task, nxt_process_t *process) in nxt_process_start()
247 nxt_process_child_fixup(nxt_task_t *task, nxt_process_t *process) in nxt_process_child_fixup()
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()
429 nxt_process_do_start(nxt_task_t *task, nxt_process_t *process) in nxt_process_do_start()
479 nxt_process_whoami(nxt_task_t *task, nxt_process_t *process) in nxt_process_whoami()
683 nxt_process_core_setup(nxt_task_t *task, nxt_process_t *process) in nxt_process_core_setup()
885 nxt_process_daemon(nxt_task_t *task) in nxt_process_daemon()
[all …]
H A Dnxt_fiber.c124 nxt_fiber_create_stack(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_create_stack()
159 nxt_fiber_create_stack(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_create_stack()
235 nxt_task_t *task; in nxt_fiber_trampoline() local
300 nxt_task_t *task; in nxt_fiber_trampoline() local
331 nxt_fiber_switch_handler(nxt_task_t *task, void *obj, void *data) in nxt_fiber_switch_handler()
343 nxt_fiber_switch(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_switch()
363 nxt_fiber_yield(nxt_task_t *task) in nxt_fiber_yield()
385 nxt_fiber_sleep(nxt_task_t *task, nxt_msec_t timeout) in nxt_fiber_sleep()
413 nxt_fiber_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_fiber_timer_handler()
431 nxt_fiber_wait(nxt_task_t *task) in nxt_fiber_wait()
[all …]
H A Dnxt_signal_handlers.c32 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_proxy.c100 nxt_conn_proxy(nxt_task_t *task, nxt_conn_proxy_t *p) in nxt_conn_proxy()
205 nxt_conn_proxy_peer_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_peer_connect()
243 nxt_conn_proxy_connected(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_connected()
293 nxt_conn_proxy_peer_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_peer_read()
377 nxt_conn_proxy_read_process(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_read_process()
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()
790 nxt_conn_proxy_refused(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_refused()
851 nxt_conn_proxy_shutdown(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_shutdown()
[all …]
H A Dnxt_conn_connect.c14 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()
H A Dnxt_stream_source.c36 nxt_stream_source_connect(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_stream_source_connect()
92 nxt_stream_source_connected(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_connected()
153 nxt_stream_source_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_write_ready()
166 nxt_stream_source_read_ready(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_read_ready()
241 nxt_stream_source_read_done(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_read_done()
342 nxt_stream_source_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_stream_source_buf_completion()
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()
464 nxt_stream_source_close(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_stream_source_close()
[all …]
H A Dnxt_h1proto.c194 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()
638 nxt_h1p_header_process(nxt_task_t *task, nxt_h1proto_t *h1p, in nxt_h1p_header_process()
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()
2047 nxt_h1p_closing(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_closing()
2104 nxt_h1p_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_free()
2626 nxt_h1p_peer_read(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_read()
[all …]
H A Dnxt_isolation.c65 nxt_isolation_main_prefork(nxt_task_t *task, nxt_process_t *process, in nxt_isolation_main_prefork()
155 nxt_isolation_set(nxt_task_t *task, nxt_conf_value_t *isolation, in nxt_isolation_set()
228 nxt_isolation_set_creds(nxt_task_t *task, nxt_conf_value_t *isolation, in nxt_isolation_set_creds()
265 nxt_isolation_credential_map(nxt_task_t *task, nxt_mp_t *mp, in nxt_isolation_credential_map()
320 nxt_isolation_vldt_creds(nxt_task_t *task, nxt_process_t *process) in nxt_isolation_vldt_creds()
519 nxt_isolation_set_mounts(nxt_task_t *task, nxt_process_t *process, in nxt_isolation_set_mounts()
665 nxt_isolation_unmount_all(nxt_task_t *task, nxt_process_t *process) in nxt_isolation_unmount_all()
758 nxt_isolation_change_root(nxt_task_t *task, nxt_process_t *process) in nxt_isolation_change_root()
791 nxt_isolation_pivot_root(nxt_task_t *task, const char *path) in nxt_isolation_pivot_root()
1014 nxt_isolation_change_root(nxt_task_t *task, nxt_process_t *process) in nxt_isolation_change_root()
[all …]
H A Dnxt_socket.c15 nxt_socket_create(nxt_task_t *task, nxt_uint_t domain, nxt_uint_t type, in nxt_socket_create()
54 nxt_socket_defer_accept(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa) in nxt_socket_defer_accept()
75 nxt_socket_getsockopt(nxt_task_t *task, nxt_socket_t s, nxt_uint_t level, in nxt_socket_getsockopt()
98 nxt_socket_setsockopt(nxt_task_t *task, nxt_socket_t s, nxt_uint_t level, in nxt_socket_setsockopt()
175 nxt_socket_bind(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa) in nxt_socket_bind()
192 nxt_socket_connect(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa) in nxt_socket_connect()
248 nxt_socket_shutdown(nxt_task_t *task, nxt_socket_t s, nxt_uint_t how) in nxt_socket_shutdown()
283 nxt_socket_close(nxt_task_t *task, nxt_socket_t s) in nxt_socket_close()
H A Dnxt_buf_filter.c24 nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f, nxt_buf_t *b) in nxt_buf_filter_add()
33 nxt_buf_filter(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter()
211 nxt_buf_filter_enqueue(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_enqueue()
224 nxt_buf_filter_file_read_start(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_file_read_start()
255 nxt_buf_filter_file_read(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_file_read()
332 nxt_buf_filter_file_job_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_file_job_completion()
400 nxt_buf_filter_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_buf_completion()
441 nxt_buf_filter_file_read_error(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_file_read_error()
H A Dnxt_http_proxy.c104 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()
153 nxt_http_proxy_server_get(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_http_proxy_server_get()
167 nxt_http_proxy_upstream_ready(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_http_proxy_upstream_ready()
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()
320 nxt_http_proxy_buf_mem_alloc(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy_buf_mem_alloc()
366 nxt_http_proxy_buf_mem_free(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy_buf_mem_free()
[all …]
H A Dnxt_job.c60 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy()
107 nxt_job_start(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_start()
135 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline()
155 nxt_job_return(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_return()
181 nxt_job_thread_return_handler(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_return_handler()
H A Dnxt_credential.c14 nxt_credential_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc, in nxt_credential_get()
95 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, in nxt_credential_groups_get()
180 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc) in nxt_credential_groups_get()
283 nxt_credential_setuid(nxt_task_t *task, nxt_credential_t *uc) in nxt_credential_setuid()
306 nxt_credential_setgids(nxt_task_t *task, nxt_credential_t *uc) in nxt_credential_setgids()
H A Dnxt_application.c157 nxt_discovery_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_discovery_start()
199 nxt_discovery_modules(nxt_task_t *task, const char *path) in nxt_discovery_modules()
499 nxt_proto_setup(nxt_task_t *task, nxt_process_t *process) in nxt_proto_setup()
579 nxt_proto_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_proto_start()
678 nxt_proto_quit_children(nxt_task_t *task) in nxt_proto_quit_children()
821 nxt_app_module_load(nxt_task_t *task, const char *name) in nxt_app_module_load()
916 nxt_app_setup(nxt_task_t *task, nxt_process_t *process) in nxt_app_setup()
1013 nxt_unit_default_init(nxt_task_t *task, nxt_unit_init_t *init, in nxt_unit_default_init()
1103 nxt_proto_process_add(nxt_task_t *task, nxt_process_t *process) in nxt_proto_process_add()
1133 nxt_proto_process_remove(nxt_task_t *task, nxt_pid_t pid) in nxt_proto_process_remove()
[all …]
H A Dnxt_controller.c288 nxt_controller_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_controller_start()
377 nxt_controller_process_new_port_handler(nxt_task_t *task, in nxt_controller_process_new_port_handler()
393 nxt_controller_send_current_conf(nxt_task_t *task) in nxt_controller_send_current_conf()
435 nxt_controller_router_ready_handler(nxt_task_t *task, in nxt_controller_router_ready_handler()
538 nxt_controller_flush_requests(nxt_task_t *task) in nxt_controller_flush_requests()
672 nxt_controller_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_init()
733 nxt_controller_conn_read(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_read()
981 nxt_controller_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_free()
1434 nxt_controller_check_postpone_request(nxt_task_t *task) in nxt_controller_check_postpone_request()
1457 nxt_controller_process_cert(nxt_task_t *task, in nxt_controller_process_cert()
[all …]
H A Dnxt_port_memory.c118 nxt_port_mmap_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_port_mmap_buf_completion()
204 nxt_port_incoming_port_mmap(nxt_task_t *task, nxt_process_t *process, in nxt_port_incoming_port_mmap()
287 nxt_port_new_port_mmap(nxt_task_t *task, nxt_port_mmaps_t *mmaps, in nxt_port_new_port_mmap()
368 nxt_shm_open(nxt_task_t *task, size_t size) in nxt_shm_open()
543 nxt_port_mmap_get_tracking(nxt_task_t *task, nxt_port_mmaps_t *mmaps, in nxt_port_mmap_get_tracking()
574 nxt_port_mmap_tracking_cancel(nxt_task_t *task, in nxt_port_mmap_tracking_cancel()
631 nxt_port_mmap_tracking_read(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_mmap_tracking_read()
729 nxt_port_mmap_increase_buf(nxt_task_t *task, nxt_buf_t *b, size_t size, in nxt_port_mmap_increase_buf()
795 nxt_port_mmap_get_incoming_buf(nxt_task_t *task, nxt_port_t *port, in nxt_port_mmap_get_incoming_buf()
842 nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_mmap_write()
[all …]
H A Dnxt_h1proto_websocket.c117 nxt_h1p_websocket_frame_start(nxt_task_t *task, nxt_http_request_t *r, in nxt_h1p_websocket_frame_start()
161 nxt_h1p_conn_ws_keepalive(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_keepalive()
358 nxt_h1p_conn_ws_keepalive_disable(nxt_task_t *task, nxt_h1proto_t *h1p) in nxt_h1p_conn_ws_keepalive_disable()
378 nxt_h1p_conn_ws_keepalive_enable(nxt_task_t *task, nxt_h1proto_t *h1p) in nxt_h1p_conn_ws_keepalive_enable()
399 nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c, in nxt_h1p_conn_ws_frame_process()
442 nxt_h1p_conn_ws_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error()
462 nxt_h1p_ws_io_read_handler(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_ws_io_read_handler()
496 nxt_h1p_conn_ws_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_timeout()
578 hxt_h1p_send_ws_error(nxt_task_t *task, nxt_http_request_t *r, in hxt_h1p_send_ws_error()
633 nxt_h1p_conn_ws_error_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error_sent()
[all …]
H A Dnxt_runtime.c47 nxt_runtime_create(nxt_task_t *task) in nxt_runtime_create()
279 nxt_runtime_event_engines(nxt_task_t *task, nxt_runtime_t *rt) in nxt_runtime_event_engines()
340 nxt_runtime_start(nxt_task_t *task, void *obj, void *data) in nxt_runtime_start()
375 nxt_runtime_initial_start(nxt_task_t *task, nxt_uint_t status) in nxt_runtime_initial_start()
431 nxt_runtime_quit(nxt_task_t *task, nxt_uint_t status) in nxt_runtime_quit()
543 nxt_runtime_exit(nxt_task_t *task, void *obj, void *data) in nxt_runtime_exit()
753 nxt_runtime_conf_init(nxt_task_t *task, nxt_runtime_t *rt) in nxt_runtime_conf_init()
913 nxt_runtime_conf_read_cmd(nxt_task_t *task, nxt_runtime_t *rt) in nxt_runtime_conf_read_cmd()
1147 nxt_runtime_hostname(nxt_task_t *task, nxt_runtime_t *rt) in nxt_runtime_hostname()
1669 nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_add()
[all …]
H A Dnxt_router.c335 nxt_router_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_router_start()
506 nxt_router_start_app_process(nxt_task_t *task, nxt_app_t *app) in nxt_router_start_app_process()
601 nxt_request_rpc_data_unlink(nxt_task_t *task, in nxt_request_rpc_data_unlink()
988 nxt_router_temp_conf(nxt_task_t *task) in nxt_router_temp_conf()
2542 nxt_router_listen_socket_rpc_create(nxt_task_t *task, in nxt_router_listen_socket_rpc_create()
2771 nxt_router_app_rpc_create(nxt_task_t *task, in nxt_router_app_rpc_create()
3331 nxt_task_t *task; in nxt_router_thread_start() local
4323 nxt_router_req_headers_ack_handler(nxt_task_t *task, in nxt_router_req_headers_ack_handler()
4753 nxt_router_app_unlink(nxt_task_t *task, nxt_app_t *app) in nxt_router_app_unlink()
5186 nxt_router_app_port_get(nxt_task_t *task, nxt_app_t *app, in nxt_router_app_port_get()
[all …]
H A Dnxt_http_source.c47 nxt_http_source_handler(nxt_task_t *task, nxt_upstream_source_t *us, in nxt_http_source_handler()
187 nxt_http_source_status_filter(nxt_task_t *task, void *obj, void *data) in nxt_http_source_status_filter()
260 nxt_http_source_header_filter(nxt_task_t *task, void *obj, void *data) in nxt_http_source_header_filter()
428 nxt_http_source_header_ready(nxt_task_t *task, nxt_http_source_t *hs, in nxt_http_source_header_ready()
498 nxt_http_source_chunk_filter(nxt_task_t *task, void *obj, void *data) in nxt_http_source_chunk_filter()
533 nxt_http_source_chunk_error(nxt_task_t *task, void *obj, void *data) in nxt_http_source_chunk_error()
549 nxt_http_source_body_filter(nxt_task_t *task, void *obj, void *data) in nxt_http_source_body_filter()
578 nxt_http_source_sync_buffer(nxt_task_t *task, nxt_http_source_t *hs, in nxt_http_source_sync_buffer()
598 nxt_http_source_error(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_http_source_error()
610 nxt_http_source_fail(nxt_task_t *task, nxt_http_source_t *hs) in nxt_http_source_fail()
H A Dnxt_stream_module.c18 nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data) in nxt_stream_connection_init()
58 nxt_stream_connection_peer(nxt_task_t *task, nxt_upstream_peer_t *up) in nxt_stream_connection_peer()
122 nxt_stream_connection_close(nxt_task_t *task, void *obj, void *data) in nxt_stream_connection_close()
H A Dnxt_main_process.c82 nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task, in nxt_main_process_start()
332 nxt_main_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_data_handler()
340 nxt_main_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_new_port_handler()
366 nxt_main_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_start_process_handler()
697 nxt_main_process_port_create(nxt_task_t *task, nxt_runtime_t *rt) in nxt_main_process_port_create()
730 nxt_main_process_title(nxt_task_t *task) in nxt_main_process_title()
756 nxt_main_process_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_sigterm_handler()
770 nxt_main_process_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_sigquit_handler()
1009 nxt_main_process_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_signal_handler()
1017 nxt_main_process_cleanup(nxt_task_t *task, nxt_process_t *process) in nxt_main_process_cleanup()
[all …]
H A Dnxt_conn_close.c75 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()

1234