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

[gnunet]

Author: wachs
Date: 2010-10-04 17:25:12 +0200 (Mon, 04 Oct 2010)
New Revision: 13145

Modified:
   gnunet/src/transport/plugin_transport_http.c
   gnunet/src/transport/test_plugin_transport_http.c
   gnunet/src/transport/test_plugin_transport_https.c
Log:
stricter suggested address checking


Modified: gnunet/src/transport/plugin_transport_http.c
===================================================================
--- gnunet/src/transport/plugin_transport_http.c        2010-10-04 08:25:28 UTC 
(rev 13144)
+++ gnunet/src/transport/plugin_transport_http.c        2010-10-04 15:25:12 UTC 
(rev 13145)
@@ -96,6 +96,16 @@
 struct IPv4HttpAddress
 {
   /**
+   * Linked list next
+   */
+  struct IPv4HttpAddress * next;
+
+  /**
+   * Linked list previous
+   */
+  struct IPv4HttpAddress * prev;
+
+  /**
    * IPv4 address, in network byte order.
    */
   uint32_t ipv4_addr GNUNET_PACKED;
@@ -114,6 +124,16 @@
 struct IPv6HttpAddress
 {
   /**
+   * Linked list next
+   */
+  struct IPv6HttpAddress * next;
+
+  /**
+   * Linked list previous
+   */
+  struct IPv6HttpAddress * prev;
+
+  /**
    * IPv6 address.
    */
   struct in6_addr ipv6_addr GNUNET_PACKED;
@@ -382,6 +402,26 @@
   CURLM * multi_handle;
 
   /**
+   * ipv4 DLL head
+   */
+  struct IPv4HttpAddress * ipv4_addr_head;
+
+  /**
+   * ipv4 DLL tail
+   */
+  struct IPv4HttpAddress * ipv4_addr_tail;
+
+  /**
+   * ipv6 DLL head
+   */
+  struct IPv6HttpAddress * ipv6_addr_head;
+
+  /**
+   * ipv6 DLL tail
+   */
+  struct IPv6HttpAddress * ipv6_addr_tail;
+
+  /**
    * Our ASCII encoded, hashed peer identity
    * This string is used to distinguish between connections and is added to 
the urls
    */
@@ -674,14 +714,16 @@
       {
          if (0 == memcmp(&plugin->bind4_address->sin_addr, &bnd_cmp, sizeof 
(struct in_addr)))
          {
+             
GNUNET_CONTAINER_DLL_insert(plugin->ipv4_addr_head,plugin->ipv4_addr_tail,t4);
                  
plugin->env->notify_address(plugin->env->cls,PROTOCOL_PREFIX,t4, sizeof (struct 
IPv4HttpAddress), GNUNET_TIME_UNIT_FOREVER_REL);
          }
       }
       else
       {
+          
GNUNET_CONTAINER_DLL_insert(plugin->ipv4_addr_head,plugin->ipv4_addr_tail,t4);
          plugin->env->notify_address(plugin->env->cls,PROTOCOL_PREFIX,t4, 
sizeof (struct IPv4HttpAddress), GNUNET_TIME_UNIT_FOREVER_REL);
       }
-      GNUNET_free (t4);
+
     }
   else if ((af == AF_INET6) && (plugin->use_ipv6 == GNUNET_YES)  && 
(plugin->bind4_address == NULL))
     {
@@ -701,6 +743,7 @@
                      sizeof (struct in6_addr));
              t6->u6_port = htons (plugin->port_inbound);
              
plugin->env->notify_address(plugin->env->cls,PROTOCOL_PREFIX,t6,sizeof (struct 
IPv6HttpAddress) , GNUNET_TIME_UNIT_FOREVER_REL);
+             
GNUNET_CONTAINER_DLL_insert(plugin->ipv6_addr_head,plugin->ipv6_addr_tail,t6);
          }
       }
       else
@@ -709,9 +752,9 @@
                   &((struct sockaddr_in6 *) addr)->sin6_addr,
                   sizeof (struct in6_addr));
           t6->u6_port = htons (plugin->port_inbound);
+          
GNUNET_CONTAINER_DLL_insert(plugin->ipv6_addr_head,plugin->ipv6_addr_tail,t6);
           
plugin->env->notify_address(plugin->env->cls,PROTOCOL_PREFIX,t6,sizeof (struct 
IPv6HttpAddress) , GNUNET_TIME_UNIT_FOREVER_REL);
       }
-      GNUNET_free (t6);
     }
   return GNUNET_OK;
 }
@@ -2393,6 +2436,10 @@
   struct Plugin *plugin = cls;
   struct IPv4HttpAddress *v4;
   struct IPv6HttpAddress *v6;
+
+  struct IPv4HttpAddress *tv4 = plugin->ipv4_addr_head;
+  struct IPv6HttpAddress *tv6 = plugin->ipv6_addr_head;
+  int res;
   unsigned int port;
 
   GNUNET_assert(cls !=NULL);
@@ -2409,6 +2456,23 @@
       {
         return GNUNET_SYSERR;
       } */
