Home
last modified time | relevance | path

Searched refs:pid (Results 51 – 73 of 73) sorted by path

123

/unit/src/
H A Dnxt_port_hash.c12 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 Dnxt_port_hash.h18 nxt_port_t *nxt_port_hash_find(nxt_lvlhsh_t *port_hash, nxt_pid_t pid,
H A Dnxt_port_memory.c214 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 Dnxt_port_rpc.c397 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 Dnxt_port_socket.c184 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 Dnxt_process.c218 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 Dnxt_process.h105 nxt_pid_t pid; member
H A Dnxt_router.c904 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 Dnxt_runtime.c218 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 Dnxt_runtime.h65 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 Dnxt_script.c551 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 Dnxt_socket_msg.h16 #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 Dnxt_unit.c953 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 Dnxt_unit.h69 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 Dnxt_work_queue.c50 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 Dnxt_work_queue.h71 int32_t pid; member
/unit/src/test/
H A Dnxt_cq_test.c127 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 Dconftest.py547 def _count_fds(pid): argument
554 ['procstat', '-f', pid],
564 ['lsof', '-n', '-p', pid],
701 return unit_instance['process'].pid
H A Dtest_php_application.py862 pid = r['headers']['X-Pid']
867 assert r['headers']['X-Pid'] != pid, 'new instance'
H A Dtest_python_isolation.py23 pid = re.search(fr'(\d+)\s*unit: "{app_name}" application', output).group(1)
H A Dtest_respawn.py77 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 Dapp.go55 pid := os.Getpid()
57 PID: pid,
/unit/test/php/opcache/
H A Dindex.php3 $pid = getmypid(); variable
5 header('X-Pid: ' . $pid);

123