send a message from A to B

diff --git a/src/cadet/test_cadeT.c b/src/cadet/test_cadeT.c
index 17db2418bc4dbb834dfad2cec7ee659ed28a266c..c939976b26cdb9067d0162591ce8e05e45cae36e 100644 (file)
--- 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 fc59349aaeffd39cdeff737466e3e0847ae7bdc7..e983dab12a9f0f12d6b52e80e53a3930f5c5aa29 100644 (file)
--- 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 7b92dc2cb3280e014f818749d65204bd791880c9..de1a24a26da473e9d8f51354ca4c98a69639d0b2 100644 (file)
--- 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.
  */