Home
last modified time | relevance | path

Searched refs:nxt_pid_t (Results 1 – 24 of 24) sorted by path

/unit/src/
H A Dnxt_application.c62 static nxt_process_t *nxt_proto_process_find(nxt_task_t *task, nxt_pid_t pid);
64 static nxt_process_t *nxt_proto_process_remove(nxt_task_t *task, nxt_pid_t pid);
705 nxt_pid_t isolated_pid, pid; in nxt_proto_process_created_handler()
768 nxt_pid_t pid; in nxt_proto_sigchld_handler()
1169 nxt_pid_t *qpid; in nxt_proto_lvlhsh_isolated_pid_test()
1173 qpid = (nxt_pid_t *) lhq->key.start; in nxt_proto_lvlhsh_isolated_pid_test()
1192 nxt_proto_process_lhq_pid(nxt_lvlhsh_query_t *lhq, nxt_pid_t *pid) in nxt_proto_process_lhq_pid()
1194 lhq->key_hash = nxt_murmur_hash2(pid, sizeof(nxt_pid_t)); in nxt_proto_process_lhq_pid()
1195 lhq->key.length = sizeof(nxt_pid_t); in nxt_proto_process_lhq_pid()
1232 nxt_proto_process_remove(nxt_task_t *task, nxt_pid_t pid) in nxt_proto_process_remove()
[all …]
H A Dnxt_controller.c488 nxt_pid_t pid; in nxt_controller_remove_pid_handler()
H A Dnxt_event_engine.h177 nxt_pid_t pid;
H A Dnxt_log_moderation.h16 nxt_pid_t pid;
H A Dnxt_main_process.c683 nxt_pid_t pid, ppid; in nxt_main_process_whoami_handler()
691 || nxt_buf_used_size(msg->buf) != sizeof(nxt_pid_t))) in nxt_main_process_whoami_handler()
697 nxt_memcpy(&ppid, msg->buf->mem.pos, sizeof(nxt_pid_t)); in nxt_main_process_whoami_handler()
743 sizeof(nxt_pid_t), 0); in nxt_main_process_whoami_handler()
748 buf->mem.free = nxt_cpymem(buf->mem.free, &pid, sizeof(nxt_pid_t)); in nxt_main_process_whoami_handler()
952 nxt_pid_t pid; in nxt_main_process_sigchld_handler()
H A Dnxt_mp.c114 nxt_pid_t pid;
H A Dnxt_port.c16 nxt_pid_t pid);
49 nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid, in nxt_port_new()
457 nxt_pid_t pid; in nxt_port_remove_notify_others()
504 nxt_pid_t pid; in nxt_port_remove_pid_handler()
511 nxt_memcpy(&pid, buf->mem.pos, sizeof(nxt_pid_t)); in nxt_port_remove_pid_handler()
519 nxt_pid_t pid) in nxt_port_remove_pid()
H A Dnxt_port.h174 nxt_pid_t pid; /* not used on Linux and FreeBSD */
215 nxt_pid_t cmsg_pid;
220 nxt_pid_t removed_pid;
270 nxt_pid_t pid;
291 nxt_pid_t pid;
300 nxt_pid_t pid;
322 nxt_port_t *nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid,
H A Dnxt_port_hash.c123 nxt_port_hash_find(nxt_lvlhsh_t *port_hash, nxt_pid_t pid, 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.c515 nxt_port_get_port_incoming_mmap(nxt_task_t *task, nxt_pid_t spid, uint32_t id) in nxt_port_get_port_incoming_mmap()
665 nxt_pid_t spid, nxt_port_mmap_msg_t *mmap_msg) in nxt_port_mmap_get_incoming_buf()
H A Dnxt_port_memory_int.h51 nxt_pid_t src_pid; /* For sanity check. */
52 nxt_pid_t dst_pid; /* For sanity check. */
H A Dnxt_port_rpc.c18 nxt_pid_t peer;
82 nxt_port_rpc_lhq_peer(nxt_lvlhsh_query_t *lhq, nxt_pid_t *peer) in nxt_port_rpc_lhq_peer()
94 nxt_pid_t peer, void *data) in nxt_port_rpc_register_handler()
189 void *ex, nxt_pid_t peer) in nxt_port_rpc_ex_set_peer()
367 nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port, nxt_pid_t peer) in nxt_port_rpc_remove_peer()
H A Dnxt_port_rpc.h18 nxt_pid_t peer, void *data);
25 void *ex, nxt_pid_t peer);
29 nxt_pid_t peer);
H A Dnxt_process.c66 nxt_pid_t nxt_pid;
69 nxt_pid_t nxt_ppid;
184 nxt_pid_t pid; in nxt_process_start()
393 static nxt_pid_t
398 nxt_pid_t pid; in nxt_process_recv_pid()
446 nxt_pid_t pid; in nxt_process_unshare()
540 static nxt_pid_t
544 nxt_pid_t pid; in nxt_process_create()
1100 nxt_pid_t
1103 nxt_pid_t pid; in nxt_process_execute()
[all …]
H A Dnxt_process.h16 typedef pid_t nxt_pid_t; typedef
105 nxt_pid_t pid;
114 nxt_pid_t isolated_pid;
164 NXT_EXPORT nxt_pid_t nxt_process_execute(nxt_task_t *task, char *name,
233 NXT_EXPORT extern nxt_pid_t nxt_pid;
234 NXT_EXPORT extern nxt_pid_t nxt_ppid;
H A Dnxt_router.c1029 nxt_pid_t removed_pid; in nxt_router_app_process_remove_pid()
H A Dnxt_runtime.c42 static nxt_process_t *nxt_runtime_process_get(nxt_runtime_t *rt, nxt_pid_t pid);
1501 if (lhq->key.length == sizeof(nxt_pid_t) in nxt_runtime_lvlhsh_pid_test()
1502 && *(nxt_pid_t *) lhq->key.start == process->pid) in nxt_runtime_lvlhsh_pid_test()
1519 nxt_runtime_process_lhq_pid(nxt_lvlhsh_query_t *lhq, nxt_pid_t *pid) in nxt_runtime_process_lhq_pid()
1529 nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid) in nxt_runtime_process_find()
1554 nxt_runtime_process_get(nxt_runtime_t *rt, nxt_pid_t pid) in nxt_runtime_process_get()
1666 nxt_pid_t pid; in nxt_runtime_process_remove()
1711 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type) in nxt_runtime_process_port_create()
1782 nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid, in nxt_runtime_port_find()
H A Dnxt_runtime.h102 nxt_process_t *nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid);
113 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type);
118 NXT_EXPORT nxt_port_t *nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid,
H A Dnxt_signal.h32 nxt_pid_t process;
H A Dnxt_socket_msg.h172 nxt_socket_msg_oob_get(nxt_recv_oob_t *oob, nxt_fd_t *fd, nxt_pid_t *pid) in nxt_socket_msg_oob_get()
H A Dnxt_sprintf.c496 i64 = (int64_t) va_arg(args, nxt_pid_t); in nxt_vsprintf()
H A Dnxt_unit.c222 nxt_pid_t pid;
/unit/src/test/
H A Dnxt_cq_test.c127 nxt_pid_t pid;