255 	struct msg_msg *msg, *t;  in freeque()  local
266 	list_for_each_entry_safe(msg, t, &msq->q_messages, m_list) {  in freeque()
268 		free_msg(msg);  in freeque()
766 static int testmsg(struct msg_msg *msg, long type, int mode)  in testmsg()  argument
773 		if (msg->m_type <= type)  in testmsg()
777 		if (msg->m_type == type)  in testmsg()
781 		if (msg->m_type != type)  in testmsg()
788 static inline int pipelined_send(struct msg_queue *msq, struct msg_msg *msg,  in pipelined_send()  argument
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()
799 			if (msr->r_maxsize < msg->m_ts) {  in pipelined_send()
807 				WRITE_ONCE(msr->r_msg, msg);  in pipelined_send()
820 	struct msg_msg *msg;  in do_msgsnd()  local
832 	msg = load_msg(mtext, msgsz);  in do_msgsnd()
833 	if (IS_ERR(msg))  in do_msgsnd()
834 		return PTR_ERR(msg);  in do_msgsnd()
836 	msg->m_type = mtype;  in do_msgsnd()
837 	msg->m_ts = msgsz;  in do_msgsnd()
861 		err = security_msg_queue_msgsnd(&msq->q_perm, msg, msgflg);  in do_msgsnd()
907 	if (!pipelined_send(msq, msg, &wake_q)) {  in do_msgsnd()
909 		list_add_tail(&msg->m_list, &msq->q_messages);  in do_msgsnd()
917 	msg = NULL;  in do_msgsnd()
924 	if (msg != NULL)  in do_msgsnd()
925 		free_msg(msg);  in do_msgsnd()
994 static long do_msg_fill(void __user *dest, struct msg_msg *msg, size_t bufsz)  in do_msg_fill()  argument
999 	if (put_user(msg->m_type, &msgp->mtype))  in do_msg_fill()
1002 	msgsz = (bufsz > msg->m_ts) ? msg->m_ts : bufsz;  in do_msg_fill()
1003 	if (store_msg(msgp->mtext, msg, msgsz))  in do_msg_fill()
1044 	struct msg_msg *msg, *found = NULL;  in find_msg()  local
1047 	list_for_each_entry(msg, &msq->q_messages, m_list) {  in find_msg()
1048 		if (testmsg(msg, *msgtyp, mode) &&  in find_msg()
1049 		    !security_msg_queue_msgrcv(&msq->q_perm, msg, current,  in find_msg()
1051 			if (mode == SEARCH_LESSEQUAL && msg->m_type != 1) {  in find_msg()
1052 				*msgtyp = msg->m_type - 1;  in find_msg()
1053 				found = msg;  in find_msg()
1056 					return msg;  in find_msg()
1058 				return msg;  in find_msg()
1072 	struct msg_msg *msg, *copy = NULL;  in do_msgrcv()  local
1100 		msg = ERR_PTR(-EACCES);  in do_msgrcv()
1108 			msg = ERR_PTR(-EIDRM);  in do_msgrcv()
1112 		msg = find_msg(msq, &msgtyp, mode);  in do_msgrcv()
1113 		if (!IS_ERR(msg)) {  in do_msgrcv()
1118 			if ((bufsz < msg->m_ts) && !(msgflg & MSG_NOERROR)) {  in do_msgrcv()
1119 				msg = ERR_PTR(-E2BIG);  in do_msgrcv()
1127 				msg = copy_msg(msg, copy);  in do_msgrcv()
1131 			list_del(&msg->m_list);  in do_msgrcv()
1135 			msq->q_cbytes -= msg->m_ts;  in do_msgrcv()
1136 			atomic_sub(msg->m_ts, &ns->msg_bytes);  in do_msgrcv()
1145 			msg = ERR_PTR(-ENOMSG);  in do_msgrcv()
1185 		msg = READ_ONCE(msr_d.r_msg);  in do_msgrcv()
1186 		if (msg != ERR_PTR(-EAGAIN))  in do_msgrcv()
1195 		msg = msr_d.r_msg;  in do_msgrcv()
1196 		if (msg != ERR_PTR(-EAGAIN))  in do_msgrcv()
1201 			msg = ERR_PTR(-ERESTARTNOHAND);  in do_msgrcv()
1213 	if (IS_ERR(msg)) {  in do_msgrcv()
1215 		return PTR_ERR(msg);  in do_msgrcv()
1218 	bufsz = msg_handler(buf, msg, bufsz);  in do_msgrcv()
1219 	free_msg(msg);  in do_msgrcv()
1237 static long compat_do_msg_fill(void __user *dest, struct msg_msg *msg, size_t bufsz)  in compat_do_msg_fill()  argument
1242 	if (put_user(msg->m_type, &msgp->mtype))  in compat_do_msg_fill()
1245 	msgsz = (bufsz > msg->m_ts) ? msg->m_ts : bufsz;  in compat_do_msg_fill()
1246 	if (store_msg(msgp->mtext, msg, msgsz))  in compat_do_msg_fill()