Home
last modified time | relevance | path

Searched refs:process (Results 1 – 25 of 48) sorted by relevance

12

/unit/src/
H A Dnxt_process.c50 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 Dnxt_process.h57 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 Dnxt_isolation.c38 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 Dnxt_application.c622 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()
1172 process = data; in nxt_proto_lvlhsh_isolated_pid_test()
1212 lhq.value = process; in nxt_proto_process_add()
1258 process = NULL; in nxt_proto_process_remove()
1262 return process; in nxt_proto_process_remove()
1280 process = NULL; in nxt_proto_process_find()
[all …]
H A Dnxt_port.c135 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 Dnxt_runtime.c525 nxt_process_t *process; in nxt_runtime_stop_all_processes() local
1497 nxt_process_t *process; in nxt_runtime_lvlhsh_pid_test() local
1499 process = data; in nxt_runtime_lvlhsh_pid_test()
1534 process = NULL; in nxt_runtime_process_find()
1549 return process; in nxt_runtime_process_find()
1571 return process; in nxt_runtime_process_get()
1582 process->pid = pid; in nxt_runtime_process_get()
1585 lhq.value = process; in nxt_runtime_process_get()
1609 return process; in nxt_runtime_process_get()
1627 lhq.value = process; in nxt_runtime_process_add()
[all …]
H A Dnxt_isolation.h9 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 Dnxt_main_process.c495 process->name = nxt_mp_alloc(process->mem_pool, app_conf->name.length in nxt_main_start_process_handler()
502 p = (u_char *) process->name; in nxt_main_start_process_handler()
571 process->data.app = app_conf; in nxt_main_start_process_handler()
615 nxt_process_t *process; in nxt_main_process_created_handler() local
626 process = port->process; in nxt_main_process_created_handler()
628 nxt_assert(process != NULL); in nxt_main_process_created_handler()
766 nxt_process_t *process; in nxt_main_process_port_create() local
774 process = port->process; in nxt_main_process_port_create()
1006 if (process != NULL) { in nxt_main_process_sigchld_handler()
1085 process->isolation.cleanup(task, process); in nxt_main_process_cleanup()
[all …]
H A Dnxt_cgroup.c18 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 Dnxt_runtime.h99 void nxt_runtime_process_add(nxt_task_t *task, nxt_process_t *process);
100 void nxt_runtime_process_remove(nxt_runtime_t *rt, nxt_process_t *process);
107 void nxt_runtime_process_release(nxt_runtime_t *rt, nxt_process_t *process);
147 #define nxt_runtime_process_each(rt, process) \ argument
152 for (process = nxt_runtime_process_first(rt, &_lhe); \
153 process != NULL; \
154 process = _nxt) { \
H A Dnxt_port_memory.c123 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 Dnxt_cgroup.h10 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 Dnxt_port_memory.h30 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 Dnxt_signal.h32 nxt_pid_t process; member
H A Dnxt_signal.c116 if (engine->signals->process == nxt_pid) { in nxt_signal_thread_start()
143 engine->signals->process = nxt_pid; in nxt_signal_thread_start()
H A Dnxt_unit.c1561 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 Dnxt_application.h32 nxt_process_t *process, nxt_common_app_conf_t *conf);
H A Dnxt_java.c32 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 DBackgroundProcessManager.java59 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 DCHANGES8 *) Bugfix: application process could crash while rewriting URLs with
170 *) Bugfix: the Ruby application process could crash on SIGTERM.
172 *) Bugfix: the Ruby application process could crash on SIGINT.
218 *) Bugfix: a prototype process could crash on an application process
271 *) Feature: process and thread lifecycle hooks in Ruby.
288 when an app process stopped or crashed.
320 *) Bugfix: the router process could crash while closing a TLS
400 *) Bugfix: the router process could crash while removing or
530 *) Bugfix: the router process could crash at exit.
909 application process.
[all …]
/unit/test/
H A Dtest_respawn.py37 def wait_for_process(process, unit_pid): argument
39 found = pid_by_name(process, unit_pid)
H A Dconftest.py575 process = Process(target=target, args=args)
576 process.start()
578 _processes.append(process)
586 for process in _processes:
587 if process.is_alive():
588 process.terminate()
589 process.join(timeout=15)
591 if process.is_alive():
/unit/auto/
H A Dsummary34 process isolation: ......... $NXT_ISOLATION
/unit/src/nodejs/unit-http/
H A Dhttp_server.js309 process.nextTick(callback);
323 process.nextTick(() => {
527 process.nextTick(o.callback);
542 process.nextTick(() => {
/unit/src/java/
H A DREADME.JSR-3404 development process. This is an intermediate build made available for

12