From 3abd69eb010eab9c5c218e0f5df14d46386758eb Mon Sep 17 00:00:00 2001
From: xrs <xrs@mail36.net>
Date: Wed, 18 Mar 2020 21:17:43 +0100
Subject: send a message from A to B

---
 src/cadet/test_cadeT.c      | 14 ++++++++++++++
 src/cadet/test_cadeT_util.c | 18 ++++++++++++++++--
 src/cadet/test_cadeT_util.h |  2 ++
 3 files changed, 32 insertions(+), 2 deletions(-)

diff --git a/src/cadet/test_cadeT.c b/src/cadet/test_cadeT.c
index 17db2418b..c939976b2 100644
--- a/src/cadet/test_cadeT.c
+++ b/src/cadet/test_cadeT.c
@@ -61,9 +61,23 @@
 
 static int kx_initiator;
 
+void
+handle_message ()
+{
+  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "%s\n", __func__);
+}
+
 static void
 send_message ()
 {
+  struct GNUNET_MQ_Envelope *envelope;
+  struct GNUNET_MessageHeader *msg;
+
+  GNUNET_log (GNUNET_ERROR_TYPE_INFO, "%s\n", __func__);
+
+  envelope = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_DUMMY);
+
+  GNUNET_MQ_send (GNUNET_CADET_get_mq (test_peers[0].channel), envelope);
 }
 
 /**
diff --git a/src/cadet/test_cadeT_util.c b/src/cadet/test_cadeT_util.c
index fc59349aa..e983dab12 100644
--- a/src/cadet/test_cadeT_util.c
+++ b/src/cadet/test_cadeT_util.c
@@ -91,6 +91,13 @@ setup_initiating_peer (void *cls,
 {
   struct GNUNET_CADET_Handle *cadet;
   struct GNUNET_CADET_Channel *channel;
+  struct GNUNET_MQ_MessageHandler msg_handlers[] = {
+    GNUNET_MQ_hd_fixed_size (message,
+                             GNUNET_MESSAGE_TYPE_DUMMY,
+                             struct GNUNET_MessageHeader,
+                             NULL),
+    GNUNET_MQ_handler_end ()
+  };
 
   GNUNET_log (GNUNET_ERROR_TYPE_INFO, "%s\n", __func__);
 
@@ -106,7 +113,7 @@ setup_initiating_peer (void *cls,
                                          &hashed_portname,
                                          NULL,
                                          &disconnect_channel,
-                                         NULL);
+                                         msg_handlers);
   test_peers[0].channel = channel;
 
   return cadet;
@@ -132,6 +139,13 @@ setup_listening_peer (void *cls,
 {
   struct GNUNET_CADET_Handle *cadet;
   struct GNUNET_CADET_Port *port;
+  struct GNUNET_MQ_MessageHandler msg_handlers[] = {
+    GNUNET_MQ_hd_fixed_size (message,
+                             GNUNET_MESSAGE_TYPE_DUMMY,
+                             struct GNUNET_MessageHeader,
+                             NULL),
+    GNUNET_MQ_handler_end ()
+  };
 
   GNUNET_log (GNUNET_ERROR_TYPE_INFO, "%s\n", __func__);
   
@@ -147,7 +161,7 @@ setup_listening_peer (void *cls,
                                  NULL,
                                  NULL,
                                  &handle_port_disconnects,
-                                 NULL);
+                                 msg_handlers);
 
   return cadet;
 }
diff --git a/src/cadet/test_cadeT_util.h b/src/cadet/test_cadeT_util.h
index 7b92dc2cb..de1a24a26 100644
--- a/src/cadet/test_cadeT_util.h
+++ b/src/cadet/test_cadeT_util.h
@@ -37,6 +37,8 @@ void prepare_test ();
 
 void run_test ();
 
+void handle_message ();
+
 /**
  * Structure for storing information of testbed peers.
  */
-- 
cgit v1.2.3