2 This file is part of GNUnet.
3 Copyright (C) 2010,2011 Christian Grothoff (and other contributing authors)
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.
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.
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.
22 * @file transport/gnunet-service-transport_hello.c
23 * @brief hello management implementation
24 * @author Christian Grothoff
27 #include "gnunet_constants.h"
28 #include "gnunet_hello_lib.h"
29 #include "gnunet_peerinfo_service.h"
30 #include "gnunet_statistics_service.h"
31 #include "gnunet-service-transport_hello.h"
32 #include "gnunet-service-transport.h"
33 #include "gnunet-service-transport_plugins.h"
37 * How often do we refresh our HELLO (due to expiration concerns)?
39 #define HELLO_REFRESH_PERIOD GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_HOURS, 6)
42 * Hello address expiration
44 extern struct GNUNET_TIME_Relative hello_expiration;
48 * Entry in linked list of network addresses for ourselves. Also
49 * includes a cached signature for 'struct TransportPongMessage's.
54 * This is a doubly-linked list.
56 struct OwnAddressList *next;
59 * This is a doubly-linked list.
61 struct OwnAddressList *prev;
66 struct GNUNET_HELLO_Address *address;
69 * How long until the current signature expires? (ZERO if the
70 * signature was never created).
72 struct GNUNET_TIME_Absolute pong_sig_expires;
75 * Signature for a 'struct TransportPongMessage' for this address.
77 struct GNUNET_CRYPTO_EddsaSignature pong_signature;
85 static struct GNUNET_HELLO_Message *our_hello;
88 * Function to call on HELLO changes.
90 static GST_HelloCallback hello_cb;
93 * Closure for #hello_cb.
95 static void *hello_cb_cls;
98 * Head of my addresses.
100 static struct OwnAddressList *oal_head;
103 * Tail of my addresses.
105 static struct OwnAddressList *oal_tail;
108 * Should we use a friend-only HELLO?
110 static int friend_option;
113 * Identifier of #refresh_hello_task().
115 static struct GNUNET_SCHEDULER_Task * hello_task;
119 * Closure for #address_generator().
121 struct GeneratorContext
124 * Where are we in the DLL?
126 struct OwnAddressList *addr_pos;
129 * When do addresses expire?
131 struct GNUNET_TIME_Absolute expiration;
136 * Add an address from the 'OwnAddressList' to the buffer.
138 * @param cls the `struct GeneratorContext`
139 * @param max maximum number of bytes left
140 * @param buf where to write the address
141 * @return bytes written or #GNUNET_SYSERR to signal the
142 * end of the iteration.
145 address_generator (void *cls,
149 struct GeneratorContext *gc = cls;
152 if (NULL == gc->addr_pos)
153 return GNUNET_SYSERR; /* Done */
154 ret = GNUNET_HELLO_add_address (gc->addr_pos->address, gc->expiration, buf,
156 gc->addr_pos = gc->addr_pos->next;
162 * Construct our HELLO message from all of the addresses of
163 * all of the transports.
166 * @param tc scheduler context
169 refresh_hello_task (void *cls,
170 const struct GNUNET_SCHEDULER_TaskContext *tc)
172 struct GeneratorContext gc;
175 gc.addr_pos = oal_head;
176 gc.expiration = GNUNET_TIME_relative_to_absolute (hello_expiration);
178 GNUNET_free_non_null (our_hello);
179 our_hello = GNUNET_HELLO_create (&GST_my_identity.public_key,
183 GNUNET_assert (NULL != our_hello);
184 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
185 "Refreshed my %s HELLO, new size is %d\n",
186 (GNUNET_YES == friend_option) ? "friend-only" : "public",
187 GNUNET_HELLO_size (our_hello));
188 GNUNET_STATISTICS_update (GST_stats,
189 gettext_noop ("# refreshed my HELLO"),
192 if (NULL != hello_cb)
193 hello_cb (hello_cb_cls,
195 GNUNET_PEERINFO_add_peer (GST_peerinfo,
200 GNUNET_SCHEDULER_add_delayed (HELLO_REFRESH_PERIOD,
207 * Schedule task to refresh hello (unless such a
208 * task exists already).
213 if (NULL != hello_task)
214 GNUNET_SCHEDULER_cancel (hello_task);
215 hello_task = GNUNET_SCHEDULER_add_now (&refresh_hello_task,
221 * Initialize the HELLO module.
223 * @param friend_only use a friend only hello
224 * @param cb function to call whenever our HELLO changes
225 * @param cb_cls closure for @a cb
228 GST_hello_start (int friend_only,
229 GST_HelloCallback cb,
233 hello_cb_cls = cb_cls;
234 friend_option = friend_only;
240 * Shutdown the HELLO module.
247 if (NULL != hello_task)
249 GNUNET_SCHEDULER_cancel (hello_task);
252 if (NULL != our_hello)
254 GNUNET_free (our_hello);
261 * Obtain this peers HELLO message.
263 * @return our HELLO message
265 const struct GNUNET_MessageHeader *
268 return (struct GNUNET_MessageHeader *) our_hello;
273 * Add or remove an address from this peer's HELLO message.
275 * @param addremove #GNUNET_YES to add, #GNUNET_NO to remove
276 * @param address address to add or remove
279 GST_hello_modify_addresses (int addremove,
280 const struct GNUNET_HELLO_Address *address)
282 struct OwnAddressList *al;
284 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
286 GNUNET_YES) ? "Adding `%s' to the set of our addresses\n" :
287 "Removing `%s' from the set of our addresses\n",
288 GST_plugins_a2s (address));
289 GNUNET_assert (address != NULL);
290 if (GNUNET_NO == addremove)
292 for (al = oal_head; al != NULL; al = al->next)
293 if (0 == GNUNET_HELLO_address_cmp (address, al->address))
295 GNUNET_CONTAINER_DLL_remove (oal_head, oal_tail, al);
296 GNUNET_HELLO_address_free (al->address);
301 /* address to be removed not found!? */
305 al = GNUNET_new (struct OwnAddressList);
306 GNUNET_CONTAINER_DLL_insert (oal_head, oal_tail, al);
307 al->address = GNUNET_HELLO_address_copy (address);
313 * Test if a particular address is one of ours.
315 * @param address address to test
316 * @param sig location where to cache PONG signatures for this address [set]
317 * @param sig_expiration how long until the current 'sig' expires?
318 * (ZERO if sig was never created) [set]
319 * @return #GNUNET_YES if this is one of our addresses,
323 GST_hello_test_address (const struct GNUNET_HELLO_Address *address,
324 struct GNUNET_CRYPTO_EddsaSignature **sig,
325 struct GNUNET_TIME_Absolute **sig_expiration)
327 struct OwnAddressList *al;
329 for (al = oal_head; al != NULL; al = al->next)
330 if (0 == GNUNET_HELLO_address_cmp (address,
333 *sig = &al->pong_signature;
334 *sig_expiration = &al->pong_sig_expires;
338 *sig_expiration = NULL;
343 /* end of file gnunet-service-transport_hello.c */