src/dht/gnunet-service-dht_hello.c

   1 /*
   2      This file is part of GNUnet.
   3      Copyright (C) 2011 GNUnet e.V.
   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 3, 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., 51 Franklin Street, Fifth Floor,
  18      Boston, MA 02110-1301, USA.
  19 */
  20
  21 /**
  22  * @file dht/gnunet-service-dht_hello.c
  23  * @brief GNUnet DHT integration with peerinfo
  24  * @author Christian Grothoff
  25  *
  26  * TODO:
  27  * - consider adding mechanism to remove expired HELLOs
  28  */
  29 #include "platform.h"
  30 #include "gnunet-service-dht.h"
  31 #include "gnunet-service-dht_hello.h"
  32 #include "gnunet_peerinfo_service.h"
  33
  34
  35 /**
  36  * Handle for peerinfo notifications.
  37  */
  38 static struct GNUNET_PEERINFO_NotifyContext *pnc;
  39
  40 /**
  41  * Hash map of peers to HELLOs.
  42  */
  43 static struct GNUNET_CONTAINER_MultiPeerMap *peer_to_hello;
  44
  45
  46 /**
  47  * Obtain a peer's HELLO if available
  48  *
  49  * @param peer peer to look for a HELLO from
  50  * @return HELLO for the given peer
  51  */
  52 const struct GNUNET_HELLO_Message *
  53 GDS_HELLO_get (const struct GNUNET_PeerIdentity *peer)
  54 {
  55   if (NULL == peer_to_hello)
  56     return NULL;
  57   return GNUNET_CONTAINER_multipeermap_get (peer_to_hello, peer);
  58 }
  59
  60
  61 /**
  62  * Function called for each HELLO known to PEERINFO.
  63  *
  64  * @param cls closure
  65  * @param peer id of the peer, NULL for last call
  66  * @param hello hello message for the peer (can be NULL)
  67  * @param err_msg error message (not used)
  68  *
  69  * FIXME this is called once per address. Merge instead of replacing?
  70  */
  71 static void
  72 process_hello (void *cls, const struct GNUNET_PeerIdentity *peer,
  73                const struct GNUNET_HELLO_Message *hello, const char *err_msg)
  74 {
  75   struct GNUNET_TIME_Absolute ex;
  76   struct GNUNET_HELLO_Message *hm;
  77
  78   if (hello == NULL)
  79     return;
  80   ex = GNUNET_HELLO_get_last_expiration (hello);
  81   if (0 == GNUNET_TIME_absolute_get_remaining (ex).rel_value_us)
  82     return;
  83   GNUNET_STATISTICS_update (GDS_stats,
  84                             gettext_noop ("# HELLOs obtained from peerinfo"), 1,
  85                             GNUNET_NO);
  86   hm = GNUNET_CONTAINER_multipeermap_get (peer_to_hello, peer);
  87   GNUNET_free_non_null (hm);
  88   hm = GNUNET_malloc (GNUNET_HELLO_size (hello));
  89   memcpy (hm, hello, GNUNET_HELLO_size (hello));
  90   GNUNET_assert (GNUNET_SYSERR !=
  91                  GNUNET_CONTAINER_multipeermap_put (peer_to_hello,
  92                                                     peer, hm,
  93                                                     GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE));
  94 }
  95
  96
  97 /**
  98  * Initialize HELLO subsystem.
  99  */
 100 void
 101 GDS_HELLO_init ()
 102 {
 103   pnc = GNUNET_PEERINFO_notify (GDS_cfg, GNUNET_NO, &process_hello, NULL);
 104   peer_to_hello = GNUNET_CONTAINER_multipeermap_create (256, GNUNET_NO);
 105 }
 106
 107
 108 /**
 109  * Free memory occopied by the HELLO.
 110  */
 111 static int
 112 free_hello (void *cls,
 113             const struct GNUNET_PeerIdentity *key,
 114             void *hello)
 115 {
 116   GNUNET_free (hello);
 117   return GNUNET_OK;
 118 }
 119
 120
 121 /**
 122  * Shutdown HELLO subsystem.
 123  */
 124 void
 125 GDS_HELLO_done ()
 126 {
 127   if (NULL != pnc)
 128   {
 129     GNUNET_PEERINFO_notify_cancel (pnc);
 130     pnc = NULL;
 131   }
 132   if (NULL != peer_to_hello)
 133   {
 134     GNUNET_CONTAINER_multipeermap_iterate (peer_to_hello, &free_hello, NULL);
 135     GNUNET_CONTAINER_multipeermap_destroy (peer_to_hello);
 136   }
 137 }
 138
 139 /* end of gnunet-service-dht_hello.c */