refactor DHT for new service API

[oweals/gnunet.git] / src / core / test_core_api_reliability.c

diff --git a/src/core/test_core_api_reliability.c b/src/core/test_core_api_reliability.c
index d7d4a6bd6d729556fef83b196b3611b7f84de7dd..cd2bcad83639cf9d8acaa95e8ba6eb0741271237 100644 (file)
--- a/src/core/test_core_api_reliability.c
+++ b/src/core/test_core_api_reliability.c
@@ -159,7 +159,7 @@ do_shutdown (void *cls)
   }
   terminate_peer (&p1);
   terminate_peer (&p2);
-  
+
 }
 
 
@@ -313,7 +313,7 @@ handle_test (void *cls,
     {
       send_message (p1.mq,
                    tr_n);
-    }  
+    }
   }
 }
 
@@ -322,12 +322,12 @@ static void
 init_notify (void *cls,
              const struct GNUNET_PeerIdentity *my_identity)
 {
-  GNUNET_MQ_hd_var_size (test,
-                        MTYPE,
-                        struct TestMessage);
   struct PeerContext *p = cls;
   struct GNUNET_MQ_MessageHandler handlers[] = {
-    make_test_handler (NULL),
+    GNUNET_MQ_hd_var_size (test,
+                           MTYPE,
+                           struct TestMessage,
+                           NULL),
     GNUNET_MQ_handler_end ()
   };
 
@@ -442,11 +442,11 @@ run (void *cls,
      const char *cfgfile,
      const struct GNUNET_CONFIGURATION_Handle *cfg)
 {
-  GNUNET_MQ_hd_fixed_size (test,
-                          MTYPE,
-                          struct TestMessage);
   struct GNUNET_MQ_MessageHandler handlers[] = {
-    make_test_handler (NULL),
+    GNUNET_MQ_hd_fixed_size (test,
+                             MTYPE,
+                             struct TestMessage,
+                             NULL),
     GNUNET_MQ_handler_end ()
   };