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

#include "gnunet_pils_service.h"
#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.

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.

void	GCH_shutdown ()
	Shut down the hello subsystem.

struct GNUNET_MessageHeader *	GCH_get_mine ()
	Get own hello message.

Variables
static struct PilsRequest *	pils_requests_head
	PILS Operation DLL.

static struct PilsRequest *	pils_requests_tail
	PILS Operation DLL.

static struct GNUNET_MessageHeader *	mine
	Hello message of local peer.

static struct GNUNET_PEERSTORE_Handle *	peerstore
	Handle to the PEERSTORE service.

static struct GNUNET_PEERSTORE_Monitor *	peerstore_notify
	Our peerstore notification context.

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 38 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 95 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));
  GCD_hello_update ();
}

References GCD_hello_update(), GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_h2s(), GNUNET_HELLO_parser_to_dht_hello_msg(), LOG, and mine.

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

{
  const struct GNUNET_PeerIdentity *my_identity;
  struct CadetPeer *peer;
  struct GNUNET_MessageHeader *hello;
 
  my_identity = GNUNET_PILS_get_identity (pils);
  if (! my_identity)
  {
    /* MUST still ask for the next record.  Returning without doing so stops
       this monitor permanently -- the PEERSTORE service waits for a
       MONITOR_NEXT that never comes -- so CADET would never learn another
       peer's HELLO for the rest of the process's life.  We only need our own
       identity to skip our own HELLO below, so skipping this one record
       while PILS is still answering costs nothing. */
    GNUNET_PEERSTORE_monitor_next (peerstore_notify, 1);
    return;
  }
 
  if (NULL == record->value)
  {
    GNUNET_PEERSTORE_monitor_next (peerstore_notify, 1);
    return;
  }
  hello = record->value;
  if (0 == GNUNET_memcmp (&record->peer, my_identity))
  {
    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_PILS_get_identity(), GNUNET_STRINGS_absolute_time_to_string(), GNUNET_YES, LOG, my_identity, peerstore_notify, pils, 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 168 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 176 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 189 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 215 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;
  }
}