Lines Matching refs:task

38 static nxt_int_t nxt_main_process_port_create(nxt_task_t *task,
40 static void nxt_main_process_title(nxt_task_t *task);
41 static void nxt_main_process_sigterm_handler(nxt_task_t *task, void *obj,
43 static void nxt_main_process_sigquit_handler(nxt_task_t *task, void *obj,
45 static void nxt_main_process_sigusr1_handler(nxt_task_t *task, void *obj,
47 static void nxt_main_process_sigchld_handler(nxt_task_t *task, void *obj,
49 static void nxt_main_process_signal_handler(nxt_task_t *task, void *obj,
51 static void nxt_main_process_cleanup(nxt_task_t *task, nxt_process_t *process);
52 static void nxt_main_port_socket_handler(nxt_task_t *task,
54 static void nxt_main_port_socket_unlink_handler(nxt_task_t *task,
58 static void nxt_main_port_modules_handler(nxt_task_t *task,
61 static void nxt_main_process_whoami_handler(nxt_task_t *task,
63 static void nxt_main_port_conf_store_handler(nxt_task_t *task,
65 static nxt_int_t nxt_main_file_store(nxt_task_t *task, const char *tmp_name,
67 static void nxt_main_port_access_log_handler(nxt_task_t *task,
87 nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task, in nxt_main_process_start() argument
92 if (nxt_main_process_port_create(task, rt) != NXT_OK) { in nxt_main_process_start()
96 nxt_main_process_title(task); in nxt_main_process_start()
103 return nxt_process_init_start(task, nxt_discovery_process); in nxt_main_process_start()
407 nxt_main_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_data_handler() argument
409 nxt_debug(task, "main data: %*s", in nxt_main_data_handler()
415 nxt_main_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_new_port_handler() argument
420 nxt_port_new_port_handler(task, msg); in nxt_main_new_port_handler()
441 nxt_main_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_start_process_handler() argument
455 rt = task->thread->runtime; in nxt_main_start_process_handler()
459 nxt_alert(task, "router port not found"); in nxt_main_start_process_handler()
464 nxt_alert(task, "process %PI cannot start processes", in nxt_main_start_process_handler()
477 nxt_process_use(task, process, -1); in nxt_main_start_process_handler()
492 nxt_debug(task, "main start prototype: %*s", b->mem.free - b->mem.pos, in nxt_main_start_process_handler()
530 nxt_alert(task, "router app configuration parsing error"); in nxt_main_start_process_handler()
535 rt = task->thread->runtime; in nxt_main_start_process_handler()
544 nxt_alert(task, "failed to map common app conf received from router"); in nxt_main_start_process_handler()
559 nxt_alert(task, "invalid app type %d received from router", (int) idx); in nxt_main_start_process_handler()
567 nxt_alert(task, "failed to map app conf received from router"); in nxt_main_start_process_handler()
578 nxt_alert(task, "failed to map app limits received from router"); in nxt_main_start_process_handler()
588 ret = nxt_process_start(task, process); in nxt_main_start_process_handler()
606 nxt_process_use(task, process, -1); in nxt_main_start_process_handler()
612 nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, in nxt_main_start_process_handler()
627 nxt_main_process_created_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_process_created_handler() argument
633 rt = task->thread->runtime; in nxt_main_process_created_handler()
648 if (nxt_slow_path(nxt_clone_credential_map(task, process->pid, in nxt_main_process_created_handler()
653 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, in nxt_main_process_created_handler()
663 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_READY_LAST, in nxt_main_process_created_handler()
695 nxt_main_process_whoami_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_process_whoami_handler() argument
708 nxt_alert(task, "whoami: buffer is NULL or unexpected size"); in nxt_main_process_whoami_handler()
714 rt = task->thread->runtime; in nxt_main_process_whoami_handler()
718 nxt_alert(task, "whoami: parent process %PI not found", ppid); in nxt_main_process_whoami_handler()
724 nxt_debug(task, "whoami: from %PI, parent %PI, fd %d", pid, ppid, in nxt_main_process_whoami_handler()
728 port = nxt_runtime_process_port_create(task, rt, pid, 0, in nxt_main_process_whoami_handler()
734 nxt_fd_nonblocking(task, msg->fd[0]); in nxt_main_process_whoami_handler()
742 port->socket.task = task; in nxt_main_process_whoami_handler()
744 nxt_port_write_enable(task, port); in nxt_main_process_whoami_handler()
757 buf = nxt_buf_mem_alloc(task->thread->engine->mem_pool, in nxt_main_process_whoami_handler()
765 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_READY_LAST, -1, in nxt_main_process_whoami_handler()
777 nxt_main_process_port_create(nxt_task_t *task, nxt_runtime_t *rt) in nxt_main_process_port_create() argument
783 port = nxt_runtime_process_port_create(task, rt, nxt_pid, 0, in nxt_main_process_port_create()
791 ret = nxt_port_socket_init(task, port, 0); in nxt_main_process_port_create()
793 nxt_port_use(task, port, -1); in nxt_main_process_port_create()
801 nxt_port_enable(task, port, &nxt_main_process_port_handlers); in nxt_main_process_port_create()
810 nxt_main_process_title(nxt_task_t *task) in nxt_main_process_title() argument
831 nxt_process_title(task, "%s", title); in nxt_main_process_title()
836 nxt_main_process_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_sigterm_handler() argument
838 nxt_debug(task, "sigterm handler signo:%d (%s)", in nxt_main_process_sigterm_handler()
845 nxt_runtime_quit(task, 0); in nxt_main_process_sigterm_handler()
850 nxt_main_process_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_sigquit_handler() argument
852 nxt_debug(task, "sigquit handler signo:%d (%s)", in nxt_main_process_sigquit_handler()
859 nxt_runtime_quit(task, 0); in nxt_main_process_sigquit_handler()
864 nxt_main_process_sigusr1_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_sigusr1_handler() argument
874 nxt_log(task, NXT_LOG_NOTICE, "signal %d (%s) received, %s", in nxt_main_process_sigusr1_handler()
877 rt = task->thread->runtime; in nxt_main_process_sigusr1_handler()
882 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_ACCESS_LOG, in nxt_main_process_sigusr1_handler()
908 ret = nxt_file_open(task, new_file, O_WRONLY | O_APPEND, O_CREAT, in nxt_main_process_sigusr1_handler()
926 nxt_port_change_log_file(task, rt, n, new_file[n].fd); in nxt_main_process_sigusr1_handler()
950 nxt_file_close(task, new_file); in nxt_main_process_sigusr1_handler()
962 nxt_main_process_sigchld_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_sigchld_handler() argument
974 nxt_debug(task, "sigchld handler signo:%d (%s)", in nxt_main_process_sigchld_handler()
977 rt = task->thread->runtime; in nxt_main_process_sigchld_handler()
993 nxt_alert(task, "waitpid() failed: %E", err); in nxt_main_process_sigchld_handler()
998 nxt_debug(task, "waitpid(): %PI", pid); in nxt_main_process_sigchld_handler()
1006 nxt_alert(task, "process %PI exited on signal %d%s", in nxt_main_process_sigchld_handler()
1010 nxt_alert(task, "process %PI exited on signal %d", in nxt_main_process_sigchld_handler()
1015 nxt_trace(task, "process %PI exited with code %d", in nxt_main_process_sigchld_handler()
1022 nxt_main_process_cleanup(task, process); in nxt_main_process_sigchld_handler()
1038 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_QUIT, in nxt_main_process_sigchld_handler()
1044 nxt_process_close_ports(task, process); in nxt_main_process_sigchld_handler()
1050 nxt_process_close_ports(task, child); in nxt_main_process_sigchld_handler()
1054 nxt_runtime_quit(task, 0); in nxt_main_process_sigchld_handler()
1062 nxt_port_remove_notify_others(task, process); in nxt_main_process_sigchld_handler()
1065 nxt_port_remove_notify_others(task, child); in nxt_main_process_sigchld_handler()
1070 nxt_process_close_ports(task, child); in nxt_main_process_sigchld_handler()
1075 nxt_process_close_ports(task, process); in nxt_main_process_sigchld_handler()
1078 ret = nxt_process_init_start(task, init); in nxt_main_process_sigchld_handler()
1080 nxt_alert(task, "failed to restart %s", init.name); in nxt_main_process_sigchld_handler()
1089 nxt_main_process_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_main_process_signal_handler() argument
1091 nxt_trace(task, "signal signo:%d (%s) received, ignored", in nxt_main_process_signal_handler()
1097 nxt_main_process_cleanup(nxt_task_t *task, nxt_process_t *process) in nxt_main_process_cleanup() argument
1100 process->isolation.cleanup(task, process); in nxt_main_process_cleanup()
1104 process->isolation.cgroup_cleanup(task, process); in nxt_main_process_cleanup()
1110 nxt_main_port_socket_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_socket_handler() argument
1121 port = nxt_runtime_port_find(task->thread->runtime, msg->port_msg.pid, in nxt_main_port_socket_handler()
1128 nxt_alert(task, "process %PI cannot create listener sockets", in nxt_main_port_socket_handler()
1144 nxt_debug(task, "listening socket \"%*s\"", in nxt_main_port_socket_handler()
1150 nxt_debug(task, "socket(\"%*s\"): %d", in nxt_main_port_socket_handler()
1160 nxt_alert(task, "%*s", size, ls.start); in nxt_main_port_socket_handler()
1162 out = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_main_port_socket_handler()
1173 nxt_port_socket_write(task, port, type, ls.socket, msg->port_msg.stream, in nxt_main_port_socket_handler()
1310 nxt_main_port_socket_unlink_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_socket_unlink_handler() argument
1326 rt = task->thread->runtime; in nxt_main_port_socket_unlink_handler()
1408 nxt_main_port_modules_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_modules_handler() argument
1423 rt = task->thread->runtime; in nxt_main_port_modules_handler()
1426 nxt_alert(task, "process %PI cannot send modules", msg->port_msg.pid); in nxt_main_port_modules_handler()
1431 nxt_debug(task, "ignoring discovered modules, exiting"); in nxt_main_port_modules_handler()
1435 port = nxt_runtime_port_find(task->thread->runtime, msg->port_msg.pid, in nxt_main_port_modules_handler()
1439 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, -1, in nxt_main_port_modules_handler()
1460 nxt_debug(task, "application languages: \"%*s\"", in nxt_main_port_modules_handler()
1495 nxt_alert(task, "missing mounts from discovery message."); in nxt_main_port_modules_handler()
1500 nxt_alert(task, "invalid mounts type from discovery message."); in nxt_main_port_modules_handler()
1536 nxt_debug(task, "lang %d %s \"%s\" (%d mounts)", in nxt_main_port_modules_handler()
1547 ret = nxt_process_init_start(task, nxt_controller_process); in nxt_main_port_modules_handler()
1549 ret = nxt_process_init_start(task, nxt_router_process); in nxt_main_port_modules_handler()
1555 nxt_runtime_quit(task, 1); in nxt_main_port_modules_handler()
1584 nxt_main_port_conf_store_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_conf_store_handler() argument
1593 rt = task->thread->runtime; in nxt_main_port_conf_store_handler()
1598 nxt_alert(task, "process %PI cannot store conf", msg->port_msg.pid); in nxt_main_port_conf_store_handler()
1611 nxt_alert(task, "conf_store_handler: invalid shm fd"); in nxt_main_port_conf_store_handler()
1616 nxt_alert(task, "conf_store_handler: unexpected buffer size (%d)", in nxt_main_port_conf_store_handler()
1632 nxt_debug(task, "conf_store_handler(%uz): %*s", size, size, p); in nxt_main_port_conf_store_handler()
1637 ret = nxt_main_file_store(task, rt->ver_tmp, rt->ver, ver, n); in nxt_main_port_conf_store_handler()
1645 ret = nxt_main_file_store(task, rt->conf_tmp, rt->conf, p, size); in nxt_main_port_conf_store_handler()
1653 nxt_alert(task, "failed to store current configuration"); in nxt_main_port_conf_store_handler()
1669 nxt_main_file_store(nxt_task_t *task, const char *tmp_name, const char *name, in nxt_main_file_store() argument
1680 ret = nxt_file_open(task, &file, NXT_FILE_WRONLY, NXT_FILE_TRUNCATE, in nxt_main_file_store()
1688 nxt_file_close(task, &file); in nxt_main_file_store()
1700 nxt_main_port_access_log_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_access_log_handler() argument
1708 nxt_debug(task, "opening access log file"); in nxt_main_port_access_log_handler()
1717 ret = nxt_file_open(task, &file, O_WRONLY | O_APPEND, O_CREAT, in nxt_main_port_access_log_handler()
1723 port = nxt_runtime_port_find(task->thread->runtime, msg->port_msg.pid, in nxt_main_port_access_log_handler()
1727 (void) nxt_port_socket_write(task, port, type, file.fd, in nxt_main_port_access_log_handler()