bsd/kern/sysv_msg.c

120 struct msginfo msginfo = {
226 	 * msginfo.msgssz should be a power of two for efficiency reasons.
227 	 * It is also pretty silly if msginfo.msgssz is less than 8
231 	while (i < 1024 && i != msginfo.msgssz)
233     	if (i != msginfo.msgssz) {
234 		printf("msginfo.msgssz=%d (0x%x) not a small power of 2; resetting to %d\n", msginfo.msgssz, msginfo.msgssz, MSGSSZ);
235 		msginfo.msgssz = MSGSSZ;
238 	if (msginfo.msgseg > 32767) {
239 		printf("msginfo.msgseg=%d (> 32767); resetting to %d\n", msginfo.msgseg, MSGSEG);
240 		msginfo.msgseg = MSGSEG;
249 	msgpool = (char *)_MALLOC(msginfo.msgmax, M_SHM, M_WAITOK);
255 			sizeof(struct msgmap) * msginfo.msgseg,
263 			sizeof(struct msg) * msginfo.msgtql,
271 			sizeof(struct user_msqid_ds) * msginfo.msgmni,
280 	for (i = 0; i < msginfo.msgseg; i++) {
286 	nfree_msgmaps = msginfo.msgseg;
290 	for (i = 0; i < msginfo.msgtql; i++) {
302 	for (i = 0; i < msginfo.msgmni; i++) {
361 		if (msghdr->msg_spot < 0 || msghdr->msg_spot >= msginfo.msgseg)
368 		if (msghdr->msg_ts >= msginfo.msgssz)
369 			msghdr->msg_ts -= msginfo.msgssz;
412 	if (msqid < 0 || msqid >= msginfo.msgmni) {
415 		    msginfo.msgmni);
529 		if (msqbuf.msg_qbytes > (user_msglen_t)msginfo.msgmnb) {
532 			    msginfo.msgmnb);
534 			msqbuf.msg_qbytes = msginfo.msgmnb;	/* silently restrict qbytes to system limit */
608 		for (msqid = 0; msqid < msginfo.msgmni; msqid++) {
614 		if (msqid < msginfo.msgmni) {
645 		for (msqid = 0; msqid < msginfo.msgmni; msqid++) {
657 		if (msqid == msginfo.msgmni) {
679 		msqptr->u.msg_qbytes = msginfo.msgmnb;
743 	if (msqid < 0 || msqid >= msginfo.msgmni) {
746 		    msginfo.msgmni);
780 	segs_needed = (msgsz + msginfo.msgssz - 1) / msginfo.msgssz;
782 	printf("msgsz=%ld, msgssz=%d, segs_needed=%d\n", msgsz, msginfo.msgssz,
959 		if (next >= msginfo.msgseg)
1022 		if (msgsz > (size_t)msginfo.msgssz)
1023 			tlen = msginfo.msgssz;
1028 		if (next >= msginfo.msgseg)
1032 		eval = copyin(user_msgp, &msgpool[next * msginfo.msgssz], tlen);
1160 	if (msqid < 0 || msqid >= msginfo.msgmni) {
1163 		    msginfo.msgmni);
1419 	for (len = 0; len < msgsz; len += msginfo.msgssz) {
1423 		if (msgsz > (size_t)msginfo.msgssz)
1424 			tlen = msginfo.msgssz;
1429 		if (next >= msginfo.msgseg)
1432 		eval = copyout(&msgpool[next * msginfo.msgssz],
1503 		if (ipcs.u64.ipcs_datalen != sizeof(struct msginfo)) {
1512 		error = copyout(&msginfo, ipcs.u64.ipcs_data, ipcs.u64.ipcs_datalen);
1524 		if (cursor < 0 || cursor >= msginfo.msgmni) {
1532 		for( ; cursor < msginfo.msgmni; cursor++) {
1537 		if (cursor == msginfo.msgmni) {