5 #include <sys/select.h>
15 #define MQNAME "/mytstqueue4"
19 void sighandler(int sig)
21 write(1, "timeout\n", 8);
38 attr.mq_msgsize = 128;
39 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);
42 status = mq_getattr(mq, &attr);
44 err(1, "mq_getattr()");
46 if (pid == 0) { /* child */
52 mq = mq_open(MQNAME, O_RDWR);
54 err(1, "child: mq_open");
55 EV_SET(&kev, __mq_oshandle(mq), EVFILT_READ, EV_ADD, 0, 0, 0);
56 status = kevent(kq, &kev, 1, NULL, 0, NULL);
58 err(1, "child: kevent");
59 buf = malloc(attr.mq_msgsize);
60 for (j = 0; j < LOOPS; ++j) {
62 status = kevent(kq, NULL, 0, &kev, 1, NULL);
64 err(1, "child: kevent 2");
65 status = mq_receive(mq, buf, attr.mq_msgsize, &prio);
67 err(2, "child: mq_receive");
68 for (i = 0; i < attr.mq_msgsize; ++i)
70 err(3, "child: message data corrupted");
72 err(4, "child: priority is incorrect: %d",
79 } else if (pid == -1) {
85 signal(SIGALRM, sighandler);
87 EV_SET(&kev, __mq_oshandle(mq), EVFILT_WRITE, EV_ADD, 0, 0, 0);
88 status = kevent(kq, &kev, 1, NULL, 0, NULL);
91 buf = malloc(attr.mq_msgsize);
92 for (j = 0; j < LOOPS; ++j) {
93 for (i = 0; i < attr.mq_msgsize; ++i) {
97 status = kevent(kq, NULL, 0, &kev, 1, NULL);
99 err(1, "child: kevent 2");
100 status = mq_send(mq, buf, attr.mq_msgsize, PRIO);
110 status = mq_close(mq);