237 	struct msg_receiver *msr, *t;  in expunge_all()  local
239 	list_for_each_entry_safe(msr, t, &msq->q_receivers, r_list) {  in expunge_all()
240 		wake_q_add(wake_q, msr->r_tsk);  in expunge_all()
241 		WRITE_ONCE(msr->r_msg, ERR_PTR(res));  in expunge_all()
791 	struct msg_receiver *msr, *t;  in pipelined_send()  local
793 	list_for_each_entry_safe(msr, t, &msq->q_receivers, r_list) {  in pipelined_send()
794 		if (testmsg(msg, msr->r_msgtype, msr->r_mode) &&  in pipelined_send()
795 		    !security_msg_queue_msgrcv(&msq->q_perm, msg, msr->r_tsk,  in pipelined_send()
796 					       msr->r_msgtype, msr->r_mode)) {  in pipelined_send()
798 			list_del(&msr->r_list);  in pipelined_send()
799 			if (msr->r_maxsize < msg->m_ts) {  in pipelined_send()
800 				wake_q_add(wake_q, msr->r_tsk);  in pipelined_send()
801 				WRITE_ONCE(msr->r_msg, ERR_PTR(-E2BIG));  in pipelined_send()
803 				ipc_update_pid(&msq->q_lrpid, task_pid(msr->r_tsk));  in pipelined_send()
806 				wake_q_add(wake_q, msr->r_tsk);  in pipelined_send()
807 				WRITE_ONCE(msr->r_msg, msg);  in pipelined_send()