33 int restore_queue(struct msgque_data *msgque)  in restore_queue()  argument
43 	sprintf(buf, "%d", msgque->msq_id);  in restore_queue()
51 	id = msgget(msgque->key, msgque->mode | IPC_CREAT | IPC_EXCL);  in restore_queue()
57 	if (id != msgque->msq_id) {  in restore_queue()
59 							id, msgque->msq_id);  in restore_queue()
64 	for (i = 0; i < msgque->qnum; i++) {  in restore_queue()
65 		if (msgsnd(msgque->msq_id, &msgque->messages[i].mtype,  in restore_queue()
66 			   msgque->messages[i].msize, IPC_NOWAIT) != 0) {  in restore_queue()
80 int check_and_destroy_queue(struct msgque_data *msgque)  in check_and_destroy_queue()  argument
86 		ret = msgrcv(msgque->msq_id, &message.mtype, MAX_MSG_SIZE,  in check_and_destroy_queue()
95 		if (ret != msgque->messages[cnt].msize) {  in check_and_destroy_queue()
97 						msgque->messages[cnt].msize);  in check_and_destroy_queue()
101 		if (message.mtype != msgque->messages[cnt].mtype) {  in check_and_destroy_queue()
106 		if (memcmp(message.mtext, msgque->messages[cnt].mtext, ret)) {  in check_and_destroy_queue()
114 	if (cnt != msgque->qnum) {  in check_and_destroy_queue()
122 	if (msgctl(msgque->msq_id, IPC_RMID, 0)) {  in check_and_destroy_queue()
129 int dump_queue(struct msgque_data *msgque)  in dump_queue()  argument
145 		if (ret == msgque->msq_id)  in dump_queue()
149 	msgque->messages = malloc(sizeof(struct msg1) * ds.msg_qnum);  in dump_queue()
150 	if (msgque->messages == NULL) {  in dump_queue()
155 	msgque->qnum = ds.msg_qnum;  in dump_queue()
156 	msgque->mode = ds.msg_perm.mode;  in dump_queue()
157 	msgque->qbytes = ds.msg_qbytes;  in dump_queue()
159 	for (i = 0; i < msgque->qnum; i++) {  in dump_queue()
160 		ret = msgrcv(msgque->msq_id, &msgque->messages[i].mtype,  in dump_queue()
166 		msgque->messages[i].msize = ret;  in dump_queue()
171 int fill_msgque(struct msgque_data *msgque)  in fill_msgque()  argument
177 	if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(TEST_STRING),  in fill_msgque()
185 	if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(ANOTHER_TEST_STRING),  in fill_msgque()
196 	struct msgque_data msgque;  in main()  local
203 	msgque.key = ftok(argv[0], 822155650);  in main()
204 	if (msgque.key == -1) {  in main()
209 	msgque.msq_id = msgget(msgque.key, IPC_CREAT | IPC_EXCL | 0666);  in main()
210 	if (msgque.msq_id == -1) {  in main()
216 	err = fill_msgque(&msgque);  in main()
222 	err = dump_queue(&msgque);  in main()
228 	err = check_and_destroy_queue(&msgque);  in main()
234 	err = restore_queue(&msgque);  in main()
240 	err = check_and_destroy_queue(&msgque);  in main()
248 	if (msgctl(msgque.msq_id, IPC_RMID, 0)) {  in main()