fixing 2012: network structure alignment now forced to be correct even on W32 using...
[oweals/gnunet.git] / src / nat / nat.c
index 891613feadcdad6e560d13e73d3594838586067c..9f8fec9a022fc004eb018fe7f2ec6d5d4c649038 100644 (file)
@@ -29,8 +29,9 @@
 #include "gnunet_util_lib.h"
 #include "gnunet_resolver_service.h"
 #include "gnunet_nat_lib.h"
+#include "nat.h"
 
-#define DEBUG_NAT GNUNET_NO
+#define LOG(kind,...) GNUNET_log_from (kind, "nat", __VA_ARGS__)
 
 /**
  * How often do we scan for changes in our IP address from our local
@@ -293,7 +294,8 @@ struct GNUNET_NAT_Handle
   unsigned int num_local_addrs;
 
   /**
-   * The our external address (according to config, UPnP may disagree...)
+   * Our external address (according to config, UPnP may disagree...),
+   * in dotted decimal notation, IPv4-only. Or NULL if not known.
    */
   char *external_address;
 
@@ -332,6 +334,11 @@ struct GNUNET_NAT_Handle
    */
   int use_localaddresses;
 
+  /**
+   * Should we return local addresses to clients
+   */
+  int return_localaddress;
+
   /**
    * Should we do a DNS lookup of our hostname to find out our own IP?
    */
@@ -369,7 +376,7 @@ start_gnunet_nat_server (struct GNUNET_NAT_Handle *h);
  * Remove all addresses from the list of 'local' addresses
  * that originated from the given source.
  *
- * @param plugin the plugin
+ * @param h handle to NAT
  * @param src source that identifies addresses to remove
  */
 static void
