Home
last modified time | relevance | path

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

12

/unit/src/
H A Dnxt_process.c34 nxt_process_t *process);
40 nxt_process_t *process);
42 nxt_process_t *process);
112 process->use_count = 1; in nxt_process_new()
116 return process; in nxt_process_new()
352 process->pid = pid; in nxt_process_create()
540 process = data; in nxt_process_whoami_ok()
633 process = data; in nxt_process_created_ok()
673 process = data; in nxt_process_created_error()
704 process->user_cred = nxt_mp_zalloc(process->mem_pool, in nxt_process_creds_set()
[all …]
H A Dnxt_process.h65 nxt_process_t *process);
129 nxt_process_t *process, nxt_mp_t *mp);
131 nxt_process_t *process, nxt_mp_t *mp);
133 nxt_process_t *process);
167 (nxt_pointer_to(process, sizeof(nxt_process_t)))
179 nxt_queue_each(port, &process->ports, nxt_port_t, link)
185 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
187 nxt_int_t nxt_process_start(nxt_task_t *task, nxt_process_t *process);
188 nxt_process_type_t nxt_process_type(nxt_process_t *process);
190 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
[all …]
H A Dnxt_isolation.c32 nxt_process_t *process);
74 app_conf = process->data.app; in nxt_isolation_main_prefork()
156 nxt_process_t *process) in nxt_isolation_set() argument
204 nxt_process_t *process) in nxt_isolation_set_namespaces() argument
229 nxt_process_t *process) in nxt_isolation_set_creds() argument
327 creds = process->user_cred; in nxt_isolation_vldt_creds()
440 nxt_process_t *process) in nxt_isolation_set_rootfs() argument
462 process->isolation.rootfs = nxt_mp_alloc(process->mem_pool, in nxt_isolation_set_rootfs()
480 nxt_process_t *process) in nxt_isolation_set_automount() argument
565 mp = process->mem_pool; in nxt_isolation_set_lang_mounts()
[all …]
H A Dnxt_application.c615 process->name = nxt_mp_alloc(process->mem_pool, nxt_app_conf->name.length in nxt_proto_start_process_handler()
681 nxt_process_t *process; in nxt_proto_quit_children() local
697 nxt_process_t *process; in nxt_proto_process_created_handler() local
716 process->pid = pid; in nxt_proto_process_created_handler()
756 nxt_process_t *process; in nxt_proto_sigchld_handler() local
1073 process = data; in nxt_proto_lvlhsh_isolated_pid_test()
1113 lhq.value = process; in nxt_proto_process_add()
1159 process = NULL; in nxt_proto_process_remove()
1163 return process; in nxt_proto_process_remove()
1181 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
1428 nxt_process_t *process; in nxt_runtime_lvlhsh_pid_test() local
1430 process = data; in nxt_runtime_lvlhsh_pid_test()
1465 process = NULL; in nxt_runtime_process_find()
1480 return process; in nxt_runtime_process_find()
1502 return process; in nxt_runtime_process_get()
1513 process->pid = pid; in nxt_runtime_process_get()
1516 lhq.value = process; in nxt_runtime_process_get()
1540 return process; in nxt_runtime_process_get()
1558 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.c395 process = nxt_process_new(rt); in nxt_main_start_process_handler()
435 process->name = nxt_mp_alloc(process->mem_pool, app_conf->name.length in nxt_main_start_process_handler()
442 p = (u_char *) process->name; in nxt_main_start_process_handler()
511 process->data.app = app_conf; in nxt_main_start_process_handler()
555 nxt_process_t *process; in nxt_main_process_created_handler() local
566 process = port->process; in nxt_main_process_created_handler()
568 nxt_assert(process != NULL); in nxt_main_process_created_handler()
701 nxt_process_t *process; in nxt_main_process_port_create() local
709 process = port->process; in nxt_main_process_port_create()
941 if (process != NULL) { in nxt_main_process_sigchld_handler()
[all …]
H A Dnxt_runtime.h98 void nxt_runtime_process_add(nxt_task_t *task, nxt_process_t *process);
99 void nxt_runtime_process_remove(nxt_runtime_t *rt, nxt_process_t *process);
106 void nxt_runtime_process_release(nxt_runtime_t *rt, nxt_process_t *process);
143 #define nxt_runtime_process_each(rt, process) \ argument
148 for (process = nxt_runtime_process_first(rt, &_lhe); \
149 process != NULL; \
150 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()
989 if (nxt_slow_path(process == NULL || nxt_queue_is_empty(&process->ports))) in nxt_process_broadcast_shm_ack()
994 port = nxt_process_port_first(process); in nxt_process_broadcast_shm_ack()
1005 nxt_process_t *process; in nxt_port_broadcast_shm_ack() local
[all …]
H A Dnxt_port_memory.h51 nxt_port_incoming_port_mmap(nxt_task_t *task, nxt_process_t *process,
74 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.c1547 port_impl->process = process; in nxt_unit_request_check_response_port()
4409 process = data; in nxt_unit_lvlhsh_pid_test()
4454 return process; in nxt_unit_process_get()
4464 process->pid = pid; in nxt_unit_process_get()
4465 process->use_count = 2; in nxt_unit_process_get()
4467 process->lib = lib; in nxt_unit_process_get()
4472 lhq.value = process; in nxt_unit_process_get()
4483 process = NULL; in nxt_unit_process_get()
4487 return process; in nxt_unit_process_get()
5561 new_port->process = process; in nxt_unit_add_port()
[all …]
H A Dnxt_application.h31 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/test/unit/check/
H A Dgo.py5 process = TestApplicationGo.prepare_env('empty')
7 if process != None and process.returncode == 0:
/unit/
H A DCHANGES7 *) Bugfix: a prototype process could crash on an application process
10 *) Bugfix: the router process crashed on reconfiguration if "access_log"
60 *) Feature: process and thread lifecycle hooks in Ruby.
77 when an app process stopped or crashed.
79 *) Bugfix: the controller or router process could crash if the
109 *) Bugfix: the router process could crash while closing a TLS
143 *) Bugfix: the controller process could crash while requesting
189 *) Bugfix: the router process could crash while removing or
319 *) Bugfix: the router process could crash at exit.
698 application process.
[all …]
/unit/test/unit/applications/lang/
H A Dgo.py65 process = subprocess.run(args, env=env, cwd=temp_dir)
73 return process
/unit/test/
H A Dconftest.py669 process = Process(target=target, args=args)
670 process.start()
672 _processes.append(process)
680 for process in _processes:
681 if process.is_alive():
682 process.terminate()
683 process.join(timeout=15)
685 if process.is_alive():
H A Dtest_respawn.py32 def wait_for_process(self, process, unit_pid): argument
34 found = self.pid_by_name(process, unit_pid)
/unit/auto/
H A Dsummary31 process isolation: ......... $NXT_ISOLATION
/unit/src/nodejs/unit-http/
H A Dhttp_server.js293 process.nextTick(callback);
307 process.nextTick(() => {
511 process.nextTick(o.callback);
526 process.nextTick(() => {
/unit/src/java/
H A DREADME.JSR-3404 development process. This is an intermediate build made available for

12