Update plibc header
[oweals/gnunet.git] / src / util / test_mq_client.c
index b7eb1516ac45b00051d8bf379915c27c20cc918d..4e460ebdb565b2bd918239efefbc1cfa0d9e4e82 100644 (file)
@@ -23,7 +23,6 @@
  * @brief tests for mq with connection client
  */
 #include "platform.h"
-#include "gnunet_common.h"
 #include "gnunet_util_lib.h"
 
 #define PORT 23336
@@ -49,17 +48,15 @@ recv_cb (void *cls, struct GNUNET_SERVER_Client *argclient,
          const struct GNUNET_MessageHeader *message)
 {
   received++;
-
-  printf ("received\n");
-
-
   if ((received == 2) && (GNUNET_YES == notify))
   {
-    printf ("done\n");
     GNUNET_SERVER_receive_done (argclient, GNUNET_NO);
     return;
   }
 
+  /* can happen if notify does not work */
+  GNUNET_assert (received < 2);
+
   GNUNET_SERVER_receive_done (argclient, GNUNET_YES);
 }
 
@@ -98,17 +95,18 @@ static struct GNUNET_SERVER_MessageHandler handlers[] = {
 
 void send_cb (void *cls)
 {
-  printf ("notify sent\n");
+  /* the notify should only be called once */
+  GNUNET_assert (GNUNET_NO == notify);
   notify = GNUNET_YES;
 }
 
 void test_mq (struct GNUNET_CLIENT_Connection *client)
 {
-  struct GNUNET_MQ_MessageQueue *mq;
-  struct GNUNET_MQ_Message *mqm;
+  struct GNUNET_MQ_Handle *mq;
+  struct GNUNET_MQ_Envelope *mqm;
 
   /* FIXME: test handling responses */
-  mq = GNUNET_MQ_queue_for_connection_client (client, NULL, NULL);
+  mq = GNUNET_MQ_queue_for_connection_client (client, NULL, NULL, NULL);
 
   mqm = GNUNET_MQ_msg_header (MY_TYPE);
   GNUNET_MQ_send (mq, mqm);