selftests/ipc/msgque.c

35 int restore_queue(struct msgque_data *msgque)
45 	sprintf(buf, "%d", msgque->msq_id);
53 	id = msgget(msgque->key, msgque->mode | IPC_CREAT | IPC_EXCL);
59 	if (id != msgque->msq_id) {
61 								, id, msgque->msq_id);
66 	for (i = 0; i < msgque->qnum; i++) {
67 		if (msgsnd(msgque->msq_id, &msgque->messages[i].mtype,
68 			   msgque->messages[i].msize, IPC_NOWAIT) != 0) {
82 int check_and_destroy_queue(struct msgque_data *msgque)
88 		ret = msgrcv(msgque->msq_id, &message.mtype, MAX_MSG_SIZE,
97 		if (ret != msgque->messages[cnt].msize) {
98 			ksft_test_result_fail("Wrong message size: %d (expected %d)\n", ret, msgque->messages[cnt].msize);
102 		if (message.mtype != msgque->messages[cnt].mtype) {
107 		if (memcmp(message.mtext, msgque->messages[cnt].mtext, ret)) {
115 	if (cnt != msgque->qnum) {
123 	if (msgctl(msgque->msq_id, IPC_RMID, NULL)) {
130 int dump_queue(struct msgque_data *msgque)
146 		if (ret == msgque->msq_id)
150 	msgque->messages = malloc(sizeof(struct msg1) * ds.msg_qnum);
151 	if (msgque->messages == NULL) {
156 	msgque->qnum = ds.msg_qnum;
157 	msgque->mode = ds.msg_perm.mode;
158 	msgque->qbytes = ds.msg_qbytes;
160 	for (i = 0; i < msgque->qnum; i++) {
161 		ret = msgrcv(msgque->msq_id, &msgque->messages[i].mtype,
167 		msgque->messages[i].msize = ret;
172 int fill_msgque(struct msgque_data *msgque)
178 	if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(TEST_STRING),
186 	if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(ANOTHER_TEST_STRING),
197 	struct msgque_data msgque;
202 	msgque.key = ftok(argv[0], 822155650);
203 	if (msgque.key == -1) {
208 	msgque.msq_id = msgget(msgque.key, IPC_CREAT | IPC_EXCL | 0666);
209 	if (msgque.msq_id == -1) {
215 	err = fill_msgque(&msgque);
221 	err = dump_queue(&msgque);
227 	err = check_and_destroy_queue(&msgque);
233 	err = restore_queue(&msgque);
239 	err = check_and_destroy_queue(&msgque);
247 	if (msgctl(msgque.msq_id, IPC_RMID, NULL)) {