spread knowledge about how to contact us (get HELLO from peerinfo), and remember HELLOs of other peers we have an interest in More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_statistics_service.h"
#include "gnunet_peerstore_service.h"
#include "cadet_protocol.h"
#include "gnunet-service-cadet.h"
#include "gnunet-service-cadet_dht.h"
#include "gnunet-service-cadet_hello.h"
#include "gnunet-service-cadet_peer.h"

Include dependency graph for gnunet-service-cadet_hello.c:

Macros
#define	LOG(level, ...) GNUNET_log_from (level, "cadet-hll", __VA_ARGS__)

Functions
static void	got_hello (void cls, const struct GNUNET_PEERSTORE_Record record, const char *err_msg)
	Process each hello message received from peerinfo. More...

static void	error_cb (void *cls)

static void	sync_cb (void *cls)

void	GCH_init (const struct GNUNET_CONFIGURATION_Handle *c)
	Initialize the hello subsystem. More...

void	GCH_shutdown ()
	Shut down the hello subsystem. More...

const struct GNUNET_MessageHeader *	GCH_get_mine (void)
	Get own hello message. More...

Variables
static struct GNUNET_MessageHeader *	mine
	Hello message of local peer. More...

static struct GNUNET_PEERSTORE_Handle *	peerstore
	Handle to the PEERSTORE service. More...

static struct GNUNET_PEERSTORE_Monitor *	peerstore_notify
	Our peerstore notification context. More...

Detailed Description

spread knowledge about how to contact us (get HELLO from peerinfo), and remember HELLOs of other peers we have an interest in

Author: Bartlomiej Polot; Christian Grothoff

Definition in file gnunet-service-cadet_hello.c.

Macro Definition Documentation

◆ LOG

#define LOG	(	level,
		...
	)	GNUNET_log_from (level, "cadet-hll", __VA_ARGS__)

Definition at line 37 of file gnunet-service-cadet_hello.c.

Function Documentation

◆ got_hello()

static void got_hello	(	void *	cls,
		const struct GNUNET_PEERSTORE_Record *	record,
		const char *	err_msg
	)

static

Process each hello message received from peerinfo.

Parameters

cls	Closure (unused).
id	Identity of the peer.
hello	Hello of the peer.
err_msg	Error message.

Definition at line 65 of file gnunet-service-cadet_hello.c.

{
  struct CadetPeer *peer;
  struct GNUNET_HELLO_Parser *parser;
  struct GNUNET_HELLO_Builder *builder;
  struct GNUNET_MessageHeader *hello;
 
  if (NULL == record->value)
  {
    GNUNET_PEERSTORE_monitor_next (peerstore_notify, 1);
    return;
  }
  hello = record->value;
  if (0 == GNUNET_memcmp (&record->peer,
                          &my_full_id))
  {
    GNUNET_free (mine);
    parser = GNUNET_HELLO_parser_from_msg (hello);
    builder = GNUNET_HELLO_builder_from_parser (parser);
    mine = GNUNET_HELLO_builder_to_dht_hello_msg (builder,
                                                  my_private_key,
                                                  GNUNET_TIME_UNIT_ZERO);
    GNUNET_HELLO_parser_free (parser);
    GNUNET_HELLO_builder_free (builder);
    GCD_hello_update ();
    GNUNET_PEERSTORE_monitor_next (peerstore_notify, 1);
    return;
  }
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Hello for %s (%d bytes), expires on %s\n",
       GNUNET_i2s (&record->peer),
       ntohs (hello->size),
       GNUNET_STRINGS_absolute_time_to_string (
         GNUNET_HELLO_get_expiration_time_from_msg (hello)));
  peer = GCP_get (&record->peer,
                  GNUNET_YES);
  GCP_set_hello (peer,
                 hello);
  GNUNET_PEERSTORE_monitor_next (peerstore_notify, 1);
}

