sys/kern/sysv_msg.c

254 		struct __msg *nmsghdr, *msghdr, *pmsghdr;
274 		msghdr = mptr->_msg_first;
275 		while (msghdr) {
291 			nmsghdr->msg_ts = msghdr->msg_ts;
295 			msgsz = msghdr->msg_ts;
309 			next = msghdr->msg_spot;
331 			msghdr = msghdr->msg_next;
370 msg_freehdr(struct __msg *msghdr)
375 	while (msghdr->msg_ts > 0) {
377 		KASSERT(msghdr->msg_spot >= 0);
378 		KASSERT(msghdr->msg_spot < msginfo.msgseg);
380 		next = msgmaps[msghdr->msg_spot].next;
381 		msgmaps[msghdr->msg_spot].next = free_msgmaps;
382 		free_msgmaps = msghdr->msg_spot;
384 		msghdr->msg_spot = next;
385 		if (msghdr->msg_ts >= msginfo.msgssz)
386 			msghdr->msg_ts -= msginfo.msgssz;
388 			msghdr->msg_ts = 0;
390 	KASSERT(msghdr->msg_spot == -1);
391 	msghdr->msg_next = free_msghdrs;
392 	free_msghdrs = msghdr;
462 		struct __msg *msghdr;
466 		msghdr = msqptr->_msg_first;
467 		while (msghdr != NULL) {
471 			msqptr->_msg_cbytes -= msghdr->msg_ts;
473 			msghdr_tmp = msghdr;
474 			msghdr = msghdr->msg_next;
651 	struct __msg *msghdr;
813 	msghdr = free_msghdrs;
814 	free_msghdrs = msghdr->msg_next;
815 	msghdr->msg_spot = -1;
816 	msghdr->msg_ts = msgsz;
831 		msgmaps[next].next = msghdr->msg_spot;
832 		msghdr->msg_spot = next;
840 	error = (*fetch_type)(user_msgp, &msghdr->msg_type, typesz);
844 		msg_freehdr(msghdr);
855 	if (msghdr->msg_type < 1) {
856 		msg_freehdr(msghdr);
859 		MSG_PRINTF(("mtype (%ld) < 1\n", msghdr->msg_type));
868 	next = msghdr->msg_spot;
884 			msg_freehdr(msghdr);
906 		msg_freehdr(msghdr);
917 		msqptr->_msg_first = msghdr;
918 		msqptr->_msg_last = msghdr;
920 		msqptr->_msg_last->msg_next = msghdr;
921 		msqptr->_msg_last = msghdr;
925 	msqptr->_msg_cbytes += msghdr->msg_ts;
960 	struct __msg *msghdr;
1005 	msghdr = NULL;
1006 	while (msghdr == NULL) {
1008 			msghdr = msqptr->_msg_first;
1009 			if (msghdr != NULL) {
1010 				if (msgsz < msghdr->msg_ts &&
1014 					    (long long)msgsz, msghdr->msg_ts));
1022 					msqptr->_msg_first = msghdr->msg_next;
1031 			     (msghdr = *prev) != NULL;
1032 			     previous = msghdr, prev = &msghdr->msg_next) {
1042 				if (msgtyp != msghdr->msg_type &&
1043 				    msghdr->msg_type > -msgtyp)
1047 				    msghdr->msg_type, msgtyp));
1048 				if (msgsz < msghdr->msg_ts &&
1052 					    (long long)msgsz, msghdr->msg_ts));
1056 				*prev = msghdr->msg_next;
1057 				if (msghdr != msqptr->_msg_last)
1072 		 * We've either extracted the msghdr for the appropriate
1076 		if (msghdr != NULL)
1134 	msqptr->_msg_cbytes -= msghdr->msg_ts;
1146 	    (long long)msgsz, msghdr->msg_ts));
1147 	if (msgsz > msghdr->msg_ts)
1148 		msgsz = msghdr->msg_ts;
1154 	error = (*put_type)(&msghdr->msg_type, user_msgp, typesz);
1158 		msg_freehdr(msghdr);
1168 	next = msghdr->msg_spot;
1185 			msg_freehdr(msghdr);
1197 	msg_freehdr(msghdr);