- start test only after warmup
[oweals/gnunet.git] / src / mesh / gnunet-service-mesh_peer.c
index e7697f0f50a269d575b334ef928e743c7f416b8b..05b924edadcf52058177cf87cc7fe6f400d208b0 100644 (file)
@@ -207,9 +207,11 @@ static unsigned long long drop_percent;
  */
 static struct GNUNET_CORE_Handle *core_handle;
 
+/**
+ * Handle to try to start new connections.
+ */
 static struct GNUNET_TRANSPORT_Handle *transport_handle;
 
-
 /******************************************************************************/
 /***************************** CORE CALLBACKS *********************************/
 /******************************************************************************/
@@ -287,7 +289,7 @@ core_connect (void *cls, const struct GNUNET_PeerIdentity *peer)
   }
   else
   {
-    LOG (GNUNET_ERROR_TYPE_DEBUG, "CONNECTED %s <= %s\n",
+    LOG (GNUNET_ERROR_TYPE_INFO, "CONNECTED %s <= %s\n",
          own_id, GNUNET_i2s (peer));
     path = path_new (2);
     path->peers[1] = mp->id;
@@ -774,8 +776,8 @@ queue_is_sendable (struct MeshPeerQueue *q)
       GNUNET_break (0);
   }
 
-  if (GMC_is_sendable (q->c, q->fwd))
-    return GNUNET_YES;
+  if (GNUNET_MESSAGE_TYPE_MESH_CONNECTION_BROKEN != q->type)
+    return GMC_is_sendable (q->c, q->fwd);
 
   return GNUNET_NO;
 }
@@ -897,7 +899,6 @@ queue_send (void *cls, size_t size, void *buf)
   {
     case GNUNET_MESSAGE_TYPE_MESH_CONNECTION_DESTROY:
     case GNUNET_MESSAGE_TYPE_MESH_CONNECTION_BROKEN:
-    case GNUNET_MESSAGE_TYPE_MESH_KEEPALIVE:
     case GNUNET_MESSAGE_TYPE_MESH_ENCRYPTED:
     case GNUNET_MESSAGE_TYPE_MESH_KX:
     case GNUNET_MESSAGE_TYPE_MESH_ACK:
@@ -1219,6 +1220,50 @@ connection_get_first_message (struct MeshPeer *peer, struct MeshConnection *c)
 }
 
 
+/**
+ * Get the first message for a connection and unqueue it.
+ *
+ * @param peer Neighboring peer.
+ * @param c Connection.
+ *
+ * @return First message for this connection.
+ */
+struct GNUNET_MessageHeader *
+GMP_connection_pop (struct MeshPeer *peer, struct MeshConnection *c)
+{
+  struct MeshPeerQueue *q;
+  struct GNUNET_MessageHeader *msg;
+
+  for (q = peer->queue_head; NULL != q; q = q->next)
+  {
+    if (q->c != c)
+      continue;
+    switch (q->type)
+    {
+      case GNUNET_MESSAGE_TYPE_MESH_CONNECTION_CREATE:
+      case GNUNET_MESSAGE_TYPE_MESH_CONNECTION_ACK:
+      case GNUNET_MESSAGE_TYPE_MESH_CONNECTION_DESTROY:
+      case GNUNET_MESSAGE_TYPE_MESH_CONNECTION_BROKEN:
+      case GNUNET_MESSAGE_TYPE_MESH_ACK:
+      case GNUNET_MESSAGE_TYPE_MESH_POLL:
+        GMP_queue_destroy (q, GNUNET_YES);
+        continue;
+
+      case GNUNET_MESSAGE_TYPE_MESH_KX:
+      case GNUNET_MESSAGE_TYPE_MESH_ENCRYPTED:
+        msg = (struct GNUNET_MessageHeader *) q->cls;
+        GMP_queue_destroy (q, GNUNET_NO);
+        return msg;
+
+      default:
+        GNUNET_break (0);
+    }
+  }
+
+  return NULL;
+}
+
+
 void
 GMP_queue_unlock (struct MeshPeer *peer, struct MeshConnection *c)
 {
@@ -1277,12 +1322,11 @@ GMP_init (const struct GNUNET_CONFIGURATION_Handle *c)
   }
   else
   {
-    LOG (GNUNET_ERROR_TYPE_WARNING,
-                "\n***************************************\n"
-                "Mesh is running with drop mode enabled.\n"
-                "This is NOT a good idea!\n"
-                "Remove the DROP_PERCENT option from your configuration.\n"
-                "***************************************\n");
+    LOG (GNUNET_ERROR_TYPE_WARNING, "**************************************\n");
+    LOG (GNUNET_ERROR_TYPE_WARNING, "Mesh is running with DROP enabled.\n");
+    LOG (GNUNET_ERROR_TYPE_WARNING, "This is NOT a good idea!\n");
+    LOG (GNUNET_ERROR_TYPE_WARNING, "Remove DROP_PERCENT from config file.\n");
+    LOG (GNUNET_ERROR_TYPE_WARNING, "**************************************\n");
   }
 
   core_handle = GNUNET_CORE_connect (c, /* Main configuration */
@@ -1295,11 +1339,24 @@ GMP_init (const struct GNUNET_CONFIGURATION_Handle *c)
                                      NULL,      /* Don't notify about all outbound messages */
                                      GNUNET_NO, /* For header-only out notification */
                                      core_handlers);    /* Register these handlers */
-  transport_handle = GNUNET_TRANSPORT_connect (c, &my_full_id,
-                                        NULL, /* cls */
-                                        NULL, NULL, NULL); /* Notify callbacks */
+  if (GNUNET_YES !=
+    GNUNET_CONFIGURATION_get_value_yesno (c, "MESH", "DISABLE_TRY_CONNECT"))
+  {
+    transport_handle = GNUNET_TRANSPORT_connect (c, &my_full_id, NULL, /* cls */
+                                                 /* Notify callbacks */
+                                                 NULL, NULL, NULL);
+  }
+  else
+  {
+    LOG (GNUNET_ERROR_TYPE_WARNING, "**************************************\n");
+    LOG (GNUNET_ERROR_TYPE_WARNING, "*  DISABLE TRYING CONNECT in config  *\n");
+    LOG (GNUNET_ERROR_TYPE_WARNING, "*  Use this only for test purposes.  *\n");
+    LOG (GNUNET_ERROR_TYPE_WARNING, "**************************************\n");
+  }
 
-  if (NULL == core_handle || NULL == transport_handle)
+
+
+  if (NULL == core_handle)
   {
     GNUNET_break (0);
     GNUNET_SCHEDULER_shutdown ();
@@ -1424,7 +1481,12 @@ GMP_connect (struct MeshPeer *peer)
     p = peer_get_best_path (peer);
     if (NULL != p)
     {
-      LOG (GNUNET_ERROR_TYPE_DEBUG, "  %u hops\n", p->length);
+      char *s;
+
+      s = path_2s (p);
+      LOG (GNUNET_ERROR_TYPE_DEBUG, "  path to use: %s\n", s);
+      GNUNET_free (s);
+
       c = GMT_use_path (t, p);
       if (NULL == c)
       {
@@ -1951,6 +2013,9 @@ GMP_try_connect (struct MeshPeer *peer)
   struct GNUNET_HELLO_Message *hello;
   struct GNUNET_MessageHeader *mh;
 
+  if (NULL == transport_handle)
+    return;
+
   hello = GMP_get_hello (peer);
   if (NULL == hello)
     return;