Home
last modified time | relevance | path

Searched refs:pid (Results 1 – 25 of 64) sorted by relevance

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.c16 nxt_pid_t pid);
65 port->pid = pid; in nxt_port_new()
164 port->pid = nxt_pid; in nxt_port_enable()
214 if (process->pid == new_port->pid || process->pid == nxt_pid) { in nxt_port_send_new_port()
248 msg->pid = new_port->pid; in nxt_port_send_port()
457 nxt_pid_t pid; in nxt_port_remove_notify_others() local
464 pid = process->pid; in nxt_port_remove_notify_others()
473 || p->pid == pid in nxt_port_remove_notify_others()
492 buf->mem.free = nxt_cpymem(buf->mem.free, &pid, sizeof(pid)); in nxt_port_remove_notify_others()
504 nxt_pid_t pid; in nxt_port_remove_pid_handler() local
[all …]
H A Dnxt_process.c202 switch (pid) { in nxt_process_start()
324 return pid; in nxt_process_create()
327 pid = fork(); in nxt_process_create()
330 return pid; in nxt_process_create()
334 if (pid == 0) { in nxt_process_create()
363 process->pid = pid; in nxt_process_create()
381 return pid; in nxt_process_create()
576 process->pid = pid; in nxt_process_whoami_ok()
579 port->pid = pid; in nxt_process_whoami_ok()
856 return pid; in nxt_process_execute()
[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()
769 rt->pid = NXT_PID; in nxt_runtime_conf_init()
1023 rt->pid = p; in nxt_runtime_conf_read_cmd()
1379 length = nxt_sprintf(pid, pid + sizeof(pid), "%PI%n", nxt_pid) - pid; in nxt_runtime_pid_file_create()
1453 lhq->key_hash = nxt_murmur_hash2(pid, sizeof(*pid)); in nxt_runtime_process_lhq_pid()
1514 process->pid = pid; in nxt_runtime_process_get()
1575 port->pid = process->pid; in nxt_runtime_process_add()
1598 nxt_pid_t pid; in nxt_runtime_process_remove() local
[all …]
H A Dnxt_application.c717 pid = msg->port_msg.pid; in nxt_proto_process_created_handler()
719 if (process->pid != pid) { in nxt_proto_process_created_handler()
721 pid); in nxt_proto_process_created_handler()
723 process->pid = pid; in nxt_proto_process_created_handler()
768 nxt_pid_t pid; in nxt_proto_sigchld_handler() local
781 if (pid == -1) { in nxt_proto_sigchld_handler()
799 if (pid == 0) { in nxt_proto_sigchld_handler()
1081 init->ready_port.id.pid = proto_port->pid; in nxt_unit_default_init()
1088 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init()
1093 init->read_port.id.pid = my_port->pid; in nxt_unit_default_init()
[all …]
H A Dnxt_clone.c31 pid_t pid, nxt_int_t default_container, nxt_int_t default_host,
34 pid_t pid, u_char *mapinfo);
85 pid_t pid, u_char *mapinfo) in nxt_clone_credential_map_write() argument
94 p = nxt_sprintf(buf, end, "/proc/%d/%s", pid, mapfile); in nxt_clone_credential_map_write()
134 nxt_clone_credential_map_set(nxt_task_t *task, const char* mapfile, pid_t pid, in nxt_clone_credential_map_set() argument
195 ret = nxt_clone_credential_map_write(task, mapfile, pid, mapinfo); in nxt_clone_credential_map_set()
204 nxt_clone_credential_map(nxt_task_t *task, pid_t pid, in nxt_clone_credential_map() argument
230 ret = nxt_clone_credential_map_set(task, "uid_map", pid, app_creds->uid, in nxt_clone_credential_map()
238 ret = nxt_clone_credential_setgroups(task, pid, rule); in nxt_clone_credential_map()
240 nxt_alert(task, "failed to write /proc/%d/setgroups", pid); in nxt_clone_credential_map()
[all …]
H A Dnxt_unit.c935 msg.pid = lib->pid; in nxt_unit_ready()
1588 msg.pid = lib->pid; in nxt_unit_send_req_headers_ack()
2636 m.msg.pid = lib->pid; in nxt_unit_mmap_buf_send()
3285 msg.pid = lib->pid; in nxt_unit_request_done()
3608 msg.pid = lib->pid; in nxt_unit_send_oosm()
3892 msg.pid = lib->pid; in nxt_unit_send_mmap()
4376 msg.pid = lib->pid; in nxt_unit_send_shm_ack()
4453 process->pid = pid; in nxt_unit_process_get()
5247 port_id->pid = pid; in nxt_unit_port_id_init()
6572 pid = lib->pid; in nxt_unit_log()
[all …]
H A Dnxt_socket_msg.h16 #define NXT_CRED_GETPID(u) (u->pid)
158 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
169 *pid = -1; in nxt_socket_msg_oob_get()
204 *pid = NXT_CRED_GETPID(creds); in nxt_socket_msg_oob_get()
211 if (nxt_slow_path(*pid == -1)) { in nxt_socket_msg_oob_get()
H A Dnxt_main_process.c618 nxt_pid_t pid, ppid; in nxt_main_process_whoami_handler() local
642 pid = nxt_recv_msg_cmsg_pid(msg); in nxt_main_process_whoami_handler()
887 nxt_pid_t pid; in nxt_main_process_sigchld_handler() local
900 pid = waitpid(-1, &status, WNOHANG); in nxt_main_process_sigchld_handler()
902 if (pid == -1) { in nxt_main_process_sigchld_handler()
920 if (pid == 0) { in nxt_main_process_sigchld_handler()
927 pid, WTERMSIG(status), in nxt_main_process_sigchld_handler()
931 pid, WTERMSIG(status)); in nxt_main_process_sigchld_handler()
1045 msg->port_msg.pid); in nxt_main_port_socket_handler()
1294 if (msg->port_msg.pid != rt->port_by_type[NXT_PROCESS_DISCOVERY]->pid) { in nxt_main_port_modules_handler()
[all …]
H A Dnxt_runtime.h65 const char *pid; member
101 nxt_process_t *nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid);
112 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type);
117 NXT_EXPORT nxt_port_t *nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid,
H A Dnxt_capability.c58 hdr.pid = nxt_pid; in nxt_capability_linux_get_version()
88 hdr.pid = nxt_pid; in nxt_capability_specific_set()
H A Dnxt_log_moderation.c54 mod->pid = nxt_pid; in nxt_log_moderate_allow()
89 msg = (mod->pid == nxt_pid); in nxt_log_moderate_timer_handler()
H A Dnxt_port.h165 nxt_pid_t pid; /* not used on Linux and FreeBSD */ member
221 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->port_msg.pid)
261 nxt_pid_t pid; member
282 nxt_pid_t pid; member
291 nxt_pid_t pid; member
313 nxt_port_t *nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid,
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 …]
/unit/go/
H A Dport.go22 pid int member
101 pid: int(p.id.pid),
130 pid: int(p.id.pid),
143 func nxt_go_port_send(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
147 pid: int(pid),
154 nxt_go_alert("port %d:%d not found", pid, id)
171 func nxt_go_port_recv(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
175 pid: int(pid),
182 nxt_go_alert("port %d:%d not found", pid, id)
H A Dnxt_cgo_lib.c54 return nxt_go_port_send(port->id.pid, port->id.id, in nxt_cgo_port_send()
63 return nxt_go_port_recv(port->id.pid, port->id.id, in nxt_cgo_port_recv()
/unit/test/
H A Dtest_respawn.py68 pid = self.pid_by_name(self.PATTERN_ROUTER, unit_pid)
70 self.kill_pids(pid)
71 skip_alert(r'process %s exited on signal 9' % pid)
79 pid = self.pid_by_name(self.PATTERN_CONTROLLER, unit_pid)
81 self.kill_pids(pid)
82 skip_alert(r'process %s exited on signal 9' % pid)
93 pid = self.pid_by_name(self.app_name, unit_pid)
95 self.kill_pids(pid)
96 skip_alert(r'process %s exited on signal 9' % pid)
/unit/pkg/deb/debian/
H A Dunit.init32 if start-stop-daemon --start --quiet --pidfile /var/run/$NAME.pid \
44 if start-stop-daemon --oknodo --stop --quiet --pidfile /var/run/$NAME.pid \
59 /var/run/$NAME.pid --exec $DAEMON || true
62 /var/run/$NAME.pid --exec $DAEMON -- $DAEMON_ARGS; then
H A Dunit.default1 DAEMON_ARGS="--log /var/log/unit.log --pid /var/run/unit.pid"
H A Dunit.logrotate11 if [ -f /var/run/unit.pid ]; then
12 /bin/kill -SIGUSR1 `cat /var/run/unit.pid`
/unit/pkg/rpm/rpmbuild/SOURCES/
H A Dunit.service10 # Environment="UNITD_OPTIONS=--log /var/log/unit/unit.log --pid /var/run/unit/unit.pid"
19 Environment="UNITD_OPTIONS=--log /var/log/unit/unit.log --pid /var/run/unit/unit.pid"
H A Dunit-debug.service10 # Environment="UNITD_OPTIONS=--log /var/log/unit/unit.log --pid /var/run/unit/unit.pid"
19 Environment="UNITD_OPTIONS=--log /var/log/unit/unit.log --pid /var/run/unit/unit.pid"
H A Dunit.logrotate10 if [ -f /var/run/unit/unit.pid ]; then
11 /bin/kill -SIGUSR1 `cat /var/run/unit/unit.pid`
/unit/test/php/opcache/
H A Dindex.php3 $pid = getmypid(); variable
5 header('X-Pid: ' . $pid);
/unit/test/go/ns_inspect/
H A Dapp.go55 pid := os.Getpid()
57 PID: pid,

123