Home
last modified time | relevance | path

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

/unit/src/
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.h28 typedef pid_t nxt_pid_t; typedef
101 nxt_pid_t pid;
110 nxt_pid_t isolated_pid;
158 NXT_EXPORT nxt_pid_t nxt_process_execute(nxt_task_t *task, char *name,
227 NXT_EXPORT extern nxt_pid_t nxt_pid;
228 NXT_EXPORT extern nxt_pid_t nxt_ppid;
H A Dnxt_process.c50 nxt_pid_t nxt_pid;
53 nxt_pid_t nxt_ppid;
168 nxt_pid_t pid; in nxt_process_start()
303 static nxt_pid_t
307 nxt_pid_t pid; in nxt_process_create()
534 nxt_pid_t pid, isolated_pid; in nxt_process_whoami_ok()
822 nxt_pid_t
825 nxt_pid_t pid; in nxt_process_execute()
839 nxt_pid_t
842 nxt_pid_t pid; in nxt_process_execute()
[all …]
H A Dnxt_port.h160 nxt_pid_t pid; /* not used on Linux and FreeBSD */
201 nxt_pid_t cmsg_pid;
206 nxt_pid_t removed_pid;
256 nxt_pid_t pid;
277 nxt_pid_t pid;
286 nxt_pid_t pid;
308 nxt_port_t *nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid,
H A Dnxt_runtime.h101 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_port_hash.h18 nxt_port_t *nxt_port_hash_find(nxt_lvlhsh_t *port_hash, nxt_pid_t pid,
H A Dnxt_signal.h32 nxt_pid_t process;
H A Dnxt_log_moderation.h16 nxt_pid_t pid;
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_application.c55 static nxt_process_t *nxt_proto_process_find(nxt_task_t *task, nxt_pid_t pid);
57 static nxt_process_t *nxt_proto_process_remove(nxt_task_t *task, nxt_pid_t pid);
696 nxt_pid_t isolated_pid, pid; in nxt_proto_process_created_handler()
755 nxt_pid_t pid; in nxt_proto_sigchld_handler()
1070 nxt_pid_t *qpid; in nxt_proto_lvlhsh_isolated_pid_test()
1074 qpid = (nxt_pid_t *) lhq->key.start; in nxt_proto_lvlhsh_isolated_pid_test()
1093 nxt_proto_process_lhq_pid(nxt_lvlhsh_query_t *lhq, nxt_pid_t *pid) in nxt_proto_process_lhq_pid()
1095 lhq->key_hash = nxt_murmur_hash2(pid, sizeof(nxt_pid_t)); in nxt_proto_process_lhq_pid()
1096 lhq->key.length = sizeof(nxt_pid_t); in nxt_proto_process_lhq_pid()
1133 nxt_proto_process_remove(nxt_task_t *task, nxt_pid_t pid) in nxt_proto_process_remove()
[all …]
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.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_cache.h71 nxt_pid_t pid;
H A Dnxt_runtime.c42 static nxt_process_t *nxt_runtime_process_get(nxt_runtime_t *rt, nxt_pid_t pid);
1432 if (lhq->key.length == sizeof(nxt_pid_t) in nxt_runtime_lvlhsh_pid_test()
1433 && *(nxt_pid_t *) lhq->key.start == process->pid) in nxt_runtime_lvlhsh_pid_test()
1450 nxt_runtime_process_lhq_pid(nxt_lvlhsh_query_t *lhq, nxt_pid_t *pid) in nxt_runtime_process_lhq_pid()
1460 nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid) in nxt_runtime_process_find()
1485 nxt_runtime_process_get(nxt_runtime_t *rt, nxt_pid_t pid) in nxt_runtime_process_get()
1597 nxt_pid_t pid; in nxt_runtime_process_remove()
1640 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type) in nxt_runtime_process_port_create()
1711 nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid, in nxt_runtime_port_find()
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_socket_msg.h158 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_main_process.c618 nxt_pid_t pid, ppid; in nxt_main_process_whoami_handler()
626 || nxt_buf_used_size(msg->buf) != sizeof(nxt_pid_t))) in nxt_main_process_whoami_handler()
632 nxt_memcpy(&ppid, msg->buf->mem.pos, sizeof(nxt_pid_t)); in nxt_main_process_whoami_handler()
678 sizeof(nxt_pid_t), 0); in nxt_main_process_whoami_handler()
683 buf->mem.free = nxt_cpymem(buf->mem.free, &pid, sizeof(nxt_pid_t)); in nxt_main_process_whoami_handler()
887 nxt_pid_t pid; in nxt_main_process_sigchld_handler()
H A Dnxt_event_engine.h177 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_sprintf.c496 i64 = (int64_t) va_arg(args, nxt_pid_t); in nxt_vsprintf()
H A Dnxt_mp.c114 nxt_pid_t pid;
H A Dnxt_controller.c456 nxt_pid_t pid; in nxt_controller_remove_pid_handler()
H A Dnxt_router.c952 nxt_pid_t removed_pid; in nxt_router_app_process_remove_pid()
H A Dnxt_unit.c222 nxt_pid_t pid;
/unit/src/test/
H A Dnxt_cq_test.c127 nxt_pid_t pid;