aboutsummaryrefslogtreecommitdiff
path: root/src/check/check.c
diff options
context:
space:
mode:
authortoni <matzeton@googlemail.com>2016-07-04 15:36:07 +0200
committertoni <matzeton@googlemail.com>2016-07-04 15:36:07 +0200
commitcb6047b694a86f78723a613819677227f14e30c3 (patch)
tree4eb9c2f2339c5185fec81447bd832d4d4f0bd3d0 /src/check/check.c
parent7248ec097b19828e047e83df89aa7bac4150c2cd (diff)
parentbc30ed7f5624f7d5ccc1e9937ed7bcb7faae9892 (diff)
Merge branch 'master' into jessie
Conflicts: main.c
Diffstat (limited to 'src/check/check.c')
-rw-r--r--src/check/check.c65
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;
+}