src/util/gnunet-service-resolver.c

   1 /*
   2      This file is part of GNUnet.
   3      (C) 2007, 2008, 2009 Christian Grothoff (and other contributing authors)
   4
   5      GNUnet is free software; you can redistribute it and/or modify
   6      it under the terms of the GNU General Public License as published
   7      by the Free Software Foundation; either version 2, or (at your
   8      option) any later version.
   9
  10      GNUnet is distributed in the hope that it will be useful, but
  11      WITHOUT ANY WARRANTY; without even the implied warranty of
  12      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13      General Public License for more details.
  14
  15      You should have received a copy of the GNU General Public License
  16      along with GNUnet; see the file COPYING.  If not, write to the
  17      Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  18      Boston, MA 02111-1307, USA.
  19 */
  20
  21 /**
  22  * @file util/gnunet-service-resolver.c
  23  * @brief code to do DNS resolution
  24  * @author Christian Grothoff
  25  */
  26 #include "platform.h"
  27 #include "gnunet_disk_lib.h"
  28 #include "gnunet_getopt_lib.h"
  29 #include "gnunet_protocols.h"
  30 #include "gnunet_service_lib.h"
  31 #include "gnunet_statistics_service.h"
  32 #include "gnunet_strings_lib.h"
  33 #include "gnunet_time_lib.h"
  34 #include "resolver.h"
  35
  36 /**
  37  * A cached DNS lookup result.
  38  */
  39 struct IPCache
  40 {
  41   /**
  42    * This is a linked list.
  43    */
  44   struct IPCache *next;
  45
  46   /**
  47    * Hostname in human-readable form.
  48    */
  49   char *addr;
  50
  51   /**
  52    * Hostname in binary format.
  53    */
  54   struct sockaddr *sa;
  55
  56   /**
  57    * Last time this entry was updated.
  58    */
  59   struct GNUNET_TIME_Absolute last_refresh;
  60
  61   /**
  62    * Last time this entry was requested.
  63    */
  64   struct GNUNET_TIME_Absolute last_request;
  65
  66   /**
  67    * Number of bytes in sa.
  68    */
  69   socklen_t salen;
  70 };
  71
  72
  73 /**
  74  * Start of the linked list of cached DNS lookup results.
  75  */
  76 static struct IPCache *head;
  77
  78
  79 #if HAVE_GETNAMEINFO
  80 /**
  81  * Resolve the given request using getnameinfo
  82  *
  83  * @param cache the request to resolve (and where to store the result)
  84  */
  85 static void
  86 getnameinfo_resolve (struct IPCache *cache)
  87 {
  88   char hostname[256];
  89
  90   if (0 ==
  91       getnameinfo (cache->sa, cache->salen, hostname, sizeof (hostname), NULL,
  92                    0, 0))
  93     cache->addr = GNUNET_strdup (hostname);
  94 }
  95 #endif
  96
  97
  98 #if HAVE_GETHOSTBYADDR
  99 /**
 100  * Resolve the given request using gethostbyaddr
 101  *
 102  * @param cache the request to resolve (and where to store the result)
 103  */
 104 static void
 105 gethostbyaddr_resolve (struct IPCache *cache)
 106 {
 107   struct hostent *ent;
 108
 109   switch (cache->sa->sa_family)
 110   {
 111   case AF_INET:
 112     ent =
 113         gethostbyaddr (&((struct sockaddr_in *) cache->sa)->sin_addr,
 114                        sizeof (struct in_addr), AF_INET);
 115     break;
 116   case AF_INET6:
 117     ent =
 118         gethostbyaddr (&((struct sockaddr_in6 *) cache->sa)->sin6_addr,
 119                        sizeof (struct in6_addr), AF_INET6);
 120     break;
 121   default:
 122     ent = NULL;
 123   }
 124   if (ent != NULL)
 125     cache->addr = GNUNET_strdup (ent->h_name);
 126 }
 127 #endif
 128
 129 /**
 130  * Resolve the given request using the available methods.
 131  *
 132  * @param cache the request to resolve (and where to store the result)
 133  */
 134 static void
 135 cache_resolve (struct IPCache *cache)
 136 {
 137 #if HAVE_GETNAMEINFO
 138   if (cache->addr == NULL)
 139     getnameinfo_resolve (cache);
 140 #endif
 141 #if HAVE_GETHOSTBYADDR
 142   if (cache->addr == NULL)
 143     gethostbyaddr_resolve (cache);
 144 #endif
 145 }
 146
 147
 148
 149 /**
 150  * Get an IP address as a string (works for both IPv4 and IPv6).  Note
 151  * that the resolution happens asynchronously and that the first call
 152  * may not immediately result in the FQN (but instead in a
 153  * human-readable IP address).
 154  *
 155  * @param client handle to the client making the request (for sending the reply)
 156  * @param sa should be of type "struct sockaddr*"
 157  * @param salen number of bytes in sa
 158  */
 159 static void
 160 get_ip_as_string (struct GNUNET_SERVER_Client *client,
 161                   const struct sockaddr *sa, socklen_t salen)
 162 {
 163   struct IPCache *cache;
 164   struct IPCache *prev;
 165   struct GNUNET_TIME_Absolute now;
 166   struct GNUNET_SERVER_TransmitContext *tc;
 167
 168   if (salen < sizeof (struct sockaddr))
 169   {
 170     GNUNET_break (0);
 171     GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
 172     return;
 173   }
 174   now = GNUNET_TIME_absolute_get ();
 175   cache = head;
 176   prev = NULL;
 177   while ((cache != NULL) &&
 178          ((cache->salen != salen) || (0 != memcmp (cache->sa, sa, salen))))
 179   {
 180     if (GNUNET_TIME_absolute_get_duration (cache->last_request).rel_value <
 181         60 * 60 * 1000)
 182     {
 183       if (prev != NULL)
 184       {
 185         prev->next = cache->next;
 186         GNUNET_free_non_null (cache->addr);
 187         GNUNET_free (cache->sa);
 188         GNUNET_free (cache);
 189         cache = prev->next;
 190       }
 191       else
 192       {
 193         head = cache->next;
 194         GNUNET_free_non_null (cache->addr);
 195         GNUNET_free (cache->sa);
 196         GNUNET_free (cache);
 197         cache = head;
 198       }
 199       continue;
 200     }
 201     prev = cache;
 202     cache = cache->next;
 203   }
 204   if (cache != NULL)
 205   {
 206     cache->last_request = now;
 207     if (GNUNET_TIME_absolute_get_duration (cache->last_request).rel_value <
 208         60 * 60 * 1000)
 209     {
 210       GNUNET_free_non_null (cache->addr);
 211       cache->addr = NULL;
 212       cache->salen = 0;
 213       cache_resolve (cache);
 214     }
 215   }
 216   else
 217   {
 218     cache = GNUNET_malloc (sizeof (struct IPCache));
 219     cache->next = head;
 220     cache->salen = salen;
 221     cache->sa = GNUNET_malloc (salen);
 222     memcpy (cache->sa, sa, salen);
 223     cache->last_request = GNUNET_TIME_absolute_get ();
 224     cache->last_refresh = GNUNET_TIME_absolute_get ();
 225     cache->addr = NULL;
 226     cache_resolve (cache);
 227     head = cache;
 228   }
 229   tc = GNUNET_SERVER_transmit_context_create (client);
 230   if (cache->addr != NULL)
 231     GNUNET_SERVER_transmit_context_append_data (tc, cache->addr,
 232                                                 strlen (cache->addr) + 1,
 233                                                 GNUNET_MESSAGE_TYPE_RESOLVER_RESPONSE);
 234   GNUNET_SERVER_transmit_context_append_data (tc, NULL, 0,
 235                                               GNUNET_MESSAGE_TYPE_RESOLVER_RESPONSE);
 236   GNUNET_SERVER_transmit_context_run (tc, GNUNET_TIME_UNIT_FOREVER_REL);
 237 }
 238
 239
 240 #if HAVE_GETADDRINFO
 241 static int
 242 getaddrinfo_resolve (struct GNUNET_SERVER_TransmitContext *tc,
 243                      const char *hostname, int domain)
 244 {
 245   int s;
 246   struct addrinfo hints;
 247   struct addrinfo *result;
 248   struct addrinfo *pos;
 249
 250   memset (&hints, 0, sizeof (struct addrinfo));
 251 // FIXME in PlibC
 252 #ifndef MINGW
 253   hints.ai_family = domain;
 254 #else
 255   hints.ai_family = AF_INET;
 256 #endif
 257   hints.ai_socktype = SOCK_STREAM;      /* go for TCP */
 258
 259   if (0 != (s = getaddrinfo (hostname, NULL, &hints, &result)))
 260   {
 261     GNUNET_log (GNUNET_ERROR_TYPE_INFO, _("Could not resolve `%s' (%s): %s\n"),
 262                 hostname,
 263                 (domain ==
 264                  AF_INET) ? "IPv4" : ((domain == AF_INET6) ? "IPv6" : "any"),
 265                 gai_strerror (s));
 266     if ((s == EAI_BADFLAGS) || (s == EAI_MEMORY)
 267 #ifndef MINGW
 268         || (s == EAI_SYSTEM)
 269 #else
 270         // FIXME NILS
 271         || 1
 272 #endif
 273         )
 274       return GNUNET_NO;         /* other function may still succeed */
 275     return GNUNET_SYSERR;
 276   }
 277   if (result == NULL)
 278     return GNUNET_SYSERR;
 279   pos = result;
 280   while (pos != NULL)
 281   {
 282     GNUNET_SERVER_transmit_context_append_data (tc, pos->ai_addr,
 283                                                 pos->ai_addrlen,
 284                                                 GNUNET_MESSAGE_TYPE_RESOLVER_RESPONSE);
 285     pos = pos->ai_next;
 286   }
 287   freeaddrinfo (result);
 288   return GNUNET_OK;
 289 }
 290 #endif
 291
 292 #if HAVE_GETHOSTBYNAME2
 293 static int
 294 gethostbyname2_resolve (struct GNUNET_SERVER_TransmitContext *tc,
 295                         const char *hostname, int domain)
 296 {
 297   struct hostent *hp;
 298   struct sockaddr_in a4;
 299   struct sockaddr_in6 a6;
 300   int ret1;
 301   int ret2;
 302
 303   if (domain == AF_UNSPEC)
 304   {
 305     ret1 = gethostbyname2_resolve (tc, hostname, AF_INET);
 306     ret2 = gethostbyname2_resolve (tc, hostname, AF_INET6);
 307     if ((ret1 == GNUNET_OK) || (ret2 == GNUNET_OK))
 308       return GNUNET_OK;
 309     if ((ret1 == GNUNET_SYSERR) || (ret2 == GNUNET_SYSERR))
 310       return GNUNET_SYSERR;
 311     return GNUNET_NO;
 312   }
 313   hp = gethostbyname2 (hostname, domain);
 314   if (hp == NULL)
 315   {
 316     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
 317                 _("Could not find IP of host `%s': %s\n"), hostname,
 318                 hstrerror (h_errno));
 319     return GNUNET_SYSERR;
 320   }
 321   GNUNET_assert (hp->h_addrtype == domain);
 322   if (domain == AF_INET)
 323   {
 324     GNUNET_assert (hp->h_length == sizeof (struct in_addr));
 325     memset (&a4, 0, sizeof (a4));
 326     a4.sin_family = AF_INET;
 327 #if HAVE_SOCKADDR_IN_SIN_LEN
 328     a4.sin_len = (u_char) sizeof (struct sockaddr_in);
 329 #endif
 330     memcpy (&a4.sin_addr, hp->h_addr_list[0], hp->h_length);
 331     GNUNET_SERVER_transmit_context_append_data (tc, &a4, sizeof (a4),
 332                                                 GNUNET_MESSAGE_TYPE_RESOLVER_RESPONSE);
 333   }
 334   else
 335   {
 336     GNUNET_assert (hp->h_length == sizeof (struct in6_addr));
 337     memset (&a6, 0, sizeof (a6));
 338     a6.sin6_family = AF_INET6;
 339 #if HAVE_SOCKADDR_IN_SIN_LEN
 340     a6.sin6_len = (u_char) sizeof (struct sockaddr_in6);
 341 #endif
 342     memcpy (&a6.sin6_addr, hp->h_addr_list[0], hp->h_length);
 343     GNUNET_SERVER_transmit_context_append_data (tc, &a6, sizeof (a6),
 344                                                 GNUNET_MESSAGE_TYPE_RESOLVER_RESPONSE);
 345   }
 346   return GNUNET_OK;
 347 }
 348 #endif
 349
 350 #if HAVE_GETHOSTBYNAME
 351 static int
 352 gethostbyname_resolve (struct GNUNET_SERVER_TransmitContext *tc,
 353                        const char *hostname)
 354 {
 355   struct hostent *hp;
 356   struct sockaddr_in addr;
 357
 358   hp = GETHOSTBYNAME (hostname);
 359   if (hp == NULL)
 360   {
 361     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
 362                 _("Could not find IP of host `%s': %s\n"), hostname,
 363                 hstrerror (h_errno));
 364     return GNUNET_SYSERR;
 365   }
 366   if (hp->h_addrtype != AF_INET)
 367   {
 368     GNUNET_break (0);
 369     return GNUNET_SYSERR;
 370   }
 371   GNUNET_assert (hp->h_length == sizeof (struct in_addr));
 372   memset (&addr, 0, sizeof (addr));
 373   addr.sin_family = AF_INET;
 374 #if HAVE_SOCKADDR_IN_SIN_LEN
 375   addr.sin_len = (u_char) sizeof (struct sockaddr_in);
 376 #endif
 377   memcpy (&addr.sin_addr, hp->h_addr_list[0], hp->h_length);
 378   GNUNET_SERVER_transmit_context_append_data (tc, &addr, sizeof (addr),
 379                                               GNUNET_MESSAGE_TYPE_RESOLVER_RESPONSE);
 380   return GNUNET_OK;
 381 }
 382 #endif
 383
 384
 385 /**
 386  * Convert a string to an IP address.
 387  *
 388  * @param client where to send the IP address
 389  * @param hostname the hostname to resolve
 390  * @param domain AF_INET or AF_INET6; use AF_UNSPEC for "any"
 391  */
 392 static void
 393 get_ip_from_hostname (struct GNUNET_SERVER_Client *client, const char *hostname,
 394                       int domain)
 395 {
 396   int ret;
 397   struct GNUNET_SERVER_TransmitContext *tc;
 398
 399   tc = GNUNET_SERVER_transmit_context_create (client);
 400   ret = GNUNET_NO;
 401 #if HAVE_GETADDRINFO
 402   if (ret == GNUNET_NO)
 403     ret = getaddrinfo_resolve (tc, hostname, domain);
 404 #endif
 405 #if HAVE_GETHOSTBYNAME2
 406   if (ret == GNUNET_NO)
 407     ret = gethostbyname2_resolve (tc, hostname, domain);
 408 #endif
 409 #if HAVE_GETHOSTBYNAME
 410   if ((ret == GNUNET_NO) && ((domain == AF_UNSPEC) || (domain == PF_INET)))
 411     gethostbyname_resolve (tc, hostname);
 412 #endif
 413   GNUNET_SERVER_transmit_context_append_data (tc, NULL, 0,
 414                                               GNUNET_MESSAGE_TYPE_RESOLVER_RESPONSE);
 415   GNUNET_SERVER_transmit_context_run (tc, GNUNET_TIME_UNIT_FOREVER_REL);
 416 }
 417
 418
 419 /**
 420  * Handle GET-message.
 421  *
 422  * @param cls closure
 423  * @param client identification of the client
 424  * @param message the actual message
 425  */
 426 static void
 427 handle_get (void *cls, struct GNUNET_SERVER_Client *client,
 428             const struct GNUNET_MessageHeader *message)
 429 {
 430   uint16_t msize;
 431   const struct GNUNET_RESOLVER_GetMessage *msg;
 432   const char *hostname;
 433   const struct sockaddr *sa;
 434   uint16_t size;
 435   int direction;
 436   int domain;
 437
 438   msize = ntohs (message->size);
 439   if (msize < sizeof (struct GNUNET_RESOLVER_GetMessage))
 440   {
 441     GNUNET_break (0);
 442     GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
 443     return;
 444   }
 445   msg = (const struct GNUNET_RESOLVER_GetMessage *) message;
 446   size = msize - sizeof (struct GNUNET_RESOLVER_GetMessage);
 447   direction = ntohl (msg->direction);
 448   domain = ntohl (msg->domain);
 449   if (direction == GNUNET_NO)
 450   {
 451     /* IP from hostname */
 452     hostname = (const char *) &msg[1];
 453     if (hostname[size - 1] != '\0')
 454     {
 455       GNUNET_break (0);
 456       GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
 457       return;
 458     }
 459 #if DEBUG_RESOLVER
 460     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, _("Resolver asked to look up `%s'.\n"),
 461                 hostname);
 462 #endif
 463     get_ip_from_hostname (client, hostname, domain);
 464   }
 465   else
 466   {
 467 #if DEBUG_RESOLVER
 468     char buf[INET6_ADDRSTRLEN];
 469 #endif
 470     if (size < sizeof (struct sockaddr))
 471     {
 472       GNUNET_break (0);
 473       GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
 474       return;
 475     }
 476     sa = (const struct sockaddr *) &msg[1];
 477     switch (sa->sa_family)
 478     {
 479     case AF_INET:
 480       if (size != sizeof (struct sockaddr_in))
 481       {
 482         GNUNET_break (0);
 483         GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
 484         return;
 485       }
 486 #if DEBUG_RESOLVER
 487       inet_ntop (AF_INET, sa, buf, size);
 488 #endif
 489       break;
 490     case AF_INET6:
 491       if (size != sizeof (struct sockaddr_in6))
 492       {
 493         GNUNET_break (0);
 494         GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
 495         return;
 496       }
 497 #if DEBUG_RESOLVER
 498       inet_ntop (AF_INET6, sa, buf, size);
 499 #endif
 500       break;
 501     default:
 502       GNUNET_break (0);
 503       GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
 504       return;
 505     }
 506 #if DEBUG_RESOLVER
 507     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
 508                 _("Resolver asked to look up IP address `%s'.\n"), buf);
 509 #endif
 510     get_ip_as_string (client, sa, size);
 511   }
 512 }
 513
 514
 515 /**
 516  * Process resolver requests.
 517  *
 518  * @param cls closure
 519  * @param server the initialized server
 520  * @param cfg configuration to use
 521  */
 522 static void
 523 run (void *cls, struct GNUNET_SERVER_Handle *server,
 524      const struct GNUNET_CONFIGURATION_Handle *cfg)
 525 {
 526   static const struct GNUNET_SERVER_MessageHandler handlers[] = {
 527     {&handle_get, NULL, GNUNET_MESSAGE_TYPE_RESOLVER_REQUEST, 0},
 528     {NULL, NULL, 0, 0}
 529   };
 530   GNUNET_SERVER_add_handlers (server, handlers);
 531 }
 532
 533
 534 /**
 535  * The main function for the resolver service.
 536  *
 537  * @param argc number of arguments from the command line
 538  * @param argv command line arguments
 539  * @return 0 ok, 1 on error
 540  */
 541 int
 542 main (int argc, char *const *argv)
 543 {
 544   int ret;
 545   struct IPCache *pos;
 546
 547   ret =
 548       (GNUNET_OK ==
 549        GNUNET_SERVICE_run (argc, argv, "resolver", GNUNET_SERVICE_OPTION_NONE,
 550                            &run, NULL)) ? 0 : 1;
 551
 552   while (head != NULL)
 553   {
 554     pos = head->next;
 555     GNUNET_free_non_null (head->addr);
 556     GNUNET_free (head->sa);
 557     GNUNET_free (head);
 558     head = pos;
 559   }
 560   return ret;
 561 }
 562
 563 /* end of gnunet-service-resolver.c */