Add meshlink_set_channel_listen_cb().

[meshlink] / test / echo-fork.c

diff --git a/test/echo-fork.c b/test/echo-fork.c
index aae7531f554a4d847043c40a4050a42cefbf3410..33966da16645043e712c99ff9a22d98966e55048 100644 (file)
--- a/test/echo-fork.c
+++ b/test/echo-fork.c
@@ -1,4 +1,9 @@
 #define _GNU_SOURCE
+
+#ifdef NDEBUG
+#undef NDEBUG
+#endif
+
 #include <stdio.h>
 #include <unistd.h>
 #include <stdlib.h>
@@ -45,16 +50,6 @@ static void b_receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, c
        assert(write(1, data, len) == (ssize_t)len);
 }
 
-static bool reject_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) {
-       (void)mesh;
-       (void)channel;
-       (void)port;
-       (void)data;
-       (void)len;
-
-       return false;
-}
-
 static bool accept_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) {
        if(port != 7) {
                return false;
@@ -84,8 +79,6 @@ static int main1(void) {
        meshlink_handle_t *mesh = meshlink_open("echo-fork_conf.1", "a", "echo-fork", DEV_CLASS_BACKBONE);
        assert(mesh);
 
-       meshlink_set_channel_accept_cb(mesh, reject_cb);
-
        assert(meshlink_start(mesh));
 
        // Open a channel.
@@ -169,7 +162,11 @@ static int main2(void) {
 }
 
 
-int main() {
+int main(void) {
+       init_sync_flag(&a_started);
+       init_sync_flag(&a_stopped);
+       init_sync_flag(&b_responded);
+
        meshlink_set_log_cb(NULL, MESHLINK_WARNING, log_cb);
 
        // Initialize and exchange configuration.