13 #include "freebsd_test_suite/macros.h"
15 #define MQNAME "/mytstqueue2"
20 alarmhandler(int sig __unused)
22 write(1, "timeout\n", 8);
34 PLAIN_REQUIRE_KERNEL_MODULE("mqueuefs", 0);
39 attr.mq_msgsize = 128;
40 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);
43 status = mq_getattr(mq, &attr);
47 if (pid == 0) { /* child */
54 signal(SIGALRM, alarmhandler);
56 mq = mq_open(MQNAME, O_RDWR);
58 err(1, "child: mq_open");
59 buf = malloc(attr.mq_msgsize);
60 for (j = 0; j < LOOPS; ++j) {
62 status = mq_receive(mq, buf, attr.mq_msgsize, &prio);
64 err(2, "child: mq_receive");
65 for (i = 0; i < attr.mq_msgsize; ++i)
67 err(3, "child: message data corrupted");
69 err(4, "child: priority is incorrect: %d",
76 } else if (pid == -1) {
82 signal(SIGALRM, alarmhandler);
83 buf = malloc(attr.mq_msgsize);
84 for (j = 0; j < LOOPS; ++j) {
85 for (i = 0; i < attr.mq_msgsize; ++i)
88 status = mq_send(mq, buf, attr.mq_msgsize, PRIO);
96 status = mq_close(mq);