netbsd-tests/kernel/t_mqueue.c

22 send_msgs(mqd_t mqfd)
29 	ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE) != -1,
33 	ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE + 1) != -1,
37 	ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE) != -1,
41 	ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE - 1) != -1,
45 	ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), 0) != -1,
49 	ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE + 1) != -1,
54 receive_msgs(mqd_t mqfd)
61 	ATF_REQUIRE_MSG(mq_getattr(mqfd, &mqa) != -1, "mq_getattr failed %d",
68 	ATF_REQUIRE_MSG(mq_receive(mqfd, m, len, &p) != -1,
73 	ATF_REQUIRE_MSG(mq_receive(mqfd, m, len, &p) != -1,
78 	ATF_REQUIRE_MSG(mq_receive(mqfd, m, len, &p) != -1,
83 	ATF_REQUIRE_MSG(mq_receive(mqfd, m, len, &p) != -1,
88 	ATF_REQUIRE_MSG(mq_receive(mqfd, m, len, &p) != -1,
93 	ATF_REQUIRE_MSG(mq_receive(mqfd, m, len, &p) != -1,
119 	mqd_t mqfd;
121 	mqfd = mq_open(mq_name, O_RDWR | O_CREAT,
123 	ATF_REQUIRE_MSG(mqfd != -1, "mq_open failed: %d", errno);
125 	send_msgs(mqfd);
126 	receive_msgs(mqfd);
128 	status = mq_close(mqfd);