References builder, GCD_hello_update(), GCP_get(), GCP_set_hello(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_HELLO_builder_free(), GNUNET_HELLO_builder_from_parser(), GNUNET_HELLO_builder_to_dht_hello_msg(), GNUNET_HELLO_get_expiration_time_from_msg(), GNUNET_HELLO_parser_free(), GNUNET_HELLO_parser_from_msg(), GNUNET_i2s(), GNUNET_memcmp, GNUNET_PEERSTORE_monitor_next(), GNUNET_STRINGS_absolute_time_to_string(), GNUNET_TIME_UNIT_ZERO, GNUNET_YES, LOG, mine, my_full_id, my_private_key, consensus-simulation::parser, peerstore_notify, record(), and GNUNET_MessageHeader::size.

Referenced by GCH_init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ error_cb()

static void error_cb ( void * cls )

static

Definition at line 111 of file gnunet-service-cadet_hello.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
              "Error in PEERSTORE monitoring\n");
}

References GNUNET_ERROR_TYPE_WARNING, and GNUNET_log.

Referenced by GCH_init().

Here is the caller graph for this function:

◆ sync_cb()

static void sync_cb ( void * cls )

static

Definition at line 119 of file gnunet-service-cadet_hello.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
              "Done with initial PEERSTORE iteration during monitoring\n");
}

References GNUNET_ERROR_TYPE_WARNING, and GNUNET_log.

Referenced by GCH_init().

Here is the caller graph for this function:

◆ GCH_init()

void GCH_init ( const struct GNUNET_CONFIGURATION_Handle * c )

Initialize the hello subsystem.

Parameters

c	Configuration.

Definition at line 132 of file gnunet-service-cadet_hello.c.

{
  GNUNET_assert (NULL == peerstore_notify);
  peerstore = GNUNET_PEERSTORE_connect (c);
  peerstore_notify =
    GNUNET_PEERSTORE_monitor_start (c,
                                    GNUNET_YES,
                                    "peerstore",
                                    NULL,
                                    GNUNET_PEERSTORE_HELLO_KEY,
                                    &error_cb,
                                    NULL,
                                    &sync_cb,
                                    NULL,
                                    &got_hello,
                                    NULL);
}

References error_cb(), GNUNET_assert, GNUNET_PEERSTORE_connect(), GNUNET_PEERSTORE_HELLO_KEY, GNUNET_PEERSTORE_monitor_start(), GNUNET_YES, got_hello(), peerstore, peerstore_notify, and sync_cb().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GCH_shutdown()

void GCH_shutdown ( void )

Shut down the hello subsystem.

Definition at line 155 of file gnunet-service-cadet_hello.c.

{
  if (NULL != peerstore_notify)
  {
    GNUNET_PEERSTORE_monitor_stop (peerstore_notify);
    peerstore_notify = NULL;
  }
  if (NULL != peerstore)
  {
    GNUNET_PEERSTORE_disconnect (peerstore);
    peerstore = NULL;
  }
  if (NULL != mine)
  {
    GNUNET_free (mine);
    mine = NULL;
  }
}

References GNUNET_free, GNUNET_PEERSTORE_disconnect(), GNUNET_PEERSTORE_monitor_stop(), mine, peerstore, and peerstore_notify.

Referenced by shutdown_rest().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GCH_get_mine()

const struct GNUNET_MessageHeader * GCH_get_mine ( void )

Get own hello message.

Returns: Own hello message.

Definition at line 181 of file gnunet-service-cadet_hello.c.

{
  struct GNUNET_HELLO_Builder *builder;
 
  if (NULL == mine)
  {
    builder = GNUNET_HELLO_builder_new (&my_full_id);
    mine = GNUNET_HELLO_builder_to_dht_hello_msg (builder,
                                                  my_private_key,
                                                  GNUNET_TIME_UNIT_ZERO);
    GNUNET_HELLO_builder_free (builder);
  }
  return mine;
}