diff options
| author | toni <matzeton@googlemail.com> | 2015-11-16 01:18:11 +0100 |
|---|---|---|
| committer | toni <matzeton@googlemail.com> | 2015-11-16 01:22:08 +0100 |
| commit | dcf8b9b6981d0d21db6edb3265b56c55b39e4ff4 (patch) | |
| tree | 7816b8c94e304e585b2227aec67d0a94ea1ce855 /tests/mqtest.c | |
| parent | 7c3c6b99bec920ea850739e62b9fec8a29dc0dc0 (diff) | |
waitpid(...) checks now for WIFEXITED instead of WIFSIGNALED
Diffstat (limited to 'tests/mqtest.c')
| -rw-r--r-- | tests/mqtest.c | 23 |
1 files changed, 19 insertions, 4 deletions
diff --git a/tests/mqtest.c b/tests/mqtest.c index e9bc8e7..f2808c8 100644 --- a/tests/mqtest.c +++ b/tests/mqtest.c @@ -1,18 +1,22 @@ #include <stdio.h> #include <stdlib.h> +#include <unistd.h> #include <string.h> #include <fcntl.h> #include <sys/stat.h> +#include <sys/wait.h> #include <mqueue.h> #include <assert.h> static mqd_t mq_test; +static mqd_t mq_recv; 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; @@ -31,10 +35,10 @@ int main(int argc, char **argv) mq_unlink("/testmq"); assert( (mq_test = mq_open( "/testmq", O_NONBLOCK | O_CREAT | O_EXCL | O_RDWR, S_IRWXU | S_IRWXG, &m_attr )) != (mqd_t)-1 ); assert( mq_getattr(mq_test, &m_attr) == 0 ); - printf("flags.........: %ld\n" - "maxmsg........: %ld\n" - "msgsize.......: %ld\n" - "curmsg........: %ld\n", + printf("flags..........: %ld\n" + "maxmsg.........: %ld\n" + "msgsize........: %ld\n" + "curmsg.........: %ld\n", m_attr.mq_flags, m_attr.mq_maxmsg, m_attr.mq_msgsize, m_attr.mq_curmsgs); strcpy(buf, "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVQXYZ"); @@ -44,6 +48,17 @@ int main(int argc, char **argv) printf("SENT(%03lu bytes): %s\n", (long unsigned int) strlen(buf), buf); printf("RECV(%03lu bytes): %s\n", (long unsigned int) sz_recv, recv); + memset(recv, '\0', bufsiz); + if (fork() > 0) { + assert( (mq_recv = mq_open( "/testmq", O_RDONLY, S_IRWXU | S_IRWXG, &m_attr )) != (mqd_t)-1 ); + assert ( (sz_recv = mq_receive(mq_recv, recv, bufsiz, &prio)) > 0 ); + printf("RECV(%03lu bytes): %s\n", (long unsigned int) sz_recv, recv); + return 0; + } + printf("SENT(%03lu bytes): %s\n", (long unsigned int) strlen(buf), buf); + assert ( mq_send(mq_test, buf, bufsiz, 0) == 0 ); + wait(&c_stat); + return 0; } |