[GNUnet-SVN] r17902 - gnunet/src/transport

[gnunet]

Author: wachs
Date: 2011-11-02 10:10:51 +0100 (Wed, 02 Nov 2011)
New Revision: 17902

Modified:
   gnunet/src/transport/gnunet-service-transport_neighbours.c
Log:
fixing https://www.gnunet.org/bugs/view.php?id=1867


Modified: gnunet/src/transport/gnunet-service-transport_neighbours.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport_neighbours.c  2011-11-01 
23:19:53 UTC (rev 17901)
+++ gnunet/src/transport/gnunet-service-transport_neighbours.c  2011-11-02 
09:10:51 UTC (rev 17902)
@@ -579,6 +579,7 @@
   struct GNUNET_TRANSPORT_PluginFunctions *papi;
   size_t ret = GNUNET_SYSERR;
 
+  GNUNET_assert (plugin_name != NULL);
   papi = GST_plugins_find (plugin_name);
   if (papi == NULL)
   {
@@ -1033,6 +1034,7 @@
 
   if (is_disconnecting(n))
     return; /* neighbour is going away */
+
   if (GNUNET_YES != success)
   {
 #if DEBUG_TRANSPORT
@@ -1052,13 +1054,16 @@
                                  n->addrlen,
                                  NULL);
 
+    change_state(n, S_NOT_CONNECTED);
+
     if (n->ats_suggest!= GNUNET_SCHEDULER_NO_TASK)
       GNUNET_SCHEDULER_cancel(n->ats_suggest);
     n->ats_suggest = GNUNET_SCHEDULER_add_delayed (ATS_RESPONSE_TIMEOUT, 
ats_suggest_cancel, n);
     GNUNET_ATS_suggest_address(GST_ats, &n->id);
     return;
   }
-  change_state(n, S_CONNECT_SENT);
+
+
 }
 
 
@@ -1275,6 +1280,8 @@
     connect_msg.timestamp =
         GNUNET_TIME_absolute_hton (GNUNET_TIME_absolute_get ());
 
+    change_state (n, S_CONNECT_SENT);
+
     ret = send_with_plugin (peer, (const char *) &connect_msg, msg_len, 
UINT32_MAX, GNUNET_TIME_UNIT_FOREVER_REL,
                             session, plugin_name, address, address_len,
                             GNUNET_YES, &send_connect_continuation, n);
@@ -1324,7 +1331,6 @@
   }
   else if (n->state == S_CONNECT_SENT)
   {
-      //FIXME
      return GNUNET_NO;
   }
   GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Invalid connection state to switch 
addresses %u \n", n->state);