/unit/src/ |
H A D | nxt_main_process.h | 22 nxt_int_t nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task,
|
H A D | nxt_mp.c | 324 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 D | nxt_mp.h | 110 nxt_task_t *task, void *obj, void *data);
|
H A D | nxt_openssl.c | 57 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 D | nxt_php_sapi.c | 372 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 D | nxt_poll_engine.c | 126 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 D | nxt_pollset_engine.c | 148 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 D | nxt_port.c | 197 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 D | nxt_port.h | 328 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 D | nxt_port_memory.c | 128 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 D | nxt_port_memory.h | 24 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 D | nxt_port_rpc.c | 107 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 D | nxt_port_rpc.h | 11 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 D | nxt_port_socket.c | 47 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 D | nxt_process.c | 155 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 D | nxt_process.h | 56 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 D | nxt_process_title.c | 46 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 D | nxt_router.c | 3355 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 D | nxt_router.h | 99 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 D | nxt_router_access_log.c | 26 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 D | nxt_runtime.c | 47 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 D | nxt_runtime.h | 12 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 D | nxt_script.c | 344 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 D | nxt_script.h | 13 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 D | nxt_select_engine.c | 89 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 …]
|