#include "gnunet-service-transport.h"
#include "gnunet-service-transport_plugins.h"
-/**
- * After how long do we expire an address in a HELLO that we just
- * validated? This value is also used for our own addresses when we
- * create a HELLO.
- */
-#define HELLO_ADDRESS_EXPIRATION GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_HOURS, 12)
/**
* How often do we refresh our HELLO (due to expiration concerns)?
/**
* Closure for 'hello_cb'.
- */
+ */
static void *hello_cb_cls;
/**
* Where are we in the DLL?
*/
struct OwnAddressList *addr_pos;
-
+
/**
* When do addresses expire?
*/
/**
* Add an address from the 'OwnAddressList' to the buffer.
- *
+ *
* @param cls the 'struct GeneratorContext'
* @param max maximum number of bytes left
* @param buf where to write the address
size_t ret;
if (NULL == gc->addr_pos)
- return 0;
- ret = GNUNET_HELLO_add_address (gc->addr_pos->plugin_name,
- gc->expiration,
- &gc->addr_pos[1],
- gc->addr_pos->addrlen,
- buf, max);
+ return 0;
+ ret =
+ GNUNET_HELLO_add_address (gc->addr_pos->plugin_name, gc->expiration,
+ &gc->addr_pos[1], gc->addr_pos->addrlen, buf,
+ max);
gc->addr_pos = gc->addr_pos->next;
return ret;
}
* @param tc scheduler context
*/
static void
-refresh_hello_task (void *cls,
- const struct GNUNET_SCHEDULER_TaskContext *tc)
+refresh_hello_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
{
struct GeneratorContext gc;
hello_task = GNUNET_SCHEDULER_NO_TASK;
gc.addr_pos = oal_head;
- gc.expiration = GNUNET_TIME_relative_to_absolute (HELLO_ADDRESS_EXPIRATION);
+ gc.expiration =
+ GNUNET_TIME_relative_to_absolute (GST_HELLO_ADDRESS_EXPIRATION);
GNUNET_free (our_hello);
- our_hello = GNUNET_HELLO_create (&GST_my_public_key,
- &address_generator,
- &gc);
+ our_hello = GNUNET_HELLO_create (&GST_my_public_key, &address_generator, &gc);
#if DEBUG_TRANSPORT
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG | GNUNET_ERROR_TYPE_BULK,
- "Refreshed my `%s', new size is %d\n", "HELLO",
- GNUNET_HELLO_size(our_hello));
+ "Refreshed my `%s', new size is %d\n", "HELLO",
+ GNUNET_HELLO_size (our_hello));
#endif
- GNUNET_STATISTICS_update (GST_stats,
- gettext_noop ("# refreshed my HELLO"),
- 1,
- GNUNET_NO);
+ GNUNET_STATISTICS_update (GST_stats, gettext_noop ("# refreshed my HELLO"), 1,
+ GNUNET_NO);
if (NULL != hello_cb)
- hello_cb (hello_cb_cls, GST_hello_get());
+ hello_cb (hello_cb_cls, GST_hello_get ());
GNUNET_PEERINFO_add_peer (GST_peerinfo, our_hello);
- hello_task
- = GNUNET_SCHEDULER_add_delayed (HELLO_REFRESH_PERIOD,
- &refresh_hello_task,
- NULL);
+ hello_task =
+ GNUNET_SCHEDULER_add_delayed (HELLO_REFRESH_PERIOD, &refresh_hello_task,
+ NULL);
}
{
if (hello_task != GNUNET_SCHEDULER_NO_TASK)
GNUNET_SCHEDULER_cancel (hello_task);
- hello_task
- = GNUNET_SCHEDULER_add_now (&refresh_hello_task,
- NULL);
+ hello_task = GNUNET_SCHEDULER_add_now (&refresh_hello_task, NULL);
}
* @param cb function to call whenever our HELLO changes
* @param cb_cls closure for cb
*/
-void
-GST_hello_start (GST_HelloCallback cb,
- void *cb_cls)
+void
+GST_hello_start (GST_HelloCallback cb, void *cb_cls)
{
hello_cb = cb;
hello_cb_cls = cb_cls;
- our_hello = GNUNET_HELLO_create (&GST_my_public_key,
- NULL, NULL);
+ our_hello = GNUNET_HELLO_create (&GST_my_public_key, NULL, NULL);
refresh_hello ();
}
hello_cb = NULL;
hello_cb_cls = NULL;
if (GNUNET_SCHEDULER_NO_TASK != hello_task)
- {
- GNUNET_SCHEDULER_cancel (hello_task);
- hello_task = GNUNET_SCHEDULER_NO_TASK;
- }
+ {
+ GNUNET_SCHEDULER_cancel (hello_task);
+ hello_task = GNUNET_SCHEDULER_NO_TASK;
+ }
if (NULL != our_hello)
- {
- GNUNET_free (our_hello);
- our_hello = NULL;
- }
+ {
+ GNUNET_free (our_hello);
+ our_hello = NULL;
+ }
}
const struct GNUNET_MessageHeader *
GST_hello_get ()
{
- return (struct GNUNET_MessageHeader*) our_hello;
+ return (struct GNUNET_MessageHeader *) our_hello;
}
* @param plugin_address_len number of bytes in plugin_address
*/
void
-GST_hello_modify_addresses (int addremove,
- const char *plugin_name,
- const void *plugin_address,
- size_t plugin_address_len)
+GST_hello_modify_addresses (int addremove, const char *plugin_name,
+ const void *plugin_address,
+ size_t plugin_address_len)
{
struct OwnAddressList *al;
#if DEBUG_TRANSPORT
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- (add_remove == GNUNET_YES)
- ? "Adding `%s':%s to the set of our addresses\n"
- : "Removing `%s':%s from the set of our addresses\n",
- GST_plugins_a2s (plugin_name,
- addr, addrlen),
- p->short_name);
+ (add_remove ==
+ GNUNET_YES) ? "Adding `%s':%s to the set of our addresses\n" :
+ "Removing `%s':%s from the set of our addresses\n",
+ GST_plugins_a2s (plugin_name, addr, addrlen), p->short_name);
#endif
GNUNET_assert (plugin_address != NULL);
if (GNUNET_NO == addremove)
- {
- for (al = oal_head; al != NULL; al = al->next)
- if ( (plugin_address_len == al->addrlen) &&
- (0 == strcmp (al->plugin_name, plugin_name)) &&
- (0 == memcmp (plugin_address, &al[1], plugin_address_len)) )
- {
- GNUNET_CONTAINER_DLL_remove (oal_head,
- oal_tail,
- al);
- GNUNET_free (al->plugin_name);
- GNUNET_free (al);
- refresh_hello ();
- return;
- }
- /* address to be removed not found!? */
- GNUNET_break (0);
- return;
- }
+ {
+ for (al = oal_head; al != NULL; al = al->next)
+ if ((plugin_address_len == al->addrlen) &&
+ (0 == strcmp (al->plugin_name, plugin_name)) &&
+ (0 == memcmp (plugin_address, &al[1], plugin_address_len)))
+ {
+ GNUNET_CONTAINER_DLL_remove (oal_head, oal_tail, al);
+ GNUNET_free (al->plugin_name);
+ GNUNET_free (al);
+ refresh_hello ();
+ return;
+ }
+ /* address to be removed not found!? */
+ GNUNET_break (0);
+ return;
+ }
al = GNUNET_malloc (sizeof (struct OwnAddressList) + plugin_address_len);
- GNUNET_CONTAINER_DLL_insert (oal_head,
- oal_tail,
- al);
+ GNUNET_CONTAINER_DLL_insert (oal_head, oal_tail, al);
al->plugin_name = GNUNET_strdup (plugin_name);
al->addrlen = plugin_address_len;
memcpy (&al[1], plugin_address, plugin_address_len);
* GNUNET_NO if not
*/
int
-GST_hello_test_address (const char *plugin_name,
- const void *plugin_address,
- size_t plugin_address_len,
- struct GNUNET_CRYPTO_RsaSignature **sig,
- struct GNUNET_TIME_Absolute **sig_expiration)
+GST_hello_test_address (const char *plugin_name, const void *plugin_address,
+ size_t plugin_address_len,
+ struct GNUNET_CRYPTO_RsaSignature **sig,
+ struct GNUNET_TIME_Absolute **sig_expiration)
{
struct OwnAddressList *al;
for (al = oal_head; al != NULL; al = al->next)
- if ( (plugin_address_len == al->addrlen) &&
- (0 == strcmp (al->plugin_name, plugin_name)) &&
- (0 == memcmp (plugin_address, &al[1], plugin_address_len)) )
- {
- *sig = &al->pong_signature;
- *sig_expiration = &al->pong_sig_expires;
- return GNUNET_YES;
- }
+ if ((plugin_address_len == al->addrlen) &&
+ (0 == strcmp (al->plugin_name, plugin_name)) &&
+ (0 == memcmp (plugin_address, &al[1], plugin_address_len)))
+ {
+ *sig = &al->pong_signature;
+ *sig_expiration = &al->pong_sig_expires;
+ return GNUNET_YES;
+ }
*sig = NULL;
*sig_expiration = NULL;
return GNUNET_NO;
projects / oweals / gnunet.git / blobdiff