Searched refs:msg_queue (Results 1 – 6 of 6) sorted by relevance
/netbsd-src/external/mit/libuv/dist/src/unix/ |
H A D | os390-syscalls.c | 151 lst->msg_queue = msgget(IPC_PRIVATE, 0600 | IPC_CREAT); in init_message_queue() 152 if (lst->msg_queue == -1) in init_message_queue() 161 if (msgsnd(lst->msg_queue, &msg, sizeof(msg.body), 0) != 0) in init_message_queue() 165 if (msgrcv(lst->msg_queue, &msg, sizeof(msg.body), 0, 0) != sizeof(msg.body)) in init_message_queue() 223 lst->items[lst->size - 1].fd = lst->msg_queue; in epoll_create1() 378 msgctl(lst->msg_queue, IPC_RMID, NULL); in epoll_queue_close() 379 lst->msg_queue = -1; in epoll_queue_close()
|
H A D | os390.c | 636 assert(ep->msg_queue != -1); in os390_regfileint() 639 reg_struct.__rfis_qid = ep->msg_queue; in os390_regfileint() 689 assert(ep->msg_queue != -1); in uv__fs_event_stop() 692 reg_struct.__rfis_qid = ep->msg_queue; in uv__fs_event_stop() 746 if (ep->msg_queue == -1) in os390_message_queue_handler() 749 msglen = msgrcv(ep->msg_queue, &msg, sizeof(msg), 0, IPC_NOWAIT); in os390_message_queue_handler()
|
H A D | os390-syscalls.h | 51 int msg_queue; member
|
/netbsd-src/sys/kern/ |
H A D | sys_mqueue.c | 232 TAILQ_REMOVE(&mq->mq_head[i], msg, msg_queue); in mqueue_destroy() 311 TAILQ_FOREACH(mit, &mq->mq_head[MQ_PQRESQ], msg_queue) { in mqueue_linear_insert() 316 TAILQ_INSERT_TAIL(&mq->mq_head[MQ_PQRESQ], msg, msg_queue); in mqueue_linear_insert() 318 TAILQ_INSERT_BEFORE(mit, msg, msg_queue); in mqueue_linear_insert() 692 TAILQ_REMOVE(&mq->mq_head[idx], msg, msg_queue); in mq_recv1() 867 TAILQ_INSERT_TAIL(&mq->mq_head[idx], msg, msg_queue); in mq_send1()
|
/netbsd-src/sys/sys/ |
H A D | mqueue.h | 105 TAILQ_ENTRY(mq_msg) msg_queue;
|
/netbsd-src/sys/external/bsd/vchiq/dist/interface/vchiq_arm/ |
H A D | vchiq_arm.c | 118 VCHIQ_HEADER_T * msg_queue[MSG_QUEUE_SIZE]; member 372 user_service->msg_queue[user_service->msg_insert & in service_callback() 991 header = user_service->msg_queue[user_service->msg_remove & in vchiq_ioctl() 1272 msg_queue[user_service->msg_remove & in vchiq_close()
|