msgque 35 tools/testing/selftests/ipc/msgque.c int restore_queue(struct msgque_data *msgque) msgque 45 tools/testing/selftests/ipc/msgque.c sprintf(buf, "%d", msgque->msq_id); msgque 53 tools/testing/selftests/ipc/msgque.c id = msgget(msgque->key, msgque->mode | IPC_CREAT | IPC_EXCL); msgque 59 tools/testing/selftests/ipc/msgque.c if (id != msgque->msq_id) { msgque 61 tools/testing/selftests/ipc/msgque.c id, msgque->msq_id); msgque 66 tools/testing/selftests/ipc/msgque.c for (i = 0; i < msgque->qnum; i++) { msgque 67 tools/testing/selftests/ipc/msgque.c if (msgsnd(msgque->msq_id, &msgque->messages[i].mtype, msgque 68 tools/testing/selftests/ipc/msgque.c msgque->messages[i].msize, IPC_NOWAIT) != 0) { msgque 82 tools/testing/selftests/ipc/msgque.c int check_and_destroy_queue(struct msgque_data *msgque) msgque 88 tools/testing/selftests/ipc/msgque.c ret = msgrcv(msgque->msq_id, &message.mtype, MAX_MSG_SIZE, msgque 97 tools/testing/selftests/ipc/msgque.c if (ret != msgque->messages[cnt].msize) { msgque 99 tools/testing/selftests/ipc/msgque.c msgque->messages[cnt].msize); msgque 103 tools/testing/selftests/ipc/msgque.c if (message.mtype != msgque->messages[cnt].mtype) { msgque 108 tools/testing/selftests/ipc/msgque.c if (memcmp(message.mtext, msgque->messages[cnt].mtext, ret)) { msgque 116 tools/testing/selftests/ipc/msgque.c if (cnt != msgque->qnum) { msgque 124 tools/testing/selftests/ipc/msgque.c if (msgctl(msgque->msq_id, IPC_RMID, NULL)) { msgque 131 tools/testing/selftests/ipc/msgque.c int dump_queue(struct msgque_data *msgque) msgque 147 tools/testing/selftests/ipc/msgque.c if (ret == msgque->msq_id) msgque 151 tools/testing/selftests/ipc/msgque.c msgque->messages = malloc(sizeof(struct msg1) * ds.msg_qnum); msgque 152 tools/testing/selftests/ipc/msgque.c if (msgque->messages == NULL) { msgque 157 tools/testing/selftests/ipc/msgque.c msgque->qnum = ds.msg_qnum; msgque 158 tools/testing/selftests/ipc/msgque.c msgque->mode = ds.msg_perm.mode; msgque 159 tools/testing/selftests/ipc/msgque.c msgque->qbytes = ds.msg_qbytes; msgque 161 tools/testing/selftests/ipc/msgque.c for (i = 0; i < msgque->qnum; i++) { msgque 162 tools/testing/selftests/ipc/msgque.c ret = msgrcv(msgque->msq_id, &msgque->messages[i].mtype, msgque 168 tools/testing/selftests/ipc/msgque.c msgque->messages[i].msize = ret; msgque 173 tools/testing/selftests/ipc/msgque.c int fill_msgque(struct msgque_data *msgque) msgque 179 tools/testing/selftests/ipc/msgque.c if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(TEST_STRING), msgque 187 tools/testing/selftests/ipc/msgque.c if (msgsnd(msgque->msq_id, &msgbuf.mtype, sizeof(ANOTHER_TEST_STRING), msgque 198 tools/testing/selftests/ipc/msgque.c struct msgque_data msgque; msgque 204 tools/testing/selftests/ipc/msgque.c msgque.key = ftok(argv[0], 822155650); msgque 205 tools/testing/selftests/ipc/msgque.c if (msgque.key == -1) { msgque 210 tools/testing/selftests/ipc/msgque.c msgque.msq_id = msgget(msgque.key, IPC_CREAT | IPC_EXCL | 0666); msgque 211 tools/testing/selftests/ipc/msgque.c if (msgque.msq_id == -1) { msgque 217 tools/testing/selftests/ipc/msgque.c err = fill_msgque(&msgque); msgque 223 tools/testing/selftests/ipc/msgque.c err = dump_queue(&msgque); msgque 229 tools/testing/selftests/ipc/msgque.c err = check_and_destroy_queue(&msgque); msgque 235 tools/testing/selftests/ipc/msgque.c err = restore_queue(&msgque); msgque 241 tools/testing/selftests/ipc/msgque.c err = check_and_destroy_queue(&msgque); msgque 249 tools/testing/selftests/ipc/msgque.c if (msgctl(msgque.msq_id, IPC_RMID, NULL)) {