core_api_monitor_peers.c File Reference

implementation of the peer_iterate function More...

#include "platform.h"
#include "gnunet_core_service.h"
#include "core.h"

Include dependency graph for core_api_monitor_peers.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_CORE_MonitorHandle
	Handle to a CORE monitoring operation. More...

Functions
static void	reconnect (struct GNUNET_CORE_MonitorHandle *mh)
	Protocol error, reconnect to CORE service and notify client. More...
static void	handle_mq_error (void *cls, enum GNUNET_MQ_Error error)
	Generic error handler, called with the appropriate error code and the same closure specified at the creation of the message queue. More...
static void	handle_receive_info (void *cls, const struct MonitorNotifyMessage *mon_message)
	Receive reply from CORE service with information about a peer. More...
struct GNUNET_CORE_MonitorHandle *	GNUNET_CORE_monitor_start (const struct GNUNET_CONFIGURATION_Handle *cfg, GNUNET_CORE_MonitorCallback peer_cb, void *peer_cb_cls)
	Monitor connectivity and KX status of all peers known to CORE. More...
void	GNUNET_CORE_monitor_stop (struct GNUNET_CORE_MonitorHandle *mh)
	Stop monitoring CORE activity. More...

Detailed Description

implementation of the peer_iterate function

Author

Christian Grothoff

Nathan Evans

Definition in file core_api_monitor_peers.c.

Function Documentation

reconnect()

static void reconnect ( struct GNUNET_CORE_MonitorHandle *  mh )

static

Protocol error, reconnect to CORE service and notify client.

Parameters

mh	monitoring session to reconnect to CORE

Definition at line 112 of file core_api_monitor_peers.c.

{
  struct GNUNET_MQ_MessageHandler handlers[] =
  { GNUNET_MQ_hd_fixed_size (receive_info,
                             GNUNET_MESSAGE_TYPE_CORE_MONITOR_NOTIFY,
                             struct MonitorNotifyMessage,
                             mh),
    GNUNET_MQ_handler_end () };
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_MessageHeader *msg;
 
  if (NULL != mh->mq)
    GNUNET_MQ_destroy (mh->mq);
  /* FIXME: use backoff? */
  mh->mq =
    GNUNET_CLIENT_connect (mh->cfg, "core", handlers, &handle_mq_error, mh);
  if (NULL == mh->mq)
    return;
  /* notify callback about reconnect */
  if (NULL != mh->peer_cb)
    mh->peer_cb (mh->peer_cb_cls,
                 NULL,
                 GNUNET_CORE_KX_CORE_DISCONNECT,
                 GNUNET_TIME_UNIT_FOREVER_ABS);
  env = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_CORE_MONITOR_PEERS);
  GNUNET_MQ_send (mh->mq, env);
}

References GNUNET_CADET_Handle::cfg, env, GNUNET_CLIENT_connect(), GNUNET_CORE_KX_CORE_DISCONNECT, GNUNET_MESSAGE_TYPE_CORE_MONITOR_NOTIFY, GNUNET_MESSAGE_TYPE_CORE_MONITOR_PEERS, GNUNET_MQ_destroy(), GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_TIME_UNIT_FOREVER_ABS, handle_mq_error(), handlers, mh, GNUNET_CADET_Handle::mq, and msg.

Referenced by GNUNET_CORE_monitor_start(), and handle_mq_error().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_mq_error()

static void handle_mq_error ( void *  cls, enum GNUNET_MQ_Error  error  )

static

Generic error handler, called with the appropriate error code and the same closure specified at the creation of the message queue.

Not every message queue implementation supports an error handler.

Parameters

cls	closure, a struct GNUNET_CORE_MonitorHandle *
error	error code

Definition at line 78 of file core_api_monitor_peers.c.

{
  struct GNUNET_CORE_MonitorHandle *mh = cls;
 
  (void) error;
  reconnect (mh);
}

References mh, and reconnect().

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_receive_info()

static void handle_receive_info ( void *  cls, const struct MonitorNotifyMessage *  mon_message  )

static

Receive reply from CORE service with information about a peer.

Parameters

cls	our struct GNUNET_CORE_MonitorHandle *
mon_message	monitor message

Definition at line 94 of file core_api_monitor_peers.c.

{
  struct GNUNET_CORE_MonitorHandle *mh = cls;
 
  mh->peer_cb (mh->peer_cb_cls,
               &mon_message->peer,
               (enum GNUNET_CORE_KxState) ntohl (mon_message->state),
               GNUNET_TIME_absolute_ntoh (mon_message->timeout));
}

References GNUNET_TIME_absolute_ntoh(), mh, MonitorNotifyMessage::peer, MonitorNotifyMessage::state, and MonitorNotifyMessage::timeout.

Here is the call graph for this function: