diff options
author | toni <matzeton@googlemail.com> | 2016-07-04 15:36:07 +0200 |
---|---|---|
committer | toni <matzeton@googlemail.com> | 2016-07-04 15:36:07 +0200 |
commit | cb6047b694a86f78723a613819677227f14e30c3 (patch) | |
tree | 4eb9c2f2339c5185fec81447bd832d4d4f0bd3d0 /src/check/check.c | |
parent | 7248ec097b19828e047e83df89aa7bac4150c2cd (diff) | |
parent | bc30ed7f5624f7d5ccc1e9937ed7bcb7faae9892 (diff) |
Merge branch 'master' into jessie
Conflicts:
main.c
Diffstat (limited to 'src/check/check.c')
-rw-r--r-- | src/check/check.c | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/src/check/check.c b/src/check/check.c new file mode 100644 index 0000000..9d28129 --- /dev/null +++ b/src/check/check.c @@ -0,0 +1,65 @@ +#include <stdlib.h> +#include <unistd.h> +#include <string.h> +#include <fcntl.h> +#include <sys/stat.h> +#include <sys/wait.h> +#include <semaphore.h> +#include <mqueue.h> + + +#define myassert(x, emask) if ((x)) { ret &= ret; } else { ret |= emask; } + +static volatile unsigned long long int ret = 0x0; +static mqd_t mq_test; +static mqd_t mq_recv; +static sem_t *sp_test; +static const size_t bufsiz = 256; + +int main(int argc, char **argv) +{ + int c_stat; + struct mq_attr m_attr; + char buf[bufsiz], recv[bufsiz]; + unsigned int prio; + ssize_t sz_recv; + + memset(buf, '\0', bufsiz); + memset(recv, '\0', bufsiz); + if (argc > 1) + strncpy(buf, argv[1], bufsiz-1); + + m_attr.mq_flags = 0; + m_attr.mq_msgsize = bufsiz; + m_attr.mq_maxmsg = 10; + m_attr.mq_curmsgs = 0; + + mq_unlink("/testmq"); + myassert( (mq_test = mq_open( "/testmq", O_NONBLOCK | O_CREAT | O_EXCL | O_RDWR, S_IRWXU | S_IRWXG, &m_attr )) != (mqd_t)-1, 0x1 ); + myassert( mq_getattr(mq_test, &m_attr) == 0, 0x2 ); + + strcpy(buf, "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVQXYZ"); + myassert( mq_send(mq_test, buf, bufsiz, 0) == 0, 0x4 ); + myassert( (sz_recv = mq_receive(mq_test, recv, bufsiz, &prio)) > 0, 0x8 ); + + memset(recv, '\0', bufsiz); + if (fork() > 0) { + myassert( (mq_recv = mq_open( "/testmq", O_RDONLY, S_IRWXU | S_IRWXG, &m_attr )) != (mqd_t)-1, 0x10 ); + myassert( (sz_recv = mq_receive(mq_recv, recv, bufsiz, &prio)) > 0, 0x20 ); + return ret; + } + myassert( mq_send(mq_test, buf, bufsiz, 0) == 0, 0x40 ); + wait(&c_stat); + myassert( c_stat == 0xFF, 0x80 ); + myassert( mq_close(mq_test) == 0, 0x100 ); + myassert( mq_unlink("/testmq") == 0, 0x200 ); + + myassert( sem_unlink("/testsem") == 0, 0x400 ); + myassert( (sp_test = sem_open("/testsem", O_CREAT | O_EXCL, S_IRUSR | S_IWUSR, 0)), 0x800 ); + myassert( sem_post(sp_test) == 0, 0x1000 ); + myassert( sem_wait(sp_test) == 0, 0x1200 ); + myassert( sem_close(sp_test) == 0, 0x1400 ); + myassert( sem_unlink("/testsem") == 0, 0x1800 ); + + return ret; +} |