@@ -398,7 +405,7 @@ remove_from_address_list_by_source (struct GNUNET_NAT_Handle *h,
  * Add the given address to the list of 'local' addresses, thereby
  * making it a 'legal' address for this peer to have.
  *
- * @param plugin the plugin
+ * @param h handle to NAT
  * @param src where did the local address originate from?
  * @param arg the address, some 'struct sockaddr'
  * @param arg_size number of bytes in arg
@@ -416,10 +423,8 @@ add_to_address_list_as_is (struct GNUNET_NAT_Handle *h,
   lal->source = src;
   GNUNET_CONTAINER_DLL_insert (h->lal_head, h->lal_tail, lal);
 #if DEBUG_NAT
-  GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "nat",
-                   "Adding address `%s' from source %d\n", GNUNET_a2s (arg,
-                                                                       arg_size),
-                   src);
+  LOG (GNUNET_ERROR_TYPE_DEBUG, "Adding address `%s' from source %d\n",
+       GNUNET_a2s (arg, arg_size), src);
 #endif
   if (NULL != h->address_callback)
     h->address_callback (h->callback_cls, GNUNET_YES, arg, arg_size);
@@ -432,7 +437,7 @@ add_to_address_list_as_is (struct GNUNET_NAT_Handle *h,
  * port number in the process to the advertised port and possibly
  * also to zero (if we have the gnunet-helper-nat-server).
  *
- * @param plugin the plugin
+ * @param h handle to NAT
  * @param src where did the local address originate from?
  * @param arg the address, some 'struct sockaddr'
  * @param arg_size number of bytes in arg
@@ -483,10 +488,10 @@ add_to_address_list (struct GNUNET_NAT_Handle *h, enum LocalAddressSource src,
  * Add the given IP address to the list of 'local' addresses, thereby
  * making it a 'legal' address for this peer to have.
  *
- * @param plugin the plugin
+ * @param h handle to NAT
  * @param src where did the local address originate from?
- * @param arg the address, some 'struct in_addr' or 'struct in6_addr'
- * @param arg_size number of bytes in arg
+ * @param addr the address, some 'struct in_addr' or 'struct in6_addr'
+ * @param addrlen number of bytes in addr
  */
 static void
 add_ip_to_address_list (struct GNUNET_NAT_Handle *h,
@@ -624,12 +629,16 @@ process_hostname_ip (void *cls, const struct sockaddr *addr, socklen_t addrlen)
  * @param name name of the interface
  * @param isDefault do we think this may be our default interface
  * @param addr address of the interface
+ * @param broadcast_addr the broadcast address (can be NULL for unknown or unassigned)
+ * @param netmask the network mask (can be NULL for unknown or unassigned))
  * @param addrlen number of bytes in addr
  * @return GNUNET_OK to continue iterating
  */
 static int
 process_interfaces (void *cls, const char *name, int isDefault,
-                    const struct sockaddr *addr, socklen_t addrlen)
+                    const struct sockaddr *addr,
+                    const struct sockaddr *broadcast_addr,
+                    const struct sockaddr *netmask, socklen_t addrlen)
 {
   struct GNUNET_NAT_Handle *h = cls;
   const struct sockaddr_in *s4;
@@ -642,9 +651,20 @@ process_interfaces (void *cls, const char *name, int isDefault,
   case AF_INET:
     s4 = (struct sockaddr_in *) addr;
     ip = &s4->sin_addr;
+
+    /* Check if address is in 127.0.0.0/8 */
+    uint32_t address = ntohl ((uint32_t) (s4->sin_addr.s_addr));
+    uint32_t value = (address & 0xFF000000) ^ 0x7F000000;
+
+    if ((h->return_localaddress == GNUNET_NO) && (value == 0))
+    {
+      return GNUNET_OK;
+    }
     if (GNUNET_YES == h->use_localaddresses)
+    {
       add_ip_to_address_list (h, LAL_INTERFACE_ADDRESS, &s4->sin_addr,
                               sizeof (struct in_addr));
+    }
     break;
   case AF_INET6:
     s6 = (struct sockaddr_in6 *) addr;
@@ -653,10 +673,17 @@ process_interfaces (void *cls, const char *name, int isDefault,
       /* skip link local addresses */
       return GNUNET_OK;
     }
+    if ((h->return_localaddress == GNUNET_NO) &&
+        (IN6_IS_ADDR_LOOPBACK (&((struct sockaddr_in6 *) addr)->sin6_addr)))
+    {
+      return GNUNET_OK;
+    }
     ip = &s6->sin6_addr;
     if (GNUNET_YES == h->use_localaddresses)
+    {
       add_ip_to_address_list (h, LAL_INTERFACE_ADDRESS, &s6->sin6_addr,
                               sizeof (struct in6_addr));
+    }
     break;
   default:
     GNUNET_break (0);
@@ -724,12 +751,11 @@ nat_server_read (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
   if (bytes < 1)
   {
 #if DEBUG_NAT
-    GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "nat",
-                     "Finished reading from server stdout with code: %d\n",
-                     bytes);
+    LOG (GNUNET_ERROR_TYPE_DEBUG,
+         "Finished reading from server stdout with code: %d\n", bytes);
 #endif
     if (0 != GNUNET_OS_process_kill (h->server_proc, SIGTERM))
-      GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill");
+      GNUNET_log_from_strerror (GNUNET_ERROR_TYPE_WARNING, "nat", "kill");
     GNUNET_OS_process_wait (h->server_proc);
     GNUNET_OS_process_close (h->server_proc);
     h->server_proc = NULL;
@@ -773,10 +799,9 @@ nat_server_read (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
       (-1 == inet_pton (AF_INET, mybuf, &sin_addr.sin_addr)))
   {
     /* should we restart gnunet-helper-nat-server? */
-    GNUNET_log_from (GNUNET_ERROR_TYPE_WARNING, "nat",
-                     _
-                     ("gnunet-helper-nat-server generated malformed address `%s'\n"),
-                     mybuf);
+    LOG (GNUNET_ERROR_TYPE_WARNING, "nat",
+         _("gnunet-helper-nat-server generated malformed address `%s'\n"),
+         mybuf);
     h->server_read_task =
         GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
                                         h->server_stdout_handle,
@@ -785,8 +810,8 @@ nat_server_read (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
   }
   sin_addr.sin_port = htons ((uint16_t) port);
 #if DEBUG_NAT
-  GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "nat",
-                   "gnunet-helper-nat-server read: %s:%d\n", mybuf, port);
+  LOG (GNUNET_ERROR_TYPE_DEBUG, "gnunet-helper-nat-server read: %s:%d\n", mybuf,
+       port);
 #endif
   h->reversal_callback (h->callback_cls, (const struct sockaddr *) &sin_addr,
                         sizeof (sin_addr));
@@ -813,8 +838,8 @@ start_gnunet_nat_server (struct GNUNET_NAT_Handle *h)
         GNUNET_DISK_pipe (GNUNET_YES, GNUNET_NO, GNUNET_YES))))
   {
 #if DEBUG_NAT
-    GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "nat" "Starting %s at `%s'\n",
-                     "gnunet-helper-nat-server", h->internal_address);
+    LOG (GNUNET_ERROR_TYPE_DEBUG, "Starting `%s' at `%s'\n",
+         "gnunet-helper-nat-server", h->internal_address);
 #endif
     /* Start the server process */
     h->server_proc =
@@ -824,8 +849,8 @@ start_gnunet_nat_server (struct GNUNET_NAT_Handle *h)
                                  h->internal_address, NULL);
     if (h->server_proc == NULL)
     {
-      GNUNET_log_from (GNUNET_ERROR_TYPE_WARNING, "nat",
-                       _("Failed to start %s\n"), "gnunet-helper-nat-server");
+      LOG (GNUNET_ERROR_TYPE_WARNING, "nat", _("Failed to start %s\n"),
+           "gnunet-helper-nat-server");
       GNUNET_DISK_pipe_close (h->server_stdout);
       h->server_stdout = NULL;
     }
@@ -1035,8 +1060,8 @@ add_from_bind (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
  * @param adv_port advertised port (port we are either bound to or that our OS
  *                 locally performs redirection from to our bound port).
  * @param num_addrs number of addresses in 'addrs'
- * @param addr the local address packets should be redirected to
- * @param addrlen actual lenght of the address
+ * @param addrs the local addresses packets should be redirected to
+ * @param addrlens actual lengths of the addresses
  * @param address_callback function to call everytime the public IP address changes
  * @param reversal_callback function to call if someone wants connection reversal from us
  * @param callback_cls closure for callbacks
@@ -1055,9 +1080,9 @@ GNUNET_NAT_register (const struct GNUNET_CONFIGURATION_Handle *cfg, int is_tcp,
   unsigned int i;
 
 #if DEBUG_NAT
-  GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "nat",
-                   "Registered with NAT service at port %u with %u IP bound local addresses\n",
-                   (unsigned int) adv_port, num_addrs);
+  LOG (GNUNET_ERROR_TYPE_DEBUG,
+       "Registered with NAT service at port %u with %u IP bound local addresses\n",
+       (unsigned int) adv_port, num_addrs);
 #endif
   h = GNUNET_malloc (sizeof (struct GNUNET_NAT_Handle));
   h->server_retry_delay = GNUNET_TIME_UNIT_SECONDS;
@@ -1092,9 +1117,9 @@ GNUNET_NAT_register (const struct GNUNET_CONFIGURATION_Handle *cfg, int is_tcp,
   if ((h->internal_address != NULL) &&
       (inet_pton (AF_INET, h->internal_address, &in_addr) != 1))
   {
-    GNUNET_log_from (GNUNET_ERROR_TYPE_WARNING, "nat",
-                     _("Malformed %s `%s' given in configuration!\n"),
-                     "INTERNAL_ADDRESS", h->internal_address);
+    LOG (GNUNET_ERROR_TYPE_WARNING, "nat",
+         _("Malformed %s `%s' given in configuration!\n"), "INTERNAL_ADDRESS",
+         h->internal_address);
     GNUNET_free (h->internal_address);
     h->internal_address = NULL;
   }
@@ -1106,15 +1131,6 @@ GNUNET_NAT_register (const struct GNUNET_CONFIGURATION_Handle *cfg, int is_tcp,
                                                   "EXTERNAL_ADDRESS",
                                                   &h->external_address);
   }
-  if ((h->external_address != NULL) &&
-      (inet_pton (AF_INET, h->external_address, &in_addr) != 1))
-  {
-    GNUNET_log_from (GNUNET_ERROR_TYPE_WARNING, "nat",
-                     _("Malformed %s `%s' given in configuration!\n"),
-                     "EXTERNAL_ADDRESS", h->external_address);
-    GNUNET_free (h->external_address);
-    h->external_address = NULL;
-  }
   h->behind_nat =
       GNUNET_CONFIGURATION_get_value_yesno (cfg, "nat", "BEHIND_NAT");
   h->nat_punched =
@@ -1127,6 +1143,10 @@ GNUNET_NAT_register (const struct GNUNET_CONFIGURATION_Handle *cfg, int is_tcp,
       GNUNET_CONFIGURATION_get_value_yesno (cfg, "nat", "ENABLE_UPNP");
   h->use_localaddresses =
       GNUNET_CONFIGURATION_get_value_yesno (cfg, "nat", "USE_LOCALADDR");
+  h->return_localaddress =
+      GNUNET_CONFIGURATION_get_value_yesno (cfg, "nat",
+                                            "RETURN_LOCAL_ADDRESSES");
+
   h->use_hostname =
       GNUNET_CONFIGURATION_get_value_yesno (cfg, "nat", "USE_HOSTNAME");
   h->disable_ipv6 =
@@ -1162,20 +1182,20 @@ GNUNET_NAT_register (const struct GNUNET_CONFIGURATION_Handle *cfg, int is_tcp,
        GNUNET_OS_check_helper_binary ("gnunet-helper-nat-server")))
   {
     h->enable_nat_server = GNUNET_NO;
-    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
-                _
-                ("Configuration requires `%s', but binary is not installed properly (SUID bit not set).  Option disabled.\n"),
-                "gnunet-helper-nat-server");
+    LOG (GNUNET_ERROR_TYPE_WARNING,
+         _
+         ("Configuration requires `%s', but binary is not installed properly (SUID bit not set).  Option disabled.\n"),
+         "gnunet-helper-nat-server");
   }
   if ((GNUNET_YES == h->enable_nat_client) &&
       (GNUNET_YES !=
        GNUNET_OS_check_helper_binary ("gnunet-helper-nat-client")))
   {
     h->enable_nat_client = GNUNET_NO;
-    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
-                _
-                ("Configuration requires `%s', but binary is not installed properly (SUID bit not set).  Option disabled.\n"),
-                "gnunet-helper-nat-client");
+    LOG (GNUNET_ERROR_TYPE_WARNING,
+         _
+         ("Configuration requires `%s', but binary is not installed properly (SUID bit not set).  Option disabled.\n"),
+         "gnunet-helper-nat-client");
   }
 
   start_gnunet_nat_server (h);
