Home
last modified time | relevance | path

Searched refs:rt (Results 1 – 20 of 20) sorted by relevance

/unit/src/
H A Dnxt_runtime.c17 nxt_runtime_t *rt);
19 nxt_runtime_t *rt);
28 nxt_runtime_t *rt);
34 nxt_runtime_t *rt);
344 rt = obj; in nxt_runtime_start()
364 nxt_runtime_thread_pool_destroy(task, rt, rt->start); in nxt_runtime_start()
385 if (rt->inherited_sockets == NULL && rt->daemon) { in nxt_runtime_initial_start()
550 rt = obj; in nxt_runtime_exit()
618 if (rt->port_by_type[rt->type] != NULL) { in nxt_runtime_exit()
619 nxt_port_use(task, rt->port_by_type[rt->type], -1); in nxt_runtime_exit()
[all …]
H A Dnxt_runtime.h93 void nxt_runtime_event_engine_free(nxt_runtime_t *rt);
100 void nxt_runtime_process_remove(nxt_runtime_t *rt, nxt_process_t *process);
102 nxt_process_t *nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid);
104 nxt_process_t *nxt_runtime_process_first(nxt_runtime_t *rt,
107 void nxt_runtime_process_release(nxt_runtime_t *rt, nxt_process_t *process);
110 nxt_lvlhsh_each(&rt->processes, lhe)
116 void nxt_runtime_stop_app_processes(nxt_task_t *task, nxt_runtime_t *rt);
127 nxt_listen_socket_t *nxt_runtime_listen_socket_add(nxt_runtime_t *rt,
130 nxt_runtime_t *rt);
132 nxt_runtime_t *rt);
[all …]
H A Dnxt_script.c353 nxt_runtime_t *rt; in nxt_script_store_load() local
357 rt = task->thread->runtime; in nxt_script_store_load()
416 p = nxt_cpymem(buf, rt->scripts.start, rt->scripts.length); in nxt_script_store_load()
486 nxt_runtime_t *rt; in nxt_script_store_get() local
499 rt = task->thread->runtime; in nxt_script_store_get()
501 recv_port = rt->port_by_type[rt->type]; in nxt_script_store_get()
548 nxt_runtime_t *rt; in nxt_script_store_get_handler() local
588 p = nxt_cpymem(file.name, rt->scripts.start, rt->scripts.length); in nxt_script_store_get_handler()
612 nxt_runtime_t *rt; in nxt_script_store_delete() local
635 nxt_runtime_t *rt; in nxt_script_store_delete_handler() local
[all …]
H A Dnxt_port.c266 rt = task->thread->runtime; in nxt_port_new_port_handler()
314 nxt_runtime_t *rt; in nxt_port_process_ready_handler() local
316 rt = task->thread->runtime; in nxt_port_process_ready_handler()
347 nxt_runtime_t *rt; in nxt_port_mmap_handler() local
350 rt = task->thread->runtime; in nxt_port_mmap_handler()
413 nxt_runtime_t *rt; in nxt_port_change_log_file_handler() local
415 rt = task->thread->runtime; in nxt_port_change_log_file_handler()
460 nxt_runtime_t *rt; in nxt_port_remove_notify_others() local
468 rt = task->thread->runtime; in nxt_port_remove_notify_others()
521 nxt_runtime_t *rt; in nxt_port_remove_pid() local
[all …]
H A Dnxt_process.c151 nxt_runtime_t *rt; in nxt_process_init_start() local
162 process->parent_port = rt->port_by_type[rt->type]; in nxt_process_init_start()
266 nxt_runtime_t *rt; in nxt_process_child_fixup() local
545 nxt_runtime_t *rt; in nxt_process_create() local
662 rt->type = init->type; in nxt_process_setup()
669 interface = nxt_service_get(rt->services, "engine", rt->engine); in nxt_process_setup()
678 ret = nxt_runtime_thread_pool_create(thread, rt, rt->auxiliary_threads, in nxt_process_setup()
695 if (rt->is_pid_isolated in nxt_process_setup()
766 nxt_runtime_t *rt; in nxt_process_whoami() local
818 nxt_runtime_t *rt; in nxt_process_whoami_ok() local
[all …]
H A Dnxt_main_process.c39 nxt_runtime_t *rt);
88 nxt_runtime_t *rt) in nxt_main_process_start() argument
90 rt->type = NXT_PROCESS_MAIN; in nxt_main_process_start()
616 nxt_runtime_t *rt; in nxt_main_process_created_handler() local
685 nxt_runtime_t *rt; in nxt_main_process_whoami_handler() local
857 nxt_runtime_t *rt; in nxt_main_process_sigusr1_handler() local
955 nxt_runtime_t *rt; in nxt_main_process_sigchld_handler() local
1525 qsort(rt->languages->elts, rt->languages->nelts, in nxt_main_port_modules_handler()
1575 nxt_runtime_t *rt; in nxt_main_port_conf_store_handler() local
1622 ret = nxt_main_file_store(task, rt->ver_tmp, rt->ver, ver, n); in nxt_main_port_conf_store_handler()
[all …]
H A Dnxt_cert.c823 nxt_runtime_t *rt; in nxt_cert_store_load() local
827 rt = task->thread->runtime; in nxt_cert_store_load()
885 p = nxt_cpymem(buf, rt->certs.start, rt->certs.length); in nxt_cert_store_load()
959 nxt_runtime_t *rt;
1069 nxt_runtime_t *rt; in nxt_cert_store_get() local
1084 recv_port = rt->port_by_type[rt->type]; in nxt_cert_store_get()
1131 nxt_runtime_t *rt; in nxt_cert_store_get_handler() local
1172 p = nxt_cpymem(file.name, rt->certs.start, rt->certs.length); in nxt_cert_store_get_handler()
1196 nxt_runtime_t *rt; in nxt_cert_store_delete() local
1219 nxt_runtime_t *rt; in nxt_cert_store_delete_handler() local
[all …]
H A Dnxt_lib.c137 nxt_thread_spin_lock(&rt->lock); in nxt_lib_stop()
139 tp = rt->thread_pools; in nxt_lib_stop()
140 rt->thread_pools = (tp != NULL) ? tp->next : NULL; in nxt_lib_stop()
142 nxt_thread_spin_unlock(&rt->lock); in nxt_lib_stop()
H A Dnxt_application.c170 nxt_runtime_t *rt; in nxt_discovery_start() local
174 rt = task->thread->runtime; in nxt_discovery_start()
600 nxt_runtime_t *rt; in nxt_proto_start_process_handler() local
771 nxt_runtime_t *rt; in nxt_proto_sigchld_handler() local
952 if (!rt->daemon) { in nxt_app_set_logs()
1057 n = rt->languages->nelts; in nxt_app_lang_module()
1116 nxt_runtime_t *rt; in nxt_unit_default_init() local
1204 nxt_runtime_t *rt; in nxt_proto_process_add() local
1213 lhq.pool = rt->mem_pool; in nxt_proto_process_add()
1234 nxt_runtime_t *rt; in nxt_proto_process_remove() local
[all …]
H A Dnxt_clone.c197 nxt_runtime_t *rt; in nxt_clone_credential_map() local
199 rt = task->thread->runtime; in nxt_clone_credential_map()
201 if (rt->capabilities.setid) { in nxt_clone_credential_map()
248 nxt_runtime_t *rt; in nxt_clone_vldt_credential_uidmap() local
255 rt = task->thread->runtime; in nxt_clone_vldt_credential_uidmap()
257 if (!rt->capabilities.setid) { in nxt_clone_vldt_credential_uidmap()
302 nxt_runtime_t *rt; in nxt_clone_vldt_credential_gidmap() local
305 rt = task->thread->runtime; in nxt_clone_vldt_credential_gidmap()
307 if (!rt->capabilities.setid) { in nxt_clone_vldt_credential_gidmap()
H A Dnxt_external.c71 nxt_runtime_t *rt; in nxt_external_start() local
76 rt = task->thread->runtime; in nxt_external_start()
79 proto_port = rt->port_by_type[NXT_PROCESS_PROTOTYPE]; in nxt_external_start()
80 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_external_start()
81 my_port = nxt_runtime_port_find(rt, nxt_pid, 0); in nxt_external_start()
H A Dnxt_controller.c230 rt); in nxt_controller_prefork()
297 nxt_runtime_t *rt; in nxt_controller_cert_cleanup() local
300 rt = data; in nxt_controller_cert_cleanup()
471 nxt_runtime_t *rt; in nxt_controller_router_ready_handler() local
490 nxt_runtime_t *rt; in nxt_controller_remove_pid_handler() local
540 nxt_runtime_t *rt; in nxt_controller_conf_init_handler() local
599 nxt_runtime_t *rt; in nxt_controller_conf_send() local
1550 nxt_runtime_t *rt; in nxt_controller_check_postpone_request() local
2221 nxt_runtime_t *rt; in nxt_controller_script_cleanup() local
2224 rt = data; in nxt_controller_script_cleanup()
[all …]
H A Dnxt_router_access_log.c206 nxt_runtime_t *rt; in nxt_router_access_log_open() local
221 rt = task->thread->runtime; in nxt_router_access_log_open()
222 main_port = rt->port_by_type[NXT_PROCESS_MAIN]; in nxt_router_access_log_open()
223 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_access_log_open()
336 nxt_runtime_t *rt; in nxt_router_access_log_reopen_handler() local
369 rt = task->thread->runtime; in nxt_router_access_log_reopen_handler()
370 main_port = rt->port_by_type[NXT_PROCESS_MAIN]; in nxt_router_access_log_reopen_handler()
371 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_access_log_reopen_handler()
H A Dnxt_isolation.c76 nxt_runtime_t *rt; in nxt_isolation_main_prefork() local
79 rt = task->thread->runtime; in nxt_isolation_main_prefork()
81 cap_setid = rt->capabilities.setid; in nxt_isolation_main_prefork()
120 nxt_strlen(rt->group))) in nxt_isolation_main_prefork()
577 nxt_runtime_t *rt; in nxt_isolation_set_mounts() local
580 rt = task->thread->runtime; in nxt_isolation_set_mounts()
581 cap_chroot = rt->capabilities.chroot; in nxt_isolation_set_mounts()
582 lang = nxt_app_lang_module(rt, app_type); in nxt_isolation_set_mounts()
723 nxt_runtime_t *rt; in nxt_isolation_unmount_all() local
727 rt = task->thread->runtime; in nxt_isolation_unmount_all()
[all …]
H A Dnxt_credential.c308 nxt_runtime_t *rt; in nxt_credential_setgids() local
313 rt = task->thread->runtime; in nxt_credential_setgids()
329 if (!rt->capabilities.setid) { in nxt_credential_setgids()
H A Dnxt_router.c340 nxt_runtime_t *rt; in nxt_router_start() local
342 rt = task->thread->runtime; in nxt_router_start()
347 rt->tls = nxt_service_get(rt->services, "SSL/TLS", "OpenSSL"); in nxt_router_start()
402 nxt_runtime_t *rt; in nxt_router_start_app_process_handler() local
510 nxt_runtime_t *rt; in nxt_router_start_app_process() local
514 rt = task->thread->runtime; in nxt_router_start_app_process()
676 nxt_runtime_t *rt; in nxt_router_new_port_handler() local
726 rt = task->thread->runtime; in nxt_router_new_port_handler()
2800 nxt_runtime_t *rt; in nxt_router_listen_socket_rpc_create() local
3030 nxt_runtime_t *rt; in nxt_router_app_rpc_create() local
[all …]
H A Dnxt_process.h23 nxt_runtime_t *rt; member
190 nxt_process_t *nxt_process_new(nxt_runtime_t *rt);
H A Dnxt_application.h157 nxt_app_lang_module_t *nxt_app_lang_module(nxt_runtime_t *rt, nxt_str_t *name);
H A Dnxt_port.h353 void nxt_port_change_log_file(nxt_task_t *task, nxt_runtime_t *rt,
/unit/src/test/
H A Dnxt_clone_test.c433 nxt_runtime_t rt; in nxt_clone_creds_test() local
446 thr->runtime = &rt; in nxt_clone_creds_test()
455 rt.mem_pool = mp; in nxt_clone_creds_test()
488 nxt_runtime_t *rt; in nxt_clone_test_mappings() local
491 rt = task->thread->runtime; in nxt_clone_test_mappings()
502 rt->capabilities.setid = tc->setid; in nxt_clone_test_mappings()
560 nxt_runtime_t *rt; in nxt_clone_test_parse_map() local
567 rt = task->thread->runtime; in nxt_clone_test_parse_map()
569 array = nxt_conf_json_parse_str(rt->mem_pool, map_str); in nxt_clone_test_parse_map()
580 map->map = nxt_mp_alloc(rt->mem_pool, in nxt_clone_test_parse_map()