src/dht/gnunet-service-xdht_hello.c

   1 /*
   2      This file is part of GNUnet.
   3      (C) 2011 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 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., 59 Temple Place - Suite 330,
  18      Boston, MA 02111-1307, USA.
  19 */
  20
  21 /**
  22  * @file dht/gnunet-service-xdht_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-xdht.h"
  31 #include "gnunet-service-xdht_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 static void
  70 process_hello (void *cls, const struct GNUNET_PeerIdentity *peer,
  71                const struct GNUNET_HELLO_Message *hello, const char *err_msg)
  72 {
  73   struct GNUNET_TIME_Absolute ex;
  74   struct GNUNET_HELLO_Message *hm;
  75
  76   if (hello == NULL)
  77     return;
  78   ex = GNUNET_HELLO_get_last_expiration (hello);
  79   if (0 == GNUNET_TIME_absolute_get_remaining (ex).rel_value_us)
  80     return;
  81   GNUNET_STATISTICS_update (GDS_stats,
  82                             gettext_noop ("# HELLOs obtained from peerinfo"), 1,
  83                             GNUNET_NO);
  84   hm = GNUNET_CONTAINER_multipeermap_get (peer_to_hello, peer);
  85   GNUNET_free_non_null (hm);
  86   hm = GNUNET_malloc (GNUNET_HELLO_size (hello));
  87   memcpy (hm, hello, GNUNET_HELLO_size (hello));
  88   GNUNET_assert (GNUNET_SYSERR !=
  89                  GNUNET_CONTAINER_multipeermap_put (peer_to_hello,
  90                                                     peer, hm,
  91                                                     GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE));
  92 }
  93
  94
  95 /**
  96  * Initialize HELLO subsystem.
  97  */
  98 void
  99 GDS_HELLO_init ()
 100 {
 101   pnc = GNUNET_PEERINFO_notify (GDS_cfg, GNUNET_NO, &process_hello, NULL);
 102   peer_to_hello = GNUNET_CONTAINER_multipeermap_create (256, GNUNET_NO);
 103 }
 104
 105
 106 /**
 107  * Free memory occopied by the HELLO.
 108  */
 109 static int
 110 free_hello (void *cls,
 111             const struct GNUNET_PeerIdentity *key,
 112             void *hello)
 113 {
 114   GNUNET_free (hello);
 115   return GNUNET_OK;
 116 }
 117
 118
 119 /**
 120  * Shutdown HELLO subsystem.
 121  */
 122 void
 123 GDS_HELLO_done ()
 124 {
 125   if (NULL != pnc)
 126   {
 127     GNUNET_PEERINFO_notify_cancel (pnc);
 128     pnc = NULL;
 129   }
 130   if (NULL != peer_to_hello)
 131   {
 132     GNUNET_CONTAINER_multipeermap_iterate (peer_to_hello, &free_hello, NULL);
 133     GNUNET_CONTAINER_multipeermap_destroy (peer_to_hello);
 134   }
 135 }
 136
 137 /* end of gnunet-service-dht_hello.c */