@@ -1251,7 +1271,7 @@ GNUNET_NAT_unregister (struct GNUNET_NAT_Handle *h)
   if (NULL != h->server_proc)
   {
     if (0 != GNUNET_OS_process_kill (h->server_proc, SIGTERM))
-      GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill");
+      GNUNET_log_from_strerror (GNUNET_ERROR_TYPE_WARNING, "nat", "kill");
     GNUNET_OS_process_wait (h->server_proc);
     GNUNET_OS_process_close (h->server_proc);
     h->server_proc = NULL;
@@ -1304,22 +1324,22 @@ GNUNET_NAT_run_client (struct GNUNET_NAT_Handle *h,
 
   if (h->internal_address == NULL)
   {
-    GNUNET_log_from (GNUNET_ERROR_TYPE_WARNING, "nat",
-                     _
-                     ("Internal IP address not known, cannot use ICMP NAT traversal method\n"));
+    LOG (GNUNET_ERROR_TYPE_WARNING, "nat",
+         _
+         ("Internal IP address not known, cannot use ICMP NAT traversal method\n"));
     return;
   }
   GNUNET_assert (sa->sin_family == AF_INET);
   if (NULL == inet_ntop (AF_INET, &sa->sin_addr, inet4, INET_ADDRSTRLEN))
   {
-    GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "inet_ntop");
+    GNUNET_log_from_strerror (GNUNET_ERROR_TYPE_WARNING, "nat", "inet_ntop");
     return;
   }
   GNUNET_snprintf (port_as_string, sizeof (port_as_string), "%d", h->adv_port);
 #if DEBUG_NAT
-  GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "nat",
-                   _("Running gnunet-helper-nat-client %s %s %u\n"),
-                   h->internal_address, inet4, (unsigned int) h->adv_port);
+  LOG (GNUNET_ERROR_TYPE_DEBUG,
+       _("Running gnunet-helper-nat-client %s %s %u\n"), h->internal_address,
+       inet4, (unsigned int) h->adv_port);
 #endif
   proc =
       GNUNET_OS_start_process (NULL, NULL, "gnunet-helper-nat-client",
@@ -1381,8 +1401,8 @@ GNUNET_NAT_test_address (struct GNUNET_NAT_Handle *h, const void *addr,
     }
     pos = pos->next;
   }
-  GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
-              "Asked to validate one of my addresses and validation failed!\n");
+  LOG (GNUNET_ERROR_TYPE_WARNING,
+       "Asked to validate one of my addresses and validation failed!\n");
   return GNUNET_NO;
 }