last modified time | relevance | path

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

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;
160 NXT_EXPORT nxt_pid_t nxt_process_execute(nxt_task_t *task, char *name,
229 NXT_EXPORT extern nxt_pid_t nxt_pid;
230 NXT_EXPORT extern nxt_pid_t nxt_ppid;
H A Dnxt_port.h165 nxt_pid_t pid; /* not used on Linux and FreeBSD */
206 nxt_pid_t cmsg_pid;
211 nxt_pid_t removed_pid;
261 nxt_pid_t pid;
282 nxt_pid_t pid;
291 nxt_pid_t pid;
313 nxt_port_t *nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid,
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()
313 static nxt_pid_t
317 nxt_pid_t pid; in nxt_process_create()
558 nxt_pid_t pid, isolated_pid; in nxt_process_whoami_ok()
568 nxt_assert(nxt_buf_used_size(buf) == sizeof(nxt_pid_t)); in nxt_process_whoami_ok()
570 nxt_memcpy(&pid, buf->mem.pos, sizeof(nxt_pid_t)); in nxt_process_whoami_ok()
844 nxt_pid_t
847 nxt_pid_t pid; in nxt_process_execute()
[all …]
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_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_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()
1113 nxt_pid_t *qpid; in nxt_proto_lvlhsh_isolated_pid_test()
1117 qpid = (nxt_pid_t *) lhq->key.start; in nxt_proto_lvlhsh_isolated_pid_test()
1136 nxt_proto_process_lhq_pid(nxt_lvlhsh_query_t *lhq, nxt_pid_t *pid) in nxt_proto_process_lhq_pid()
1138 lhq->key_hash = nxt_murmur_hash2(pid, sizeof(nxt_pid_t)); in nxt_proto_process_lhq_pid()
1139 lhq->key.length = sizeof(nxt_pid_t); in nxt_proto_process_lhq_pid()
1176 nxt_proto_process_remove(nxt_task_t *task, nxt_pid_t pid) in nxt_proto_process_remove()
[all …]
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);
1433 if (lhq->key.length == sizeof(nxt_pid_t) in nxt_runtime_lvlhsh_pid_test()
1434 && *(nxt_pid_t *) lhq->key.start == process->pid) in nxt_runtime_lvlhsh_pid_test()
1451 nxt_runtime_process_lhq_pid(nxt_lvlhsh_query_t *lhq, nxt_pid_t *pid) in nxt_runtime_process_lhq_pid()
1461 nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid) in nxt_runtime_process_find()
1486 nxt_runtime_process_get(nxt_runtime_t *rt, nxt_pid_t pid) in nxt_runtime_process_get()
1598 nxt_pid_t pid; in nxt_runtime_process_remove()
1643 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type) in nxt_runtime_process_port_create()
1714 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.c464 nxt_pid_t pid; in nxt_controller_remove_pid_handler()
H A Dnxt_router.c1008 nxt_pid_t removed_pid; in nxt_router_app_process_remove_pid()
H A Dnxt_unit.c222 nxt_pid_t pid;
H A Dnxt_cq_test.c127 nxt_pid_t pid;