| /src/sys/sys/ |
| mqueue.h | 105 TAILQ_ENTRY(mq_msg) msg_queue; member in struct:mq_msg
|
| /src/external/mit/libuv/dist/src/unix/ |
| os390-syscalls.h | 51 int msg_queue; member in struct:__anon23811
|
| os390-syscalls.c | 151 lst->msg_queue = msgget(IPC_PRIVATE, 0600 | IPC_CREAT);
152 if (lst->msg_queue == -1)
161 if (msgsnd(lst->msg_queue, &msg, sizeof(msg.body), 0) != 0)
165 if (msgrcv(lst->msg_queue, &msg, sizeof(msg.body), 0, 0) != sizeof(msg.body))
223 lst->items[lst->size - 1].fd = lst->msg_queue;
378 msgctl(lst->msg_queue, IPC_RMID, NULL);
379 lst->msg_queue = -1;
|
| os390.c | 643 assert(ep->msg_queue != -1);
646 reg_struct.__rfis_qid = ep->msg_queue;
696 assert(ep->msg_queue != -1);
699 reg_struct.__rfis_qid = ep->msg_queue;
753 if (ep->msg_queue == -1)
756 msglen = msgrcv(ep->msg_queue, &msg, sizeof(msg), 0, IPC_NOWAIT);
|
| /src/external/bsd/wpa/dist/wpa_supplicant/ |
| ctrl_iface_unix.c | 39 struct dl_list msg_queue; member in struct:ctrl_iface_priv
49 struct dl_list msg_queue; member in struct:ctrl_iface_global_priv
320 while (gpriv && !dl_list_empty(&gpriv->msg_queue) &&
322 msg = dl_list_first(&gpriv->msg_queue, struct ctrl_iface_msg,
344 while (priv && !dl_list_empty(&priv->msg_queue) &&
346 msg = dl_list_first(&priv->msg_queue, struct ctrl_iface_msg,
370 if (priv && !dl_list_empty(&priv->msg_queue))
374 if (gpriv && !dl_list_empty(&gpriv->msg_queue))
443 if (!dl_list_empty(&gpriv->msg_queue) ||
452 &gpriv->msg_queue);
[all...] |
| /src/sys/kern/ |
| sys_mqueue.c | 232 TAILQ_REMOVE(&mq->mq_head[i], msg, msg_queue);
311 TAILQ_FOREACH(mit, &mq->mq_head[MQ_PQRESQ], msg_queue) {
316 TAILQ_INSERT_TAIL(&mq->mq_head[MQ_PQRESQ], msg, msg_queue);
318 TAILQ_INSERT_BEFORE(mit, msg, msg_queue);
692 TAILQ_REMOVE(&mq->mq_head[idx], msg, msg_queue);
867 TAILQ_INSERT_TAIL(&mq->mq_head[idx], msg, msg_queue);
|
| /src/sys/external/bsd/vchiq/dist/interface/vchiq_arm/ |
| vchiq_arm.c | 118 VCHIQ_HEADER_T * msg_queue[MSG_QUEUE_SIZE]; member in struct:user_service_struct
372 user_service->msg_queue[user_service->msg_insert &
1094 header = user_service->msg_queue[user_service->msg_remove &
1375 msg_queue[user_service->msg_remove &
|
