Home
last modified time | relevance | path

Searched refs:task (Results 76 – 100 of 137) sorted by path

123456

/unit/src/
H A Dnxt_main_process.h22 nxt_int_t nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task,
H A Dnxt_mp.c324 work->handler(work->task, work->obj, work->data); in nxt_mp_destroy()
1042 nxt_task_t *task, void *obj, void *data) in nxt_mp_cleanup() argument
1054 work->task = task; in nxt_mp_cleanup()
H A Dnxt_mp.h110 nxt_task_t *task, void *obj, void *data);
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_php_sapi.c372 nxt_php_setup(nxt_task_t *task, nxt_process_t *process, in nxt_php_setup() argument
415 ret = nxt_php_set_ini_path(task, &ini_path, in nxt_php_setup()
431 nxt_php_set_options(task, value, ZEND_INI_SYSTEM); in nxt_php_setup()
434 nxt_php_set_options(task, value, ZEND_INI_USER); in nxt_php_setup()
455 nxt_php_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_php_start() argument
499 ret = nxt_unit_default_init(task, &php_init, conf); in nxt_php_start()
501 nxt_alert(task, "nxt_unit_default_init() failed"); in nxt_php_start()
696 nxt_log(task, NXT_LOG_ERR, in nxt_php_set_options()
705 nxt_php_disable(task, "function", &value, in nxt_php_set_options()
713 nxt_php_disable(task, "class", &value, in nxt_php_set_options()
[all …]
H A Dnxt_poll_engine.c126 nxt_debug(&engine->task, "poll free"); in nxt_poll_free()
369 ev->task, ev, ev->data); in nxt_poll_commit_changes()
467 nxt_debug(&engine->task, "poll delete event: fd:%d", fd); in nxt_poll_set_delete()
518 nxt_debug(&engine->task, "poll() events:%ui timeout:%M", in nxt_poll()
525 nxt_thread_time_update(engine->task.thread); in nxt_poll()
527 nxt_debug(&engine->task, "poll(): %d", nevents); in nxt_poll()
531 nxt_log(&engine->task, level, "poll() failed %E", err); in nxt_poll()
549 nxt_alert(&engine->task, in nxt_poll()
614 ev->task, ev, ev->data); in nxt_poll()
626 ev->task, ev, ev->data); in nxt_poll()
[all …]
H A Dnxt_pollset_engine.c148 nxt_debug(&engine->task, "pollset %d free", ps); in nxt_pollset_free()
388 nxt_debug(&engine->task, "pollset %d changes:%ui", in nxt_pollset_commit_changes()
472 ev->task, ev, ev->data); in nxt_pollset_change_error()
494 nxt_debug(&engine->task, "pollset_query(%d, %d): %d", in nxt_pollset_remove()
510 nxt_debug(&engine->task, "pollset %d remove fd:%d", in nxt_pollset_remove()
562 nxt_debug(&engine->task, "pollset_poll(%d) timeout:%M", in nxt_pollset_poll()
570 nxt_thread_time_update(engine->task.thread); in nxt_pollset_poll()
572 nxt_debug(&engine->task, "pollset_poll(%d): %d", in nxt_pollset_poll()
594 nxt_alert(&engine->task, in nxt_pollset_poll()
606 nxt_alert(ev->task, in nxt_pollset_poll()
[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_port.h328 nxt_int_t nxt_port_socket_init(nxt_task_t *task, nxt_port_t *port,
331 void nxt_port_close(nxt_task_t *task, nxt_port_t *port);
332 void nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port);
334 void nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port);
341 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write() argument
349 void nxt_port_enable(nxt_task_t *task, nxt_port_t *port,
351 nxt_int_t nxt_port_send_port(nxt_task_t *task, nxt_port_t *port,
353 void nxt_port_change_log_file(nxt_task_t *task, nxt_runtime_t *rt,
360 void nxt_port_change_log_file_handler(nxt_task_t *task,
367 nxt_int_t nxt_port_post(nxt_task_t *task, nxt_port_t *port,
[all …]
H A Dnxt_port_memory.c128 if (nxt_buf_ts_handle(task, obj, data)) { in nxt_port_mmap_buf_completion()
181 nxt_process_broadcast_shm_ack(task, process); in nxt_port_mmap_buf_completion()
313 fd = nxt_shm_open(task, PORT_MMAP_SIZE); in nxt_port_new_port_mmap()
368 nxt_shm_open(nxt_task_t *task, size_t size) in nxt_shm_open() argument
404 nxt_debug(task, "shm_open(SHM_ANON): %FD", fd); in nxt_shm_open()
419 nxt_debug(task, "shm_open(%s): %FD", name, fd); in nxt_shm_open()
562 b = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, 0); in nxt_port_mmap_get_buf()
572 mp = task->thread->engine->mem_pool; in nxt_port_mmap_get_buf()
609 nxt_log(task, NXT_LOG_WARN, in nxt_port_mmap_increase_buf()
737 nxt_log_error(NXT_LOG_ERR, task->log, in nxt_port_mmap_write()
[all …]
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_port_rpc.c107 nxt_port_rpc_ex_set_peer(task, port, ex, peer); in nxt_port_rpc_register_handler()
205 nxt_port_rpc_remove_from_peers(task, port, reg); in nxt_port_rpc_ex_set_peer()
344 reg->error_handler(task, msg, reg->data); in nxt_port_rpc_handler()
347 reg->ready_handler(task, msg, reg->data); in nxt_port_rpc_handler()
362 nxt_port_use(task, port, -1); in nxt_port_rpc_handler()
433 reg->error_handler(task, &msg, reg->data); in nxt_port_rpc_remove_peer()
446 nxt_log_error(NXT_LOG_ERR, task->log, in nxt_port_rpc_remove_peer()
454 nxt_port_use(task, port, -1); in nxt_port_rpc_remove_peer()
487 nxt_port_use(task, port, -1); in nxt_port_rpc_cancel()
493 nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port) in nxt_port_rpc_close() argument
[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_socket.c47 port->socket.task = task; in nxt_port_socket_init()
110 nxt_socket_close(task, port->pair[0]); in nxt_port_socket_init()
111 nxt_socket_close(task, port->pair[1]); in nxt_port_socket_init()
134 port->engine = task->thread->engine; in nxt_port_write_enable()
320 nxt_port_use(task, port, 1); in nxt_port_msg_chk_insert()
428 nxt_sendbuf_mem_coalesce(task, &sb); in nxt_port_write_handler()
563 nxt_port_use(task, port, use_delta); in nxt_port_write_handler()
708 port->engine = task->thread->engine; in nxt_port_read_enable()
1218 port->handler(task, fmsg); in nxt_port_read_msg_process()
1271 port->handler(task, msg); in nxt_port_read_msg_process()
[all …]
H A Dnxt_process.c155 rt = task->thread->runtime; in nxt_process_init_start()
280 task->thread->tid = 0; in nxt_process_child_fixup()
288 rt = task->thread->runtime; in nxt_process_child_fixup()
607 rt = task->thread->runtime; in nxt_process_create()
653 thread = task->thread; in nxt_process_setup()
768 rt = task->thread->runtime; in nxt_process_whoami()
861 nxt_process_quit(task, 1); in nxt_process_whoami_error()
942 nxt_process_quit(task, 1); in nxt_process_created_ok()
958 nxt_process_quit(task, 1); in nxt_process_created_error()
1153 task->thread->tid = 0; in nxt_process_daemon()
[all …]
H A Dnxt_process.h56 typedef void (*nxt_isolation_cleanup_t)(nxt_task_t *task,
58 typedef void (*nxt_cgroup_cleanup_t)(nxt_task_t *task,
132 typedef nxt_int_t (*nxt_process_prefork_t)(nxt_task_t *task,
134 typedef nxt_int_t (*nxt_process_postfork_t)(nxt_task_t *task,
136 typedef nxt_int_t (*nxt_process_setup_t)(nxt_task_t *task,
138 typedef nxt_int_t (*nxt_process_start_t)(nxt_task_t *task,
164 NXT_EXPORT nxt_pid_t nxt_process_execute(nxt_task_t *task, char *name,
166 NXT_EXPORT nxt_int_t nxt_process_daemon(nxt_task_t *task);
191 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
193 nxt_int_t nxt_process_start(nxt_task_t *task, nxt_process_t *process);
[all …]
H A Dnxt_process_title.c46 nxt_process_arguments(nxt_task_t *task, char **orig_argv, char ***orig_envp) in nxt_process_arguments() argument
129 nxt_debug(task, "arguments and environment are not contiguous"); in nxt_process_arguments()
190 nxt_process_title(nxt_task_t *task, const char *fmt, ...) in nxt_process_title() argument
244 nxt_debug(task, "setproctitle: \"%s\"", start); in nxt_process_title()
250 nxt_process_arguments(nxt_task_t *task, char **orig_argv, char ***orig_envp) in nxt_process_arguments() argument
H A Dnxt_router.c3355 job->work.task = &job->task; in nxt_router_engine_joints_create()
3401 job->task = tmcf->engine->task; in nxt_router_engine_quit()
3403 job->work.task = &job->task; in nxt_router_engine_quit()
3433 job->work.task = &job->task; in nxt_router_engine_joints_delete()
3484 link->work.task = task; in nxt_router_thread_create()
3585 task = &engine->task; in nxt_router_thread_start()
3597 thread->task = &engine->task; in nxt_router_thread_start()
3635 work->task = link->work.task; in nxt_router_thread_start()
3831 task = &task->thread->engine->task; in nxt_router_listen_socket_close()
5169 r->timer.task = &engine->task; in nxt_router_process_http_request()
[all …]
H A Dnxt_router.h99 nxt_task_t task; member
236 void (*handler)(nxt_task_t *task, nxt_http_request_t *r,
245 void nxt_router_process_http_request(nxt_task_t *task, nxt_http_request_t *r,
247 void nxt_router_app_port_close(nxt_task_t *task, nxt_port_t *port);
250 void nxt_router_listen_event_release(nxt_task_t *task, nxt_listen_event_t *lev,
253 void nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data);
254 void nxt_router_conf_error(nxt_task_t *task, nxt_router_temp_conf_t *tmcf);
255 void nxt_router_conf_release(nxt_task_t *task, nxt_socket_conf_joint_t *joint);
257 nxt_int_t nxt_router_access_log_create(nxt_task_t *task,
262 void nxt_router_access_log_release(nxt_task_t *task,
[all …]
H A Dnxt_router_access_log.c26 static void nxt_router_access_log_writer(nxt_task_t *task,
33 static void nxt_router_access_log_ready(nxt_task_t *task,
35 static void nxt_router_access_log_error(nxt_task_t *task,
95 nxt_alert(task, "access log map error"); in nxt_router_access_log_create()
183 nxt_router_access_log_write_ready(task, r, ctx); in nxt_router_access_log_writer()
195 nxt_tstr_query_resolve(task, r->tstr_query, ctx, in nxt_router_access_log_writer()
246 rt = task->thread->runtime; in nxt_router_access_log_open()
262 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_open()
270 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_open()
300 nxt_router_conf_error(task, tmcf); in nxt_router_access_log_error()
[all …]
H A Dnxt_runtime.c47 nxt_runtime_create(nxt_task_t *task) in nxt_runtime_create() argument
65 task->thread->runtime = rt; in nxt_runtime_create()
299 thread = task->thread; in nxt_runtime_event_engines()
370 nxt_runtime_quit(task, 1); in nxt_runtime_start()
382 thr = task->thread; in nxt_runtime_initial_start()
426 nxt_runtime_quit(task, 1); in nxt_runtime_initial_start()
437 rt = task->thread->runtime; in nxt_runtime_quit()
441 nxt_debug(task, "exiting"); in nxt_runtime_quit()
708 cont(task, 0); in nxt_runtime_thread_pool_destroy()
744 rt = task->thread->runtime; in nxt_runtime_thread_pool_exit()
[all …]
H A Dnxt_runtime.h12 typedef void (*nxt_runtime_cont_t)(nxt_task_t *task, nxt_uint_t status);
94 nxt_int_t nxt_runtime_create(nxt_task_t *task);
95 void nxt_runtime_quit(nxt_task_t *task, nxt_uint_t status);
103 void nxt_runtime_process_add(nxt_task_t *task, nxt_process_t *process);
116 nxt_port_t *nxt_runtime_process_port_create(nxt_task_t *task, nxt_runtime_t *rt,
119 void nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port);
120 void nxt_runtime_stop_app_processes(nxt_task_t *task, nxt_runtime_t *rt);
127 nxt_int_t nxt_runtime_controller_socket(nxt_task_t *task, nxt_runtime_t *rt);
133 nxt_int_t nxt_runtime_listen_sockets_create(nxt_task_t *task,
135 nxt_int_t nxt_runtime_listen_sockets_enable(nxt_task_t *task,
[all …]
H A Dnxt_script.c344 nxt_script_store_load(nxt_task_t *task, nxt_mp_t *mp) in nxt_script_store_load() argument
357 rt = task->thread->runtime; in nxt_script_store_load()
374 nxt_alert(task, "opendir(\"%s\") failed %E", in nxt_script_store_load()
385 nxt_debug(task, "readdir(\"%s\"): \"%s\"", in nxt_script_store_load()
499 rt = task->thread->runtime; in nxt_script_store_get()
513 nxt_port_rpc_cancel(task, recv_port, stream); in nxt_script_store_get()
521 handler(task, NULL, ctx); in nxt_script_store_get()
573 rt = task->thread->runtime; in nxt_script_store_get_handler()
620 rt = task->thread->runtime; in nxt_script_store_delete()
623 (void) nxt_port_socket_write(task, main_port, in nxt_script_store_delete()
[all …]
H A Dnxt_script.h13 nxt_script_t *nxt_script_new(nxt_task_t *task, nxt_str_t *name, u_char *data,
17 void nxt_script_info_init(nxt_task_t *task, nxt_array_t *scripts);
23 nxt_array_t *nxt_script_store_load(nxt_task_t *task, nxt_mp_t *mem_pool);
26 void nxt_script_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp,
28 void nxt_script_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp);
30 void nxt_script_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
31 void nxt_script_store_delete_handler(nxt_task_t *task,
H A Dnxt_select_engine.c89 nxt_debug(&engine->task, "select free"); in nxt_select_free()
134 nxt_debug(ev->task, "select enable read: fd:%d", fd); in nxt_select_enable_read()
138 ev->task, ev, ev->data); in nxt_select_enable_read()
161 nxt_debug(ev->task, "select enable write: fd:%d", fd); in nxt_select_enable_write()
165 ev->task, ev, ev->data); in nxt_select_enable_write()
191 ev->error_handler(task, ev, data); in nxt_select_error_handler()
202 nxt_debug(ev->task, "select disable read: fd:%d", fd); in nxt_select_disable_read()
320 nxt_thread_time_update(engine->task.thread); in nxt_select_poll()
322 nxt_debug(&engine->task, "select(): %d", nevents); in nxt_select_poll()
347 ev->task, ev, ev->data); in nxt_select_poll()
[all …]

123456