Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 136) sorted by last modified time

123456

/unit/src/
H A Dnxt_var.c61 static nxt_str_t *nxt_var_cache_value(nxt_task_t *task, nxt_var_query_t *query,
235 nxt_var_cache_value(nxt_task_t *task, nxt_var_query_t *query, uint32_t index) in nxt_var_cache_value() argument
266 ret = nxt_var_index[index >> 16](task, value, query->ctx, in nxt_var_cache_value()
556 nxt_var_query(nxt_task_t *task, nxt_var_query_t *query, nxt_var_t *var, in nxt_var_query() argument
587 value = nxt_var_cache_value(task, query, subs[i].index); in nxt_var_query()
643 nxt_debug(task, "var: \"%*s\" -> \"%V\"", length, src, str); in nxt_var_query()
662 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_var_query_resolve()
664 task, query->ctx, query->data); in nxt_var_query_resolve()
670 nxt_var_query_handle(nxt_task_t *task, nxt_var_query_t *query, in nxt_var_query_handle() argument
676 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_var_query_handle()
[all …]
H A Dnxt_main_process.c91 nxt_main_process_title(task); in nxt_main_process_start()
368 rt = task->thread->runtime; in nxt_main_start_process_handler()
448 rt = task->thread->runtime; in nxt_main_start_process_handler()
546 rt = task->thread->runtime; in nxt_main_process_created_handler()
622 rt = task->thread->runtime; in nxt_main_process_whoami_handler()
650 port->socket.task = task; in nxt_main_process_whoami_handler()
753 nxt_runtime_quit(task, 0); in nxt_main_process_sigterm_handler()
767 nxt_runtime_quit(task, 0); in nxt_main_process_sigquit_handler()
785 rt = task->thread->runtime; in nxt_main_process_sigusr1_handler()
885 rt = task->thread->runtime; in nxt_main_process_sigchld_handler()
[all …]
H A Dnxt_application.h30 typedef nxt_int_t (*nxt_application_setup_t)(nxt_task_t *task,
142 NXT_EXPORT nxt_int_t nxt_unit_default_init(nxt_task_t *task,
H A Dnxt_var.h14 typedef nxt_int_t (*nxt_var_handler_t)(nxt_task_t *task,
62 void nxt_var_query(nxt_task_t *task, nxt_var_query_t *query,
64 void nxt_var_query_resolve(nxt_task_t *task, nxt_var_query_t *query, void *data,
66 void nxt_var_query_handle(nxt_task_t *task, nxt_var_query_t *query,
H A Dnxt_sockaddr.c184 nxt_getsockname(nxt_task_t *task, nxt_mp_t *mp, nxt_socket_t s) in nxt_getsockname() argument
222 nxt_log(task, NXT_LOG_ERR, "getsockname(%d) failed %E", s, nxt_errno); in nxt_getsockname()
H A Dnxt_php_sapi.c367 nxt_php_setup(nxt_task_t *task, nxt_process_t *process, in nxt_php_setup() argument
410 ret = nxt_php_set_ini_path(task, &ini_path, in nxt_php_setup()
426 nxt_php_set_options(task, value, ZEND_INI_SYSTEM); in nxt_php_setup()
429 nxt_php_set_options(task, value, ZEND_INI_USER); in nxt_php_setup()
450 nxt_php_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_php_start() argument
494 ret = nxt_unit_default_init(task, &php_init, conf); in nxt_php_start()
496 nxt_alert(task, "nxt_unit_default_init() failed"); in nxt_php_start()
691 nxt_log(task, NXT_LOG_ERR, in nxt_php_set_options()
700 nxt_php_disable(task, "function", &value, in nxt_php_set_options()
708 nxt_php_disable(task, "class", &value, in nxt_php_set_options()
[all …]
H A Dnxt_http_route.c190 static nxt_int_t nxt_http_route_resolve(nxt_task_t *task,
192 static nxt_int_t nxt_http_action_resolve(nxt_task_t *task,
801 nxt_http_route_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_create() argument
887 return nxt_http_route_rule_create(task, mp, types, 0, in nxt_http_route_types_rule_create()
1304 nxt_debug(task, "http pass: \"%V\"", &str); in nxt_http_pass_var()
1320 nxt_var_query_resolve(task, r->var_query, action, in nxt_http_pass_var()
1353 nxt_http_request_error(task, r, status); in nxt_http_pass_var_ready()
1357 nxt_http_request_action(task, r, action); in nxt_http_pass_var_ready()
1507 ret = nxt_http_action_resolve(task, tmcf, action); in nxt_http_action_create()
1548 action = nxt_http_route_match(task, r, *match); in nxt_http_route_handler()
[all …]
H A Dnxt_http_variables.c10 static nxt_int_t nxt_http_var_dollar(nxt_task_t *task, nxt_str_t *str,
12 static nxt_int_t nxt_http_var_request_time(nxt_task_t *task, nxt_str_t *str,
14 static nxt_int_t nxt_http_var_method(nxt_task_t *task, nxt_str_t *str,
16 static nxt_int_t nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str,
30 static nxt_int_t nxt_http_var_status(nxt_task_t *task, nxt_str_t *str,
34 static nxt_int_t nxt_http_var_referer(nxt_task_t *task, nxt_str_t *str,
40 static nxt_int_t nxt_http_var_header(nxt_task_t *task, nxt_str_t *str,
42 static nxt_int_t nxt_http_var_cookie(nxt_task_t *task, nxt_str_t *str,
129 now = nxt_thread_monotonic_time(task->thread); in nxt_http_var_request_time()
215 nxt_http_var_time_local(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_time_local() argument
[all …]
H A Dnxt_openssl.c57 static void nxt_openssl_library_free(nxt_task_t *task);
133 nxt_openssl_library_init(nxt_task_t *task) in nxt_openssl_library_init() argument
171 nxt_log(task, NXT_LOG_INFO, "%s, %xl", in nxt_openssl_library_init()
194 nxt_openssl_log_error(task, NXT_LOG_ALERT, in nxt_openssl_library_init()
208 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free() argument
268 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free() argument
795 nxt_debug(c->socket.task,
1225 nxt_debug(task, "openssl conn free");
1271 nxt_thread_time_debug_update(task->thread);
1537 nxt_openssl_conn_free(task, c);
[all …]
H A Dnxt_controller.c174 rt = task->thread->runtime; in nxt_controller_prefork()
267 nxt_file_close(task, &file); in nxt_controller_file_read()
430 rt = task->thread->runtime; in nxt_controller_send_current_conf()
449 rt = task->thread->runtime; in nxt_controller_router_ready_handler()
468 rt = task->thread->runtime; in nxt_controller_remove_pid_handler()
576 rt = task->thread->runtime; in nxt_controller_conf_send()
1007 nxt_conn_free(task, c); in nxt_controller_conn_free()
1493 rt = task->thread->runtime; in nxt_controller_check_postpone_request()
1515 rt = task->thread->runtime; in nxt_controller_process_status()
1978 rt = task->thread->runtime; in nxt_controller_process_control()
[all …]
H A Dnxt_h1proto.c496 r->task = c->task; in nxt_h1p_conn_request_init()
497 task = &r->task; in nxt_h1p_conn_request_init()
498 c->socket.task = task; in nxt_h1p_conn_request_init()
499 c->read_timer.task = task; in nxt_h1p_conn_request_init()
1699 task = &c->task; in nxt_h1p_request_close()
1700 c->socket.task = task; in nxt_h1p_request_close()
1701 c->read_timer.task = task; in nxt_h1p_request_close()
1702 c->write_timer.task = task; in nxt_h1p_request_close()
2825 task = &c->task; in nxt_h1p_peer_close()
2826 c->socket.task = task; in nxt_h1p_peer_close()
[all …]
H A Dnxt_application.c174 rt = task->thread->runtime; in nxt_discovery_start()
232 nxt_log(task, NXT_LOG_NOTICE, in nxt_discovery_modules()
604 rt = task->thread->runtime; in nxt_proto_start_process_handler()
676 nxt_proto_quit_children(task); in nxt_proto_quit_handler()
681 nxt_process_quit(task, 0); in nxt_proto_quit_handler()
753 nxt_proto_quit_children(task); in nxt_proto_sigterm_handler()
758 nxt_process_quit(task, 0); in nxt_proto_sigterm_handler()
773 rt = task->thread->runtime; in nxt_proto_sigchld_handler()
1064 rt = task->thread->runtime; in nxt_unit_default_init()
1151 rt = task->thread->runtime; in nxt_proto_process_add()
[all …]
H A Dnxt_router.c3183 job->work.task = &job->task; in nxt_router_engine_joints_create()
3229 job->task = tmcf->engine->task; in nxt_router_engine_quit()
3231 job->work.task = &job->task; in nxt_router_engine_quit()
3261 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3312 link->work.task = task; in nxt_router_thread_create()
3413 task = &engine->task; in nxt_router_thread_start()
3425 thread->task = &engine->task; in nxt_router_thread_start()
3463 work->task = link->work.task; in nxt_router_thread_start()
3659 task = &task->thread->engine->task; in nxt_router_listen_socket_close()
4960 r->timer.task = &engine->task; in nxt_router_process_http_request()
[all …]
H A Dnxt_port.c197 nxt_runtime_quit(task, 0); in nxt_port_quit_handler()
235 b = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_port_send_port()
266 rt = task->thread->runtime; in nxt_port_new_port_handler()
301 port->socket.task = task; in nxt_port_new_port_handler()
316 rt = task->thread->runtime; in nxt_port_process_ready_handler()
350 rt = task->thread->runtime; in nxt_port_mmap_handler()
415 rt = task->thread->runtime; in nxt_port_change_log_file_handler()
468 rt = task->thread->runtime; in nxt_port_remove_notify_others()
485 buf = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_port_remove_notify_others()
567 handler(task, port, data); in nxt_port_post_handler()
[all …]
H A Dnxt_capability.c31 static nxt_int_t nxt_capability_specific_set(nxt_task_t *task,
36 nxt_capability_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_set() argument
46 return nxt_capability_specific_set(task, cap); in nxt_capability_set()
66 nxt_capability_specific_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_specific_set() argument
91 nxt_alert(task, "failed to get process capabilities: %E", nxt_errno); in nxt_capability_specific_set()
114 nxt_capability_specific_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_specific_set() argument
H A Dnxt_fs_mount.h44 nxt_int_t nxt_fs_mount(nxt_task_t *task, nxt_fs_mount_t *mnt);
H A Dnxt_fs_mount.c16 nxt_fs_mount(nxt_task_t *task, nxt_fs_mount_t *mnt) in nxt_fs_mount() argument
27 nxt_log(task, NXT_LOG_WARN, in nxt_fs_mount()
69 nxt_alert(task, "mount(\"%s\", \"%s\", \"%s\", %ul, \"%s\") %E", in nxt_fs_mount()
81 nxt_fs_mount(nxt_task_t *task, nxt_fs_mount_t *mnt) in nxt_fs_mount() argument
92 nxt_alert(task, "nmount(2) doesn't support \"nodev\" option"); in nxt_fs_mount()
195 nxt_alert(task, "nmount(%p, %d, 0) %s", iov, iovlen, errmsg); in nxt_fs_mount()
H A Dnxt_main.h19 typedef void (*nxt_port_handler_t)(nxt_task_t *task, nxt_port_recv_msg_t *msg);
29 typedef void (*nxt_work_handler_t)(nxt_task_t *task, void *obj, void *data);
H A Dnxt_http.h167 nxt_task_t task; member
264 void (*close)(nxt_task_t *task, nxt_http_proto_t proto,
311 nxt_int_t nxt_http_init(nxt_task_t *task);
312 nxt_int_t nxt_h1p_init(nxt_task_t *task);
313 nxt_int_t nxt_http_response_hash_init(nxt_task_t *task);
316 nxt_http_request_t *nxt_http_request_create(nxt_task_t *task);
348 nxt_http_routes_t *nxt_http_routes_create(nxt_task_t *task,
350 nxt_http_action_t *nxt_http_action_create(nxt_task_t *task,
352 nxt_int_t nxt_http_routes_resolve(nxt_task_t *task,
359 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
[all …]
H A Dnxt_http_request.c13 static nxt_int_t nxt_http_request_forward(nxt_task_t *task,
66 nxt_http_init(nxt_task_t *task) in nxt_http_init() argument
70 ret = nxt_h1p_init(task); in nxt_http_init()
76 return nxt_http_response_hash_init(task); in nxt_http_init()
244 nxt_http_request_create(nxt_task_t *task) in nxt_http_request_create() argument
283 task->thread->engine->requests_cnt++; in nxt_http_request_create()
330 nxt_http_request_read_body(task, r); in nxt_http_request_start()
548 nxt_http_request_action(task, r, action); in nxt_http_request_ready()
580 nxt_debug(task, "http application handler"); in nxt_http_application_handler()
586 nxt_http_request_proto_info(task, r); in nxt_http_application_handler()
[all …]
/unit/src/python/
H A Dnxt_python.c25 static nxt_int_t nxt_python_start(nxt_task_t *task,
27 static nxt_int_t nxt_python_set_target(nxt_task_t *task,
68 nxt_python_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_python_start() argument
103 nxt_alert(task, "Failed to allocate memory"); in nxt_python_start()
123 nxt_alert(task, "Failed to allocate memory"); in nxt_python_start()
140 nxt_alert(task, "Failed to allocate memory"); in nxt_python_start()
201 nxt_alert(task, "Could not allocate targets"); in nxt_python_start()
232 nxt_unit_default_init(task, &python_init, data->app); in nxt_python_start()
317 nxt_python_set_target(nxt_task_t *task, nxt_python_target_t *target, in nxt_python_set_target() argument
392 nxt_python_set_path(nxt_task_t *task, nxt_conf_value_t *value) in nxt_python_set_path() argument
[all …]
H A Dnxt_python_asgi.c415 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local
523 task = PyObject_CallFunctionObjArgs(ctx_data->loop_create_task, res, NULL); in nxt_py_asgi_request_handler()
524 if (nxt_slow_path(task == NULL)) { in nxt_py_asgi_request_handler()
536 res = PyObject_CallMethodObjArgs(task, nxt_py_add_done_callback_str, done, in nxt_py_asgi_request_handler()
549 Py_DECREF(task); in nxt_py_asgi_request_handler()
/unit/src/test/
H A Dnxt_tests.c28 nxt_task_t task; in main() local
36 task.log = &nxt_main_log; in main()
39 thr->task = &task; in main()
H A Dnxt_utf8_file_name_test.c47 nxt_task_t task; in nxt_utf8_file_name_test() local
76 task.thread = thr; in nxt_utf8_file_name_test()
77 task.log = thr->log; in nxt_utf8_file_name_test()
112 ret = nxt_file_open(&task, &uc_file, NXT_FILE_WRONLY, NXT_FILE_TRUNCATE, in nxt_utf8_file_name_test()
122 nxt_file_close(&task, &uc_file); in nxt_utf8_file_name_test()
124 ret = nxt_file_open(&task, &lc_file, NXT_FILE_RDONLY, NXT_FILE_OPEN, in nxt_utf8_file_name_test()
130 nxt_file_close(&task, &lc_file); in nxt_utf8_file_name_test()
/unit/src/perl/
H A Dnxt_perl_psgi.c91 static nxt_int_t nxt_perl_psgi_start(nxt_task_t *task,
1129 nxt_perl_psgi_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_perl_psgi_start() argument
1163 nxt_unit_default_init(task, &perl_init, common_conf); in nxt_perl_psgi_start()

123456