+
+      if (plugin->bind4_address!=NULL)
+      {
+         res = memcmp (&plugin->bind4_address->sin_addr, &v4->ipv4_addr, 
sizeof(uint32_t));
+         if ((res==0) && (ntohs (v4->u_port) == plugin->port_inbound))
+                 return GNUNET_OK;
+         else
+                 return GNUNET_SYSERR;
+      }
+
+      while (tv4!=NULL)
+      {
+         res = memcmp (&tv4->ipv4_addr, &v4->ipv4_addr, sizeof(uint32_t));
+         if ((res==0) && (v4->u_port == tv4->u_port) && (ntohs (v4->u_port) == 
plugin->port_inbound))
+                 return GNUNET_OK;
+         tv4 = tv4->next;
+      }
       port = ntohs (v4->u_port);
       if (port != plugin->port_inbound)
       {
@@ -2422,14 +2486,26 @@
         {
           return GNUNET_SYSERR;
         }
-      port = ntohs (v6->u6_port);
-      if (port != plugin->port_inbound)
+
+      if (plugin->bind6_address!=NULL)
       {
-        return GNUNET_SYSERR;
+         res = memcmp (&plugin->bind6_address->sin6_addr, &v6->ipv6_addr, 
sizeof(struct in6_addr));
+         if ((res==0) && (ntohs (v6->u6_port) == plugin->port_inbound))
+                 return GNUNET_OK;
+         else
+                 return GNUNET_SYSERR;
       }
+
+      while (tv6!=NULL)
+      {
+         res = memcmp (&tv6->ipv6_addr, &v6->ipv6_addr, sizeof(struct 
in6_addr));
+         if ((res==0) && (v6->u6_port == tv6->u6_port) && (ntohs (v6->u6_port) 
== plugin->port_inbound))
+                 return GNUNET_OK;
+         tv6 = tv6->next;
+      }
     }
 
-  return GNUNET_OK;
+  return GNUNET_SYSERR;
 }
 
 
@@ -2495,6 +2571,8 @@
   struct GNUNET_TRANSPORT_PluginFunctions *api = cls;
   struct Plugin *plugin = api->cls;
   CURLMcode mret;
+  struct IPv4HttpAddress * ipv4addr;
+  struct IPv6HttpAddress * ipv6addr;
   GNUNET_assert(cls !=NULL);
 
   if (plugin->http_server_daemon_v4 != NULL)
@@ -2520,6 +2598,20 @@
     plugin->http_server_task_v6 = GNUNET_SCHEDULER_NO_TASK;
   }
 
+  while (plugin->ipv4_addr_head!=NULL)
+  {
+         ipv4addr = plugin->ipv4_addr_head;
+         
GNUNET_CONTAINER_DLL_remove(plugin->ipv4_addr_head,plugin->ipv4_addr_tail,ipv4addr);
+         GNUNET_free(ipv4addr);
+  }
+
+  while (plugin->ipv6_addr_head!=NULL)
+  {
+         ipv6addr = plugin->ipv6_addr_head;
+         
GNUNET_CONTAINER_DLL_remove(plugin->ipv6_addr_head,plugin->ipv6_addr_tail,ipv6addr);
+         GNUNET_free(ipv6addr);
+  }
+
   /* free all peer information */
   if (plugin->peers!=NULL)
   {

Modified: gnunet/src/transport/test_plugin_transport_http.c
===================================================================
--- gnunet/src/transport/test_plugin_transport_http.c   2010-10-04 08:25:28 UTC 
(rev 13144)
+++ gnunet/src/transport/test_plugin_transport_http.c   2010-10-04 15:25:12 UTC 
(rev 13145)
@@ -162,6 +162,10 @@
  */
 struct IPv4HttpAddress
 {
+  struct IPv4HttpAddress * next;
+
+  struct IPv4HttpAddress * prev;
+
   /**
    * IPv4 address, in network byte order.
    */
@@ -180,6 +184,10 @@
  */
 struct IPv6HttpAddress
 {
+  struct IPv6HttpAddress * next;
+
+  struct IPv6HttpAddress * prev;
+
   /**
    * IPv6 address.
    */
@@ -192,6 +200,7 @@
 
 };
 
+
 /**
  * Our public key.
  */

Modified: gnunet/src/transport/test_plugin_transport_https.c
===================================================================
--- gnunet/src/transport/test_plugin_transport_https.c  2010-10-04 08:25:28 UTC 
(rev 13144)
+++ gnunet/src/transport/test_plugin_transport_https.c  2010-10-04 15:25:12 UTC 
(rev 13145)
@@ -162,6 +162,10 @@
  */
 struct IPv4HttpAddress
 {
+  struct IPv4HttpAddress * next;
+
+  struct IPv4HttpAddress * prev;
+
   /**
    * IPv4 address, in network byte order.
    */
@@ -180,6 +184,10 @@
  */
 struct IPv6HttpAddress
 {
+  struct IPv6HttpAddress * next;
+
+  struct IPv6HttpAddress * prev;
+
   /**
    * IPv6 address.
    */
@@ -458,8 +466,8 @@
   }
 
   GNUNET_free(test_addr);
-  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Unloading http plugin\n");
-  GNUNET_assert (NULL == GNUNET_PLUGIN_unload 
("libgnunet_plugin_transport_http", api));
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Unloading https plugin\n");
+  GNUNET_assert (NULL == GNUNET_PLUGIN_unload 
("libgnunet_plugin_transport_https", api));
 
   GNUNET_SCHEDULER_shutdown(sched);
   GNUNET_DISK_directory_remove ("/tmp/test_plugin_transport_http");