Searched refs:msg_queue (Results 1 – 6 of 6) sorted by relevance
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/wpa_supplicant/ |
D | ctrl_iface_unix.c | 39 struct dl_list msg_queue; member 49 struct dl_list msg_queue; member 317 while (gpriv && !dl_list_empty(&gpriv->msg_queue) && in wpas_ctrl_msg_send_pending_global() 319 msg = dl_list_first(&gpriv->msg_queue, struct ctrl_iface_msg, in wpas_ctrl_msg_send_pending_global() 341 while (priv && !dl_list_empty(&priv->msg_queue) && in wpas_ctrl_msg_send_pending_iface() 343 msg = dl_list_first(&priv->msg_queue, struct ctrl_iface_msg, in wpas_ctrl_msg_send_pending_iface() 367 if (priv && !dl_list_empty(&priv->msg_queue)) in wpas_ctrl_msg_queue_timeout() 371 if (gpriv && !dl_list_empty(&gpriv->msg_queue)) in wpas_ctrl_msg_queue_timeout() 440 if (!dl_list_empty(&gpriv->msg_queue) || in wpa_supplicant_ctrl_iface_msg_cb() 449 &gpriv->msg_queue); in wpa_supplicant_ctrl_iface_msg_cb() [all …]
|
/third_party/wpa_supplicant/wpa_supplicant-2.9/wpa_supplicant/ |
D | ctrl_iface_unix.c | 39 struct dl_list msg_queue; member 49 struct dl_list msg_queue; member 307 while (gpriv && !dl_list_empty(&gpriv->msg_queue) && in wpas_ctrl_msg_send_pending_global() 309 msg = dl_list_first(&gpriv->msg_queue, struct ctrl_iface_msg, in wpas_ctrl_msg_send_pending_global() 331 while (priv && !dl_list_empty(&priv->msg_queue) && in wpas_ctrl_msg_send_pending_iface() 333 msg = dl_list_first(&priv->msg_queue, struct ctrl_iface_msg, in wpas_ctrl_msg_send_pending_iface() 357 if (priv && !dl_list_empty(&priv->msg_queue)) in wpas_ctrl_msg_queue_timeout() 361 if (gpriv && !dl_list_empty(&gpriv->msg_queue)) in wpas_ctrl_msg_queue_timeout() 430 if (!dl_list_empty(&gpriv->msg_queue) || in wpa_supplicant_ctrl_iface_msg_cb() 439 &gpriv->msg_queue); in wpa_supplicant_ctrl_iface_msg_cb() [all …]
|
/third_party/libuv/src/unix/ |
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() 376 msgctl(lst->msg_queue, IPC_RMID, NULL); in epoll_queue_close() 377 lst->msg_queue = -1; in epoll_queue_close()
|
D | os390.c | 554 assert(ep->msg_queue != -1); in uv_fs_event_start() 557 reg_struct.__rfis_qid = ep->msg_queue; in uv_fs_event_start() 588 assert(ep->msg_queue != -1); in uv_fs_event_stop() 591 reg_struct.__rfis_qid = ep->msg_queue; in uv_fs_event_stop() 617 if (ep->msg_queue == -1) in os390_message_queue_handler() 620 msglen = msgrcv(ep->msg_queue, &msg, sizeof(msg), 0, IPC_NOWAIT); in os390_message_queue_handler()
|
D | os390-syscalls.h | 51 int msg_queue; member
|
/third_party/quickjs/ |
D | quickjs-libc.c | 111 struct list_head msg_queue; /* list of JSWorkerMessage.link */ member 2150 if (!list_empty(&ps->msg_queue)) { in handle_posted_message() 2151 el = ps->msg_queue.next; in handle_posted_message() 2157 if (list_empty(&ps->msg_queue)) { in handle_posted_message() 3152 init_list_head(&ps->msg_queue); in js_new_message_pipe() 3189 list_for_each_safe(el, el1, &ps->msg_queue) { in js_free_message_pipe() 3434 if (list_empty(&ps->msg_queue)) { in js_worker_postMessage() 3445 list_add_tail(&msg->link, &ps->msg_queue); in js_worker_postMessage()
|