188 	struct msg_receiver *msr, *t;  in expunge_all()  local
190 	list_for_each_entry_safe(msr, t, &msq->q_receivers, r_list) {  in expunge_all()
191 		msr->r_msg = NULL; /* initialize expunge ordering */  in expunge_all()
192 		wake_up_process(msr->r_tsk);  in expunge_all()
200 		msr->r_msg = ERR_PTR(res);  in expunge_all()
571 	struct msg_receiver *msr, *t;  in pipelined_send()  local
573 	list_for_each_entry_safe(msr, t, &msq->q_receivers, r_list) {  in pipelined_send()
574 		if (testmsg(msg, msr->r_msgtype, msr->r_mode) &&  in pipelined_send()
575 		    !security_msg_queue_msgrcv(msq, msg, msr->r_tsk,  in pipelined_send()
576 					       msr->r_msgtype, msr->r_mode)) {  in pipelined_send()
578 			list_del(&msr->r_list);  in pipelined_send()
579 			if (msr->r_maxsize < msg->m_ts) {  in pipelined_send()
581 				msr->r_msg = NULL;  in pipelined_send()
582 				wake_up_process(msr->r_tsk);  in pipelined_send()
585 				msr->r_msg = ERR_PTR(-E2BIG);  in pipelined_send()
587 				msr->r_msg = NULL;  in pipelined_send()
588 				msq->q_lrpid = task_pid_vnr(msr->r_tsk);  in pipelined_send()
590 				wake_up_process(msr->r_tsk);  in pipelined_send()
599 				msr->r_msg = msg;  in pipelined_send()