Lines Matching refs:wake_q
212 static void ss_wakeup(struct msg_queue *msq, struct wake_q_head *wake_q, bool kill) in ss_wakeup() argument
233 wake_q_add(wake_q, mss->tsk); in ss_wakeup()
237 static void expunge_all(struct msg_queue *msq, int res, struct wake_q_head *wake_q) in expunge_all() argument
249 wake_q_add_safe(wake_q, r_tsk); in expunge_all()
265 DEFINE_WAKE_Q(wake_q); in freeque()
267 expunge_all(msq, -EIDRM, &wake_q); in freeque()
268 ss_wakeup(msq, &wake_q, true); in freeque()
271 wake_up_q(&wake_q); in freeque()
419 DEFINE_WAKE_Q(wake_q); in msgctl_down()
439 expunge_all(msq, -EAGAIN, &wake_q); in msgctl_down()
444 ss_wakeup(msq, &wake_q, false); in msgctl_down()
446 wake_up_q(&wake_q); in msgctl_down()
815 …c inline int pipelined_send(struct msg_queue *msq, struct msg_msg *msg, struct wake_q_head *wake_q) in pipelined_send() argument
825 wake_q_add(wake_q, msr->r_tsk); in pipelined_send()
833 wake_q_add(wake_q, msr->r_tsk); in pipelined_send()
851 DEFINE_WAKE_Q(wake_q); in do_msgsnd()
940 if (!pipelined_send(msq, msg, &wake_q)) { in do_msgsnd()
954 wake_up_q(&wake_q); in do_msgsnd()
1114 DEFINE_WAKE_Q(wake_q); in do_msgrcv()
1183 ss_wakeup(msq, &wake_q, false); in do_msgrcv()
1265 wake_up_q(&wake_q); in do_msgrcv()