Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 102) sorted by last modified time

12345

/unit/src/
H A Dnxt_var.c233 nxt_var_cache_value(nxt_task_t *task, nxt_var_cache_t *cache, uint32_t index, in nxt_var_cache_value()
507 nxt_var_interpreter(nxt_task_t *task, nxt_var_cache_t *cache, nxt_var_t *var, in nxt_var_interpreter()
H A Dnxt_router.h93 nxt_task_t task; member
H A Dnxt_tstr.c242 nxt_tstr_query(nxt_task_t *task, nxt_tstr_query_t *query, nxt_tstr_t *tstr, in nxt_tstr_query()
291 nxt_tstr_query_resolve(nxt_task_t *task, nxt_tstr_query_t *query, void *data, in nxt_tstr_query_resolve()
307 nxt_tstr_query_handle(nxt_task_t *task, nxt_tstr_query_t *query, in nxt_tstr_query_handle()
H A Dnxt_router_access_log.c60 nxt_router_access_log_create(nxt_task_t *task, nxt_router_conf_t *rtcf, in nxt_router_access_log_create()
141 nxt_router_access_log_writer(nxt_task_t *task, nxt_http_request_t *r, in nxt_router_access_log_writer()
178 nxt_router_access_log_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_ready()
193 nxt_router_access_log_write_error(nxt_task_t *task, void *obj, void *data) in nxt_router_access_log_write_error()
200 nxt_router_access_log_open(nxt_task_t *task, nxt_router_temp_conf_t *tmcf) in nxt_router_access_log_open()
250 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready()
268 nxt_router_access_log_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_error()
296 nxt_router_access_log_release(nxt_task_t *task, nxt_thread_spinlock_t *lock, in nxt_router_access_log_release()
329 nxt_router_access_log_reopen_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_access_log_reopen_handler()
413 nxt_router_access_log_reopen_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_ready()
[all …]
H A Dnxt_router.c314 nxt_router_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_router_start()
485 nxt_router_start_app_process(nxt_task_t *task, nxt_app_t *app) in nxt_router_start_app_process()
580 nxt_request_rpc_data_unlink(nxt_task_t *task, in nxt_request_rpc_data_unlink()
1045 nxt_router_temp_conf(nxt_task_t *task) in nxt_router_temp_conf()
2625 nxt_router_listen_socket_rpc_create(nxt_task_t *task, in nxt_router_listen_socket_rpc_create()
2854 nxt_router_app_rpc_create(nxt_task_t *task, in nxt_router_app_rpc_create()
3414 nxt_task_t *task; in nxt_router_thread_start() local
4028 nxt_router_req_headers_ack_handler(nxt_task_t *task, in nxt_router_req_headers_ack_handler()
4458 nxt_router_app_unlink(nxt_task_t *task, nxt_app_t *app) in nxt_router_app_unlink()
4891 nxt_router_app_port_get(nxt_task_t *task, nxt_app_t *app, in nxt_router_app_port_get()
[all …]
H A Dnxt_http_static.c74 nxt_http_static_init(nxt_task_t *task, nxt_router_temp_conf_t *tmcf, in nxt_http_static_init()
189 nxt_http_static(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static()
228 nxt_http_static_iterate(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static_iterate()
301 nxt_http_static_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_ready()
665 nxt_http_static_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_error()
676 nxt_http_static_next(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static_next()
787 nxt_http_static_body_handler(nxt_task_t *task, void *obj, void *data) in nxt_http_static_body_handler()
849 nxt_http_static_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_http_static_buf_completion()
H A Dnxt_js.c202 nxt_js_call(nxt_task_t *task, nxt_js_cache_t *cache, nxt_js_t *js, in nxt_js_call()
H A Dnxt_http_variables.c119 nxt_http_var_request_time(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_request_time()
160 nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_request_uri()
174 nxt_http_var_uri(nxt_task_t *task, nxt_str_t *str, void *ctx, uint16_t field) in nxt_http_var_uri()
187 nxt_http_var_host(nxt_task_t *task, nxt_str_t *str, void *ctx, uint16_t field) in nxt_http_var_host()
200 nxt_http_var_remote_addr(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_remote_addr()
215 nxt_http_var_time_local(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_time_local()
273 nxt_http_var_request_line(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_request_line()
316 nxt_http_var_body_bytes_sent(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_body_bytes_sent()
358 nxt_http_var_referer(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_referer()
378 nxt_http_var_user_agent(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_user_agent()
[all …]
H A Dnxt_http_return.c75 nxt_http_return(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_return()
177 nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_ready()
220 nxt_http_return_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_error()
H A Dnxt_http_route.c686 nxt_http_route_table_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_table_create()
725 nxt_http_route_ruleset_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_ruleset_create()
773 nxt_http_route_rule_name_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_name_create()
801 nxt_http_route_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_create()
843 nxt_http_route_addr_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_addr_rule_create()
884 nxt_http_route_types_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_types_rule_create()
925 nxt_http_route_pattern_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_pattern_create()
1293 nxt_http_pass_var(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_pass_var()
1337 nxt_http_pass_query_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_pass_query_ready()
1540 nxt_http_route_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_route_handler()
[all …]
H A Dnxt_http_request.c66 nxt_http_init(nxt_task_t *task) in nxt_http_init()
244 nxt_http_request_create(nxt_task_t *task) in nxt_http_request_create()
306 nxt_http_request_start(nxt_task_t *task, void *obj, void *data) in nxt_http_request_start()
342 nxt_http_request_forward(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_forward()
542 nxt_http_request_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_request_ready()
555 nxt_http_request_action(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_action()
579 nxt_http_application_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_application_handler()
604 nxt_http_request_proto_info(nxt_task_t *task, nxt_http_request_t *r) in nxt_http_request_proto_info()
613 nxt_http_request_read_body(nxt_task_t *task, nxt_http_request_t *r) in nxt_http_request_read_body()
622 nxt_http_request_header_send(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_header_send()
[all …]
H A Dnxt_http.h167 nxt_task_t task; member
H A Dnxt_main_process.c82 nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task, in nxt_main_process_start()
320 nxt_main_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_data_handler()
328 nxt_main_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_new_port_handler()
354 nxt_main_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_start_process_handler()
685 nxt_main_process_port_create(nxt_task_t *task, nxt_runtime_t *rt) in nxt_main_process_port_create()
718 nxt_main_process_title(nxt_task_t *task) in nxt_main_process_title()
744 nxt_main_process_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_sigterm_handler()
758 nxt_main_process_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_sigquit_handler()
997 nxt_main_process_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_signal_handler()
1005 nxt_main_process_cleanup(nxt_task_t *task, nxt_process_t *process) in nxt_main_process_cleanup()
[all …]
H A Dnxt_sockaddr.c184 nxt_getsockname(nxt_task_t *task, nxt_mp_t *mp, nxt_socket_t s) in nxt_getsockname()
H A Dnxt_php_sapi.c367 nxt_php_setup(nxt_task_t *task, nxt_process_t *process, in nxt_php_setup()
450 nxt_php_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_php_start()
519 nxt_php_set_target(nxt_task_t *task, nxt_php_target_t *target, in nxt_php_set_target()
633 nxt_php_set_ini_path(nxt_task_t *task, nxt_str_t *ini_path, char *workdir) in nxt_php_set_ini_path()
673 nxt_php_set_options(nxt_task_t *task, nxt_conf_value_t *options, int type) in nxt_php_set_options()
816 nxt_php_disable(nxt_task_t *task, const char *type, nxt_str_t *value, in nxt_php_disable()
H A Dnxt_openssl.c133 nxt_openssl_library_init(nxt_task_t *task) in nxt_openssl_library_init()
208 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free()
268 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free()
294 nxt_openssl_server_init(nxt_task_t *task, nxt_mp_t *mp, in nxt_openssl_server_init()
976 nxt_openssl_bundle_hash_insert(nxt_task_t *task, nxt_lvlhsh_t *lvlhsh,
1136 nxt_openssl_server_free(nxt_task_t *task, nxt_tls_conf_t *conf)
1221 nxt_openssl_conn_free(nxt_task_t *task, nxt_conn_t *c)
1238 nxt_openssl_conn_handshake(nxt_task_t *task, void *obj, void *data)
1367 nxt_openssl_conn_io_sendbuf(nxt_task_t *task, nxt_sendbuf_t *sb)
1423 nxt_openssl_conn_io_shutdown(nxt_task_t *task, void *obj, void *data)
[all …]
H A Dnxt_controller.c296 nxt_controller_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_controller_start()
385 nxt_controller_process_new_port_handler(nxt_task_t *task, in nxt_controller_process_new_port_handler()
401 nxt_controller_send_current_conf(nxt_task_t *task) in nxt_controller_send_current_conf()
443 nxt_controller_router_ready_handler(nxt_task_t *task, in nxt_controller_router_ready_handler()
546 nxt_controller_flush_requests(nxt_task_t *task) in nxt_controller_flush_requests()
688 nxt_controller_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_init()
749 nxt_controller_conn_read(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_read()
997 nxt_controller_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_free()
1481 nxt_controller_check_postpone_request(nxt_task_t *task) in nxt_controller_check_postpone_request()
1626 nxt_controller_process_cert(nxt_task_t *task, in nxt_controller_process_cert()
[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()
1893 nxt_h1p_idle_response(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_idle_response()
2001 nxt_h1p_shutdown(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_shutdown()
2048 nxt_h1p_closing(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_closing()
2105 nxt_h1p_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_free()
2627 nxt_h1p_peer_read(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_read()
[all …]
H A Dnxt_application.c164 nxt_discovery_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_discovery_start()
206 nxt_discovery_modules(nxt_task_t *task, const char *path) in nxt_discovery_modules()
506 nxt_proto_setup(nxt_task_t *task, nxt_process_t *process) in nxt_proto_setup()
586 nxt_proto_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_proto_start()
687 nxt_proto_quit_children(nxt_task_t *task) in nxt_proto_quit_children()
864 nxt_app_module_load(nxt_task_t *task, const char *name) in nxt_app_module_load()
959 nxt_app_setup(nxt_task_t *task, nxt_process_t *process) in nxt_app_setup()
1056 nxt_unit_default_init(nxt_task_t *task, nxt_unit_init_t *init, in nxt_unit_default_init()
1146 nxt_proto_process_add(nxt_task_t *task, nxt_process_t *process) in nxt_proto_process_add()
1176 nxt_proto_process_remove(nxt_task_t *task, nxt_pid_t pid) in nxt_proto_process_remove()
[all …]
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 …]
/unit/src/python/
H A Dnxt_python.c68 nxt_python_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_python_start()
317 nxt_python_set_target(nxt_task_t *task, nxt_python_target_t *target, in nxt_python_set_target()
392 nxt_python_set_path(nxt_task_t *task, nxt_conf_value_t *value) in nxt_python_set_path()
H A Dnxt_python_asgi.c415 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local
/unit/src/test/
H A Dnxt_tests.c28 nxt_task_t task; in main() local
H A Dnxt_utf8_file_name_test.c47 nxt_task_t task; in nxt_utf8_file_name_test() local
/unit/src/perl/
H A Dnxt_perl_psgi.c1129 nxt_perl_psgi_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_perl_psgi_start()

12345