-fix queueing issue

diff --git a/src/core/core_api.c b/src/core/core_api.c
index 451b871fb2fbdeb45e253d0f5b5e480dcc793ae5..4c55d0e5f42c8b03308466d6c385d99ce71f2f90 100644 (file)
--- a/src/core/core_api.c
+++ b/src/core/core_api.c
@@ -332,6 +332,9 @@ handle_mq_error (void *cls,
 {
   struct GNUNET_CORE_Handle *h = cls;
 
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+              "MQ ERROR: %d\n",
+              error);
   reconnect_later (h);
 }
 
@@ -707,12 +710,13 @@ handle_send_ready (void *cls,
   sm->peer = pr->peer;
   sm->cork = htonl ((uint32_t) th->cork);
   sm->reserved = htonl (0);
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+              "Calling get_message with buffer of %u bytes\n",
+              (unsigned int) th->msize);
   ret = th->get_message (th->get_message_cls,
                          th->msize,
                          &sm[1]);
   sm->header.size = htons (ret + sizeof (struct SendMessage));
-  th->msize = ret;
-  // GNUNET_assert (ret == th->msize); /* NOTE: API change! */
   delay = GNUNET_TIME_absolute_get_duration (th->request_time);
   overdue = GNUNET_TIME_absolute_get_duration (th->deadline);
   if (overdue.rel_value_us > GNUNET_CONSTANTS_LATENCY_WARN.rel_value_us)
@@ -887,6 +891,11 @@ GNUNET_CORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg,
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Connecting to CORE service\n");
   reconnect (h);
+  if (NULL == h->mq)
+  {
+    GNUNET_CORE_disconnect (h);
+    return NULL;
+  }
   return h;
 }
 

diff --git a/src/core/test_core_api_data.conf b/src/core/test_core_api_data.conf
index a13cc87064c6efb11ff813a0061ad029b72e613e..53f864bddec3765c8a9387377bbaddccea1a291e 100644 (file)
--- a/src/core/test_core_api_data.conf
+++ b/src/core/test_core_api_data.conf
@@ -8,4 +8,3 @@ WAN_QUOTA_OUT = 64 kiB
 [core]
 PORT = 2092
 UNIXPATH = $GNUNET_RUNTIME_DIR/gnunet-service-core.sock
-