/unit/src/ |
H A D | nxt_port_hash.c | 12 int32_t pid; member 27 && pid_port_id->pid == port->pid in nxt_port_hash_test() 69 pid_port.pid = port->pid; in nxt_port_hash_add() 85 port->id, port->pid); in nxt_port_hash_add() 100 pid_port.pid = port->pid; in nxt_port_hash_remove() 114 port->id, port->pid); in nxt_port_hash_remove() 123 nxt_port_hash_find(nxt_lvlhsh_t *port_hash, nxt_pid_t pid, in nxt_port_hash_find() argument 129 pid_port.pid = pid; in nxt_port_hash_find() 135 nxt_thread_log_debug("process port (%PI, %d) found", pid, port_id); in nxt_port_hash_find() 139 nxt_thread_log_debug("process port (%PI, %d) not found", pid, port_id); in nxt_port_hash_find()
|
H A D | nxt_port_hash.h | 18 nxt_port_t *nxt_port_hash_find(nxt_lvlhsh_t *port_hash, nxt_pid_t pid,
|
H A D | nxt_port_memory.c | 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() 239 "%PI != %PI or %PI != %PI", hdr->src_pid, process->pid, in nxt_port_incoming_port_mmap() 722 "via shared memory", sb->size, port->pid); in nxt_port_mmap_write() 752 port->pid); in nxt_port_mmap_write() 781 msg->port_msg.pid); in nxt_port_mmap_read() 784 msg->port_msg.pid, mmap_msg); in nxt_port_mmap_read()
|
H A D | nxt_port_rpc.c | 397 msg.port_msg.pid = nxt_pid; in nxt_port_rpc_remove_peer() 509 msg.port_msg.pid = nxt_pid; in nxt_port_rpc_close()
|
H A D | nxt_port_socket.c | 184 msg.port_msg.pid = nxt_pid; in nxt_port_socket_write2() 206 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_socket_write2() 233 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_socket_write2() 859 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler() 941 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler() 959 (int) port->pid, (int) port->id, in nxt_port_queue_read_handler() 971 (int) port->pid, (int) port->id, in nxt_port_queue_read_handler() 1029 uint32_t pid; member 1044 && frag_key->pid == (uint32_t) fmsg->port_msg.pid) in nxt_port_lvlhsh_frag_test() 1095 frag_key.pid = fmsg->port_msg.pid; in nxt_port_frag_start() [all …]
|
H A D | nxt_process.c | 218 switch (pid) { in nxt_process_start() 412 pid = -1; in nxt_process_recv_pid() 420 return pid; in nxt_process_recv_pid() 474 pid = fork(); in nxt_process_unshare() 557 pid = fork(); in nxt_process_create() 604 process->pid = pid; in nxt_process_create() 633 return pid; in nxt_process_create() 832 process->pid = pid; in nxt_process_whoami_ok() 835 port->pid = pid; in nxt_process_whoami_ok() 1112 return pid; in nxt_process_execute() [all …]
|
H A D | nxt_process.h | 105 nxt_pid_t pid; member
|
H A D | nxt_router.c | 904 proto_port->pid); in nxt_router_app_restart_handler() 3145 &app->name, port->pid, port->id); in nxt_router_app_prefork_ready() 4244 msg->port_msg.pid); in nxt_router_req_headers_ack_handler() 4703 port->pid, port->id, in nxt_router_app_port_release() 4806 port->pid); in nxt_router_app_port_close() 4820 port->pid, port->id); in nxt_router_app_port_close() 4920 &app->name, port->pid, in nxt_router_adjust_idle_timer() 4945 &app->name, port->pid); in nxt_router_adjust_idle_timer() 5037 proto_port->pid); in nxt_router_free_app() 5291 msg.pm.pid = reply_port->pid; in nxt_router_app_prepare_request() [all …]
|
H A D | nxt_runtime.c | 218 u_char *nfd, *pid; in nxt_runtime_systemd_listen_sockets() local 235 if (pid == NULL) { in nxt_runtime_systemd_listen_sockets() 244 if (nxt_pid != nxt_int_parse(pid, nxt_strlen(pid))) { in nxt_runtime_systemd_listen_sockets() 786 rt->pid = NXT_PID; in nxt_runtime_conf_init() 1124 rt->pid = p; in nxt_runtime_conf_read_cmd() 1502 length = nxt_sprintf(pid, pid + sizeof(pid), "%PI%n", nxt_pid) - pid; in nxt_runtime_pid_file_create() 1576 lhq->key_hash = nxt_murmur_hash2(pid, sizeof(*pid)); in nxt_runtime_process_lhq_pid() 1637 process->pid = pid; in nxt_runtime_process_get() 1698 port->pid = process->pid; in nxt_runtime_process_add() 1721 nxt_pid_t pid; in nxt_runtime_process_remove() local [all …]
|
H A D | nxt_runtime.h | 65 const char *pid; member 106 nxt_process_t *nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid); 117 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type); 122 NXT_EXPORT nxt_port_t *nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid,
|
H A D | nxt_script.c | 551 port = nxt_runtime_port_find(task->thread->runtime, msg->port_msg.pid, in nxt_script_store_get_handler() 556 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_script_store_get_handler() 564 msg->port_msg.pid); in nxt_script_store_get_handler() 646 if (nxt_slow_path(nxt_recv_msg_cmsg_pid(msg) != ctl_port->pid)) { in nxt_script_store_delete_handler()
|
H A D | nxt_socket_msg.h | 16 #define NXT_CRED_GETPID(u) (u->pid) 172 nxt_socket_msg_oob_get(nxt_recv_oob_t *oob, nxt_fd_t *fd, nxt_pid_t *pid) in nxt_socket_msg_oob_get() argument 183 *pid = -1; in nxt_socket_msg_oob_get() 218 *pid = NXT_CRED_GETPID(creds); in nxt_socket_msg_oob_get() 225 if (nxt_slow_path(*pid == -1)) { in nxt_socket_msg_oob_get()
|
H A D | nxt_unit.c | 953 msg.pid = lib->pid; in nxt_unit_ready() 1606 msg.pid = lib->pid; in nxt_unit_send_req_headers_ack() 2655 m.msg.pid = lib->pid; in nxt_unit_mmap_buf_send() 3304 msg.pid = lib->pid; in nxt_unit_request_done() 3627 msg.pid = lib->pid; in nxt_unit_send_oosm() 3911 msg.pid = lib->pid; in nxt_unit_send_mmap() 4395 msg.pid = lib->pid; in nxt_unit_send_shm_ack() 4472 process->pid = pid; in nxt_unit_process_get() 5266 port_id->pid = pid; in nxt_unit_port_id_init() 6591 pid = lib->pid; in nxt_unit_log() [all …]
|
H A D | nxt_unit.h | 69 pid_t pid; member 143 void (*remove_pid)(nxt_unit_t *, pid_t pid); 243 void nxt_unit_port_id_init(nxt_unit_port_id_t *port_id, pid_t pid, uint16_t id);
|
H A D | nxt_work_queue.c | 50 if (nxt_slow_path(nxt_pid != wq->pid)) { in nxt_work_queue_thread_assert() 51 wq->pid = nxt_pid; in nxt_work_queue_thread_assert() 68 wq->pid = nxt_pid; in nxt_work_queue_thread_adopt()
|
H A D | nxt_work_queue.h | 71 int32_t pid; member
|
/unit/src/test/ |
H A D | nxt_cq_test.c | 127 nxt_pid_t pid; member 311 pid_t pid = fork(); in worker_create() local 313 if (pid == 0) { in worker_create() 318 wi->pid = pid; in worker_create() 333 waitpid(wi->pid, &wi->status, 0); in worker_wait()
|
/unit/test/ |
H A D | conftest.py | 547 def _count_fds(pid): argument 554 ['procstat', '-f', pid], 564 ['lsof', '-n', '-p', pid], 701 return unit_instance['process'].pid
|
H A D | test_php_application.py | 862 pid = r['headers']['X-Pid'] 867 assert r['headers']['X-Pid'] != pid, 'new instance'
|
H A D | test_python_isolation.py | 23 pid = re.search(fr'(\d+)\s*unit: "{app_name}" application', output).group(1)
|
H A D | test_respawn.py | 77 pid = pid_by_name(PATTERN_ROUTER, unit_pid) 79 kill_pids(pid) 89 pid = pid_by_name(PATTERN_CONTROLLER, unit_pid) 91 kill_pids(pid) 102 pid = pid_by_name(client.app_name, unit_pid) 104 kill_pids(pid)
|
/unit/test/go/ns_inspect/ |
H A D | app.go | 55 pid := os.Getpid() 57 PID: pid,
|
/unit/test/php/opcache/ |
H A D | index.php | 3 $pid = getmypid(); variable 5 header('X-Pid: ' . $pid);
|