Add heavily concurrent stress test

Author: Neil T. Dantam

.gitignore

@@ -130,3 +130,4 @@ modules.order
 /clocktest
 /holedigger
 /doc/man/man3
+/achstress

Makefile.am

@@ -104,6 +104,10 @@ noinst_PROGRAMS += holedigger
 holedigger_SOURCES = src/test/holedigger.c
 holedigger_LDADD = libach.la libachtest.la
 
+noinst_PROGRAMS += achstress
+achstress_SOURCES = src/test/achstress.c
+achstress_LDADD = libach.la libachtest.la
+
 robusttest_SOURCES = src/test/robusttest.c
 robusttest_LDADD = libach.la
 

TODO

@@ -1,14 +1,6 @@
 TODO list for Ach
 
 * TODO Return ACH_MISSED_FRAME from kernel-space
-* TODO Test message transmission under heavy concurrency
-  - Create c channels, p publishers, c subscribers, and i interrupters
-  - Publishers generate random messages, append a checksum, send to
-    all channels
-  - Subscribers get messages from all channels, and check the checksum
-    - Get messages via ach_get() next/last and poll()
-  - Interrupters randomly signal publishers and subscribers
-  - Test user, kernel, and anonymous channels
 * TODO Test for resource leaks
   - See kmemleak
   - open/close seem fine

include/achtest.h

@@ -76,3 +76,17 @@ void check_ach(const char *thing, ach_status_t r );
             exit(EXIT_FAILURE);                                         \
         }                                                               \
     }
+
+#define CHECK_ACH_MASK( thing,  allow_mask, exp )                       \
+{                                                                       \
+        enum ach_status check_ach_result = (exp);                       \
+        if( !( allow_mask & ACH_MASK_FROM_STATUS(check_ach_result)) )   \
+        {                                                               \
+            fprintf(stderr,                                             \
+                    "FAILURE:\t%s: %s, at %s:%d\n"                      \
+                    "expression:\t(" #exp ")\n",                        \
+                    thing, ach_result_to_string(check_ach_result),      \
+                    __FILE__, __LINE__ );                               \
+            exit(EXIT_FAILURE);                                         \
+        }                                                               \
+    }