version 1.3, 2012/11/06 19:35:38 |
version 1.4, 2014/03/02 19:56:48 |
|
|
|
|
#include <mqueue.h> |
#include <mqueue.h> |
|
|
char *tmpdir; |
|
|
|
#define MQ_PRIO_BASE 24 |
#define MQ_PRIO_BASE 24 |
|
|
static void |
static void |
Line 98 receive_msgs(mqd_t mqfd) |
|
Line 96 receive_msgs(mqd_t mqfd) |
|
"mq_receive 6 prio/data mismatch"); |
"mq_receive 6 prio/data mismatch"); |
} |
} |
|
|
ATF_TC_WITH_CLEANUP(mqueue); |
ATF_TC(mqueue); |
ATF_TC_HEAD(mqueue, tc) |
ATF_TC_HEAD(mqueue, tc) |
{ |
{ |
|
|
Line 109 ATF_TC_HEAD(mqueue, tc) |
|
Line 107 ATF_TC_HEAD(mqueue, tc) |
|
ATF_TC_BODY(mqueue, tc) |
ATF_TC_BODY(mqueue, tc) |
{ |
{ |
int status; |
int status; |
|
char *tmpdir; |
char template[32]; |
char template[32]; |
char mq_name[64]; |
char mq_name[64]; |
|
|
Line 130 ATF_TC_BODY(mqueue, tc) |
|
Line 129 ATF_TC_BODY(mqueue, tc) |
|
ATF_REQUIRE_MSG(status == 0, "mq_close failed: %d", errno); |
ATF_REQUIRE_MSG(status == 0, "mq_close failed: %d", errno); |
} |
} |
|
|
ATF_TC_CLEANUP(mqueue, tc) |
|
{ |
|
int status; |
|
|
|
if (tmpdir != NULL) { |
|
status = rmdir(tmpdir); |
|
ATF_REQUIRE_MSG(status == 0, "rmdir failed: %d", errno); |
|
} |
|
} |
|
|
|
ATF_TP_ADD_TCS(tp) |
ATF_TP_ADD_TCS(tp) |
{ |
{ |
ATF_TP_ADD_TC(tp, mqueue); |
ATF_TP_ADD_TC(tp, mqueue); |