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