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

[gnunet]

Author: wachs
Date: 2011-09-13 10:48:47 +0200 (Tue, 13 Sep 2011)
New Revision: 16784

Modified:
   gnunet/src/transport/gnunet-service-transport-new.c
   gnunet/src/transport/plugin_transport_tcp.c
Log:
fix: ats data


Modified: gnunet/src/transport/gnunet-service-transport-new.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport-new.c 2011-09-13 08:22:44 UTC 
(rev 16783)
+++ gnunet/src/transport/gnunet-service-transport-new.c 2011-09-13 08:48:47 UTC 
(rev 16784)
@@ -165,7 +165,6 @@
   struct GNUNET_TIME_Relative ret;
   uint16_t type;
 
-
   ret = GNUNET_TIME_UNIT_ZERO;
   if (NULL != message)
   {
@@ -202,8 +201,8 @@
       (void) GST_blacklist_test_allowed (peer, NULL, &try_connect_if_allowed,
                                          NULL);
       /* TODO: if 'session != NULL', and timestamp more recent than the
-        previous one, maybe notify ATS that this is now the preferred
-       * way to communicate with this peer (other peer switched transport) */
+       * previous one, maybe notify ATS that this is now the preferred
+       * * way to communicate with this peer (other peer switched transport) */
       break;
     case GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_DISCONNECT:
       /* TODO: do some validation to prevent an attacker from sending
@@ -242,6 +241,9 @@
       break;
     }
   }
+
+  GNUNET_assert ((ats_count > 0) && (ats != NULL));
+
   GNUNET_ATS_address_update (GST_ats, peer, GNUNET_TIME_absolute_get (),       
 /* valid at least until right now... */
                              plugin_name, session, sender_address,
                              sender_address_len, ats, ats_count);

Modified: gnunet/src/transport/plugin_transport_tcp.c
===================================================================
--- gnunet/src/transport/plugin_transport_tcp.c 2011-09-13 08:22:44 UTC (rev 
16783)
+++ gnunet/src/transport/plugin_transport_tcp.c 2011-09-13 08:48:47 UTC (rev 
16784)
@@ -1661,11 +1661,15 @@
 {
   struct Session *session = cls;
   struct GNUNET_TIME_Relative delay;
+  struct GNUNET_TRANSPORT_ATS_Information ats;
 
+  ats.type = htonl (GNUNET_TRANSPORT_ATS_ARRAY_TERMINATOR);
+  ats.value = htonl (0);
+
   session->receive_delay_task = GNUNET_SCHEDULER_NO_TASK;
   delay =
       session->plugin->env->receive (session->plugin->env->cls,
-                                     &session->target, NULL, NULL, 0, session,
+                                     &session->target, NULL, &ats, 1, session,
                                      NULL, 0);
   if (delay.rel_value == 0)
     GNUNET_SERVER_receive_done (session->client, GNUNET_OK);