Lines Matching defs:mqfd
27 send_msgs(mqd_t mqfd)
34 ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE) != -1,
38 ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE + 1) != -1,
42 ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE) != -1,
46 ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE - 1) != -1,
50 ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), 0) != -1,
54 ATF_REQUIRE_MSG(mq_send(mqfd, msg, sizeof(msg), MQ_PRIO_BASE + 1) != -1,
59 receive_msgs(mqd_t mqfd)
66 ATF_REQUIRE_MSG(mq_getattr(mqfd, &mqa) != -1, "mq_getattr failed %d",
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,
98 ATF_REQUIRE_MSG(mq_receive(mqfd, m, len, &p) != -1,
132 mqd_t mqfd;
134 mqfd = mq_open(mq_name, O_RDWR | O_CREAT,
137 ATF_REQUIRE_MSG(mqfd != (mqd_t)-1, "mq_open failed: %d", errno);
139 ATF_REQUIRE_MSG(mqfd != -1, "mq_open failed: %d", errno);
142 send_msgs(mqfd);
143 receive_msgs(mqfd);
145 status = mq_close(mqfd);