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:

Data Structures
struct	PilsRequest
	DLL. More...

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

Functions
static void	sign_hello_cb (void cls, const struct GNUNET_HELLO_Parser parser, const struct GNUNET_HashCode *hash)

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...

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

Variables
static struct PilsRequest *	pils_requests_head
	PILS Operation DLL. More...

static struct PilsRequest *	pils_requests_tail
	PILS Operation DLL. More...

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_PILS_Handle *	pils
	Handle to the PILS 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

◆ sign_hello_cb()

static void sign_hello_cb	(	void *	cls,
		const struct GNUNET_HELLO_Parser *	parser,
		const struct GNUNET_HashCode *	hash
	)

static

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

{
 
  GNUNET_free (mine);
  mine = GNUNET_HELLO_parser_to_dht_hello_msg (parser);
  LOG (GNUNET_ERROR_TYPE_INFO,
       "Received new PID information with address hash `%s'\n",
       GNUNET_h2s (hash));
  my_full_id = *GNUNET_HELLO_parser_get_id (parser);
  GCD_hello_update ();
}

References GCD_hello_update(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_h2s(), GNUNET_HELLO_parser_get_id(), GNUNET_HELLO_parser_to_dht_hello_msg(), LOG, mine, my_full_id, and warningfilter::parser.

Referenced by GCH_init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ 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 123 of file gnunet-service-cadet_hello.c.

{
  struct CadetPeer *peer;
  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))
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "Ignoring own HELLOs\n");
    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 GCP_get(), GCP_set_hello(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_HELLO_get_expiration_time_from_msg(), GNUNET_i2s(), GNUNET_memcmp, GNUNET_PEERSTORE_monitor_next(), GNUNET_STRINGS_absolute_time_to_string(), GNUNET_YES, LOG, my_full_id, 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 160 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 168 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 181 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);
  pils = GNUNET_PILS_connect (c,
                              &sign_hello_cb,
                              NULL);
}

References error_cb(), GNUNET_assert, GNUNET_PEERSTORE_connect(), GNUNET_PEERSTORE_HELLO_KEY, GNUNET_PEERSTORE_monitor_start(), GNUNET_PILS_connect(), GNUNET_YES, got_hello(), peerstore, peerstore_notify, pils, sign_hello_cb(), 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 207 of file gnunet-service-cadet_hello.c.

{
  struct PilsRequest *pr;
 
  if (NULL != peerstore_notify)
  {
    GNUNET_PEERSTORE_monitor_stop (peerstore_notify);
    peerstore_notify = NULL;
  }
  if (NULL != peerstore)
  {
    GNUNET_PEERSTORE_disconnect (peerstore);
    peerstore = NULL;
  }
  while (NULL != (pr = pils_requests_head))
  {
    GNUNET_CONTAINER_DLL_remove (pils_requests_head,
                                 pils_requests_tail,
                                 pr);
    if (NULL != pr->op)
      GNUNET_PILS_cancel (pr->op);
    if (NULL != pr->builder)
      GNUNET_HELLO_builder_free (pr->builder);
    GNUNET_free (pr);
  }
  if (NULL != pils)
  {
    GNUNET_PILS_disconnect (pils);
    pils = NULL;
  }
  if (NULL != mine)
  {
    GNUNET_free (mine);
    mine = NULL;
  }
}