/unit/src/ |
H A D | nxt_process.c | 50 nxt_process_t *process); 56 nxt_process_t *process); 58 nxt_process_t *process); 132 return process; in nxt_process_new() 604 process->pid = pid; in nxt_process_create() 626 process->name, process->isolation.cgroup.path, nxt_errno); in nxt_process_create() 820 process = data; in nxt_process_whoami_ok() 913 process = data; in nxt_process_created_ok() 953 process = data; in nxt_process_created_error() 984 process->user_cred = nxt_mp_zalloc(process->mem_pool, in nxt_process_creds_set() [all …]
|
H A D | nxt_process.h | 57 nxt_process_t *process); 59 const nxt_process_t *process); 133 nxt_process_t *process, nxt_mp_t *mp); 135 nxt_process_t *process, nxt_mp_t *mp); 137 nxt_process_t *process); 173 (nxt_pointer_to(process, sizeof(nxt_process_t))) 185 nxt_queue_each(port, &process->ports, nxt_port_t, link) 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); 194 nxt_process_type_t nxt_process_type(nxt_process_t *process); [all …]
|
H A D | nxt_isolation.c | 38 nxt_process_t *process); 166 nxt_process_t *process) in nxt_isolation_set() argument 222 nxt_process_t *process) in nxt_isolation_set_cgroup() argument 241 process->isolation.cgroup.path = nxt_mp_alloc(process->mem_pool, in nxt_isolation_set_cgroup() 258 nxt_process_t *process) in nxt_isolation_set_namespaces() argument 283 nxt_process_t *process) in nxt_isolation_set_creds() argument 494 nxt_process_t *process) in nxt_isolation_set_rootfs() argument 516 process->isolation.rootfs = nxt_mp_alloc(process->mem_pool, in nxt_isolation_set_rootfs() 534 nxt_process_t *process) in nxt_isolation_set_automount() argument 619 mp = process->mem_pool; in nxt_isolation_set_lang_mounts() [all …]
|
H A D | nxt_application.c | 622 process->name = nxt_mp_alloc(process->mem_pool, nxt_app_conf->name.length in nxt_proto_start_process_handler() 723 process->pid = pid; in nxt_proto_process_created_handler() 809 process != NULL ? process->pid : 0, in nxt_proto_sigchld_handler() 823 process != NULL ? process->pid : 0, in nxt_proto_sigchld_handler() 956 process = rt->port_by_type[NXT_PROCESS_PROTOTYPE]->process; in nxt_app_set_logs() 1175 process = data; in nxt_proto_lvlhsh_isolated_pid_test() 1215 lhq.value = process; in nxt_proto_process_add() 1261 process = NULL; in nxt_proto_process_remove() 1265 return process; in nxt_proto_process_remove() 1283 process = NULL; in nxt_proto_process_find() [all …]
|
H A D | nxt_port.c | 135 nxt_assert(port->process != NULL); in nxt_port_release() 207 nxt_process_t *process; in nxt_port_send_new_port() local 214 if (process->pid == new_port->pid || process->pid == nxt_pid) { in nxt_port_send_new_port() 313 nxt_process_t *process; in nxt_port_process_ready_handler() local 348 nxt_process_t *process; in nxt_port_mmap_handler() local 380 nxt_process_t *process; in nxt_port_change_log_file() local 386 if (nxt_pid == process->pid) { in nxt_port_change_log_file() 464 pid = process->pid; in nxt_port_remove_notify_others() 466 ptype = nxt_process_type(process); in nxt_port_remove_notify_others() 522 nxt_process_t *process; in nxt_port_remove_pid() local [all …]
|
H A D | nxt_runtime.c | 525 nxt_process_t *process; in nxt_runtime_stop_all_processes() local 1552 nxt_process_t *process; in nxt_runtime_lvlhsh_pid_test() local 1554 process = data; in nxt_runtime_lvlhsh_pid_test() 1589 process = NULL; in nxt_runtime_process_find() 1604 return process; in nxt_runtime_process_find() 1626 return process; in nxt_runtime_process_get() 1637 process->pid = pid; in nxt_runtime_process_get() 1640 lhq.value = process; in nxt_runtime_process_get() 1664 return process; in nxt_runtime_process_get() 1682 lhq.value = process; in nxt_runtime_process_add() [all …]
|
H A D | nxt_isolation.h | 9 nxt_int_t nxt_isolation_main_prefork(nxt_task_t *task, nxt_process_t *process, 14 nxt_process_t *process); 15 nxt_int_t nxt_isolation_change_root(nxt_task_t *task, nxt_process_t *process);
|
H A D | nxt_main_process.c | 510 process->name = nxt_mp_alloc(process->mem_pool, app_conf->name.length in nxt_main_start_process_handler() 517 p = (u_char *) process->name; in nxt_main_start_process_handler() 586 process->data.app = app_conf; in nxt_main_start_process_handler() 630 nxt_process_t *process; in nxt_main_process_created_handler() local 641 process = port->process; in nxt_main_process_created_handler() 643 nxt_assert(process != NULL); in nxt_main_process_created_handler() 781 nxt_process_t *process; in nxt_main_process_port_create() local 789 process = port->process; in nxt_main_process_port_create() 1021 if (process != NULL) { in nxt_main_process_sigchld_handler() 1100 process->isolation.cleanup(task, process); in nxt_main_process_cleanup() [all …]
|
H A D | nxt_cgroup.c | 18 nxt_cgroup_proc_add(nxt_task_t *task, nxt_process_t *process) in nxt_cgroup_proc_add() argument 26 || nxt_process_type(process) != NXT_PROCESS_PROTOTYPE in nxt_cgroup_proc_add() 27 || process->isolation.cgroup.path == NULL) in nxt_cgroup_proc_add() 32 ret = nxt_mk_cgpath(task, process->isolation.cgroup.path, cgprocs); in nxt_cgroup_proc_add() 56 len = fprintf(fp, "%d\n", process->pid); in nxt_cgroup_proc_add() 68 nxt_cgroup_cleanup(nxt_task_t *task, const nxt_process_t *process) in nxt_cgroup_cleanup() argument 79 ret = nxt_mk_cgpath(task, process->isolation.cgroup.path, cgpath); in nxt_cgroup_cleanup()
|
H A D | nxt_runtime.h | 103 void nxt_runtime_process_add(nxt_task_t *task, nxt_process_t *process); 104 void nxt_runtime_process_remove(nxt_runtime_t *rt, nxt_process_t *process); 111 void nxt_runtime_process_release(nxt_runtime_t *rt, nxt_process_t *process); 151 #define nxt_runtime_process_each(rt, process) \ argument 156 for (process = nxt_runtime_process_first(rt, &_lhe); \ 157 process != NULL; \ 158 process = _nxt) { \
|
H A D | nxt_port_memory.c | 123 nxt_process_t *process; in nxt_port_mmap_buf_completion() local 181 nxt_process_broadcast_shm_ack(task, process); in nxt_port_mmap_buf_completion() 214 fd, process->pid); in nxt_port_incoming_port_mmap() 235 if (nxt_slow_path(hdr->src_pid != process->pid in nxt_port_incoming_port_mmap() 259 nxt_thread_mutex_lock(&process->incoming.mutex); in nxt_port_incoming_port_mmap() 517 nxt_process_t *process; in nxt_port_get_port_incoming_mmap() local 521 if (nxt_slow_path(process == NULL)) { in nxt_port_get_port_incoming_mmap() 858 if (nxt_slow_path(process == NULL || nxt_queue_is_empty(&process->ports))) in nxt_process_broadcast_shm_ack() 863 port = nxt_process_port_first(process); in nxt_process_broadcast_shm_ack() 874 nxt_process_t *process; in nxt_port_broadcast_shm_ack() local [all …]
|
H A D | nxt_cgroup.h | 10 nxt_int_t nxt_cgroup_proc_add(nxt_task_t *task, nxt_process_t *process); 11 void nxt_cgroup_cleanup(nxt_task_t *task, const nxt_process_t *process);
|
H A D | nxt_port_memory.h | 30 nxt_port_incoming_port_mmap(nxt_task_t *task, nxt_process_t *process, 53 void nxt_process_broadcast_shm_ack(nxt_task_t *task, nxt_process_t *process);
|
H A D | nxt_signal.c | 116 if (engine->signals->process == nxt_pid) { in nxt_signal_thread_start() 143 engine->signals->process = nxt_pid; in nxt_signal_thread_start()
|
H A D | nxt_signal.h | 32 nxt_pid_t process; member
|
H A D | nxt_unit.c | 1561 port_impl->process = process; in nxt_unit_request_check_response_port() 4417 process = data; in nxt_unit_lvlhsh_pid_test() 4462 return process; in nxt_unit_process_get() 4472 process->pid = pid; in nxt_unit_process_get() 4473 process->use_count = 2; in nxt_unit_process_get() 4475 process->lib = lib; in nxt_unit_process_get() 4480 lhq.value = process; in nxt_unit_process_get() 4491 process = NULL; in nxt_unit_process_get() 4495 return process; in nxt_unit_process_get() 5568 new_port->process = process; in nxt_unit_add_port() [all …]
|
H A D | nxt_application.h | 33 nxt_process_t *process, nxt_common_app_conf_t *conf);
|
H A D | nxt_java.c | 32 static nxt_int_t nxt_java_setup(nxt_task_t *task, nxt_process_t *process, 78 nxt_java_setup(nxt_task_t *task, nxt_process_t *process, in nxt_java_setup() argument 85 rootfs = (char *) process->isolation.rootfs; in nxt_java_setup() 112 p = nxt_cpymem(path, process->isolation.rootfs, rootfs_len); in nxt_java_setup()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | BackgroundProcessManager.java | 59 public void register(BackgroundProcess process) { in register() argument 68 processes.add(process); in register() 73 public void unregister(BackgroundProcess process) { in unregister() argument 75 processes.remove(process); in unregister() 84 private void process() { in process() method in BackgroundProcessManager 89 for (BackgroundProcess process : currentProcesses) { in process() 91 process.backgroundProcess(); in process() 140 manager.process(); in run()
|
/unit/ |
H A D | CHANGES | 223 *) Bugfix: the Ruby application process could crash on SIGTERM. 225 *) Bugfix: the Ruby application process could crash on SIGINT. 271 *) Bugfix: a prototype process could crash on an application process 324 *) Feature: process and thread lifecycle hooks in Ruby. 341 when an app process stopped or crashed. 343 *) Bugfix: the controller or router process could crash if the 373 *) Bugfix: the router process could crash while closing a TLS 453 *) Bugfix: the router process could crash while removing or 583 *) Bugfix: the router process could crash at exit. 962 application process. [all …]
|
/unit/test/ |
H A D | test_respawn.py | 38 def wait_for_process(process, unit_pid): argument 40 found = pid_by_name(process, unit_pid)
|
H A D | conftest.py | 578 process = Process(target=target, args=args) 579 process.start() 581 _processes.append(process) 589 for process in _processes: 590 if process.is_alive(): 591 process.terminate() 592 process.join(timeout=15) 594 if process.is_alive():
|
/unit/auto/ |
H A D | summary | 34 process isolation: ......... $NXT_ISOLATION
|
/unit/src/nodejs/unit-http/ |
H A D | http_server.js | 309 process.nextTick(callback); 323 process.nextTick(() => { 534 process.nextTick(o.callback); 549 process.nextTick(() => {
|
/unit/src/java/ |
H A D | README.JSR-340 | 4 development process. This is an intermediate build made available for
|