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

[gnunet]

Author: wachs
Date: 2011-08-29 16:20:36 +0200 (Mon, 29 Aug 2011)
New Revision: 16623

Modified:
   gnunet/src/transport/gnunet-service-transport_validation.c
Log:
- handle_pong used wrong address size
- TODO: GNUNET_ATS_address_update crashes transport service



Modified: gnunet/src/transport/gnunet-service-transport_validation.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport_validation.c  2011-08-29 
10:25:18 UTC (rev 16622)
+++ gnunet/src/transport/gnunet-service-transport_validation.c  2011-08-29 
14:20:36 UTC (rev 16623)
@@ -889,10 +889,11 @@
 {
   const struct TransportPongMessage *pong;
   struct ValidationEntry *ve;
+  const char *tname;
   const char *addr;
-  const char *addrend;
-  size_t alen;
+  size_t addrlen;
   size_t slen;
+  size_t size;
   uint32_t rdelay;
   struct GNUNET_TIME_Relative delay;
   struct GNUNET_HELLO_Message *hello;
@@ -905,19 +906,22 @@
   GNUNET_STATISTICS_update (GST_stats,
                             gettext_noop ("# PONG messages received"), 1,
                             GNUNET_NO);
+
   pong = (const struct TransportPongMessage *) hdr;
-  addr = (const char *) &pong[1];
-  alen = ntohs (hdr->size) - sizeof (struct TransportPongMessage);
-  addrend = memchr (addr, '\0', alen);
-  if (NULL == addrend)
+  tname = (const char *) &pong[1];
+  size = ntohs (hdr->size) - sizeof (struct TransportPongMessage);
+  addr = memchr (tname, '\0', size);
+  if (NULL == addr)
   {
     GNUNET_break_op (0);
     return;
   }
-  addrend++;
-  slen = strlen (addr);
-  alen -= slen;
-  ve = find_validation_entry (NULL, sender, addr, addrend, alen);
+  addr++;
+  slen = strlen (tname) + 1;
+  addrlen = size - slen;
+
+  ve = find_validation_entry (NULL, sender, tname, addr, addrlen);
+
   if (NULL == ve)
   {
     GNUNET_STATISTICS_update (GST_stats,
@@ -951,9 +955,17 @@
     return;
   }
 
+#if VERBOSE_VALIDATION
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+              "Address validated for peer `%s' with plugin `%s': `%s'\n",
+              GNUNET_i2s (sender), tname, GST_plugins_a2s (tname, addr,
+                                                           addrlen));
+#endif
+
   /* validity achieved, remember it! */
   ve->valid_until = GNUNET_TIME_relative_to_absolute 
(HELLO_ADDRESS_EXPIRATION);
-  GNUNET_ATS_address_update (GST_ats, &ve->pid, ve->valid_until, 
ve->transport_name, NULL, ve->addr, ve->addrlen, NULL, 0);     /* FIXME: 
compute and add latency here... */
+  // FIXME: This crashes transport service
+  //  GNUNET_ATS_address_update (GST_ats, &ve->pid, ve->valid_until, 
ve->transport_name, NULL, ve->addr, ve->addrlen, NULL, 0);     /* FIXME: 
compute and add latency here... */
 
   /* build HELLO to store in PEERINFO */
   hello = GNUNET_HELLO_create (&ve->public_key, &add_valid_peer_address, ve);