src/dht/gnunet-service-dht.c

   1 /*
   2      This file is part of GNUnet.
   3      Copyright (C) 2009, 2010, 2011, 2016 GNUnet e.V.
   4
   5      GNUnet is free software: you can redistribute it and/or modify it
   6      under the terms of the GNU Affero General Public License as published
   7      by the Free Software Foundation, either version 3 of the License,
   8      or (at your 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      Affero General Public License for more details.
  14
  15      You should have received a copy of the GNU Affero General Public License
  16      along with this program.  If not, see <http://www.gnu.org/licenses/>.
  17 */
  18
  19 /**
  20  * @file dht/gnunet-service-dht.c
  21  * @brief GNUnet DHT service
  22  * @author Christian Grothoff
  23  * @author Nathan Evans
  24  */
  25 #include "platform.h"
  26 #include "gnunet_block_lib.h"
  27 #include "gnunet_util_lib.h"
  28 #include "gnunet_transport_service.h"
  29 #include "gnunet_transport_hello_service.h"
  30 #include "gnunet_hello_lib.h"
  31 #include "gnunet_dht_service.h"
  32 #include "gnunet_statistics_service.h"
  33 #include "gnunet-service-dht.h"
  34 #include "gnunet-service-dht_datacache.h"
  35 #include "gnunet-service-dht_hello.h"
  36 #include "gnunet-service-dht_neighbours.h"
  37 #include "gnunet-service-dht_nse.h"
  38 #include "gnunet-service-dht_routing.h"
  39
  40 /**
  41  * Our HELLO
  42  */
  43 struct GNUNET_MessageHeader *GDS_my_hello;
  44
  45 /**
  46  * Handle to get our current HELLO.
  47  */
  48 static struct GNUNET_TRANSPORT_HelloGetHandle *ghh;
  49
  50 /**
  51  * Hello address expiration
  52  */
  53 struct GNUNET_TIME_Relative hello_expiration;
  54
  55
  56 #include "gnunet-service-dht_clients.c"
  57
  58
  59 /**
  60  * Receive the HELLO from transport service, free current and replace
  61  * if necessary.
  62  *
  63  * @param cls NULL
  64  * @param message HELLO message of peer
  65  */
  66 static void
  67 process_hello (void *cls,
  68                const struct GNUNET_MessageHeader *message)
  69 {
  70   GNUNET_free_non_null (GDS_my_hello);
  71   GDS_my_hello = GNUNET_malloc (ntohs (message->size));
  72   GNUNET_memcpy (GDS_my_hello,
  73                  message,
  74                  ntohs (message->size));
  75 }
  76
  77
  78 /**
  79  * Task run during shutdown.
  80  *
  81  * @param cls unused
  82  */
  83 static void
  84 shutdown_task (void *cls)
  85 {
  86   if (NULL != ghh)
  87   {
  88     GNUNET_TRANSPORT_hello_get_cancel (ghh);
  89     ghh = NULL;
  90   }
  91   GDS_NEIGHBOURS_done ();
  92   GDS_DATACACHE_done ();
  93   GDS_ROUTING_done ();
  94   GDS_HELLO_done ();
  95   GDS_NSE_done ();
  96   if (NULL != GDS_block_context)
  97   {
  98     GNUNET_BLOCK_context_destroy (GDS_block_context);
  99     GDS_block_context = NULL;
 100   }
 101   if (NULL != GDS_stats)
 102   {
 103     GNUNET_STATISTICS_destroy (GDS_stats,
 104                                GNUNET_YES);
 105     GDS_stats = NULL;
 106   }
 107   GNUNET_free_non_null (GDS_my_hello);
 108   GDS_my_hello = NULL;
 109   GDS_CLIENTS_stop ();
 110 }
 111
 112
 113 /**
 114  * Process dht requests.
 115  *
 116  * @param cls closure
 117  * @param c configuration to use
 118  * @param service the initialized service
 119  */
 120 static void
 121 run (void *cls,
 122      const struct GNUNET_CONFIGURATION_Handle *c,
 123      struct GNUNET_SERVICE_Handle *service)
 124 {
 125   GDS_cfg = c;
 126   GDS_service = service;
 127   if (GNUNET_OK !=
 128       GNUNET_CONFIGURATION_get_value_time (c,
 129                                            "transport",
 130                                            "HELLO_EXPIRATION",
 131                                            &hello_expiration))
 132   {
 133     hello_expiration = GNUNET_CONSTANTS_HELLO_ADDRESS_EXPIRATION;
 134   }
 135   GDS_block_context = GNUNET_BLOCK_context_create (GDS_cfg);
 136   GDS_stats = GNUNET_STATISTICS_create ("dht",
 137                                         GDS_cfg);
 138   GNUNET_SERVICE_suspend (GDS_service);
 139   GDS_CLIENTS_init ();
 140   GDS_ROUTING_init ();
 141   GDS_NSE_init ();
 142   GDS_DATACACHE_init ();
 143   GDS_HELLO_init ();
 144   if (GNUNET_OK != GDS_NEIGHBOURS_init ())
 145   {
 146     shutdown_task (NULL);
 147     return;
 148   }
 149   GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
 150                                  NULL);
 151   ghh = GNUNET_TRANSPORT_hello_get (GDS_cfg,
 152                                     GNUNET_TRANSPORT_AC_GLOBAL,
 153                                     &process_hello,
 154                                     NULL);
 155 }
 156
 157
 158 /* Finally, define the main method */
 159 GDS_DHT_SERVICE_INIT("dht", &run);
 160
 161
 162
 163
 164 /* end of gnunet-service-dht.c */