transport_api_monitor.c File Reference

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_protocols.h"
#include "gnunet_transport_monitor_service.h"
#include "transport.h"

Include dependency graph for transport_api_monitor.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_TRANSPORT_MonitorContext
	Opaque handle to the transport service for monitors. More...

Functions
static void	reconnect (struct GNUNET_TRANSPORT_MonitorContext *mc)
	(re)connect our monitor to the transport service
static void	send_start_monitor (struct GNUNET_TRANSPORT_MonitorContext *mc)
	Send message to the transport service about our monitoring desire.
static void	disconnect (struct GNUNET_TRANSPORT_MonitorContext *mc)
	Disconnect from the transport service.
static void	error_handler (void *cls, enum GNUNET_MQ_Error error)
	Function called on MQ errors.
static int	check_monitor_data (void *cls, const struct GNUNET_TRANSPORT_MonitorData *md)
	Transport service sends us information about what is going on.
static void	handle_monitor_data (void *cls, const struct GNUNET_TRANSPORT_MonitorData *md)
	Transport service sends us information about what is going on.
static void	handle_monitor_end (void *cls, const struct GNUNET_MessageHeader *me)
	One shot was requested, and transport service is done.
struct GNUNET_TRANSPORT_MonitorContext *	GNUNET_TRANSPORT_monitor (const struct GNUNET_CONFIGURATION_Handle *cfg, const struct GNUNET_PeerIdentity *peer, int one_shot, GNUNET_TRANSPORT_MonitorCallback cb, void *cb_cls)
	Return information about a specific peer or all peers currently known to transport service once or in monitoring mode.
void	GNUNET_TRANSPORT_monitor_cancel (struct GNUNET_TRANSPORT_MonitorContext *mc)
	Cancel request to monitor peers.

Function Documentation

reconnect()

static void reconnect ( struct GNUNET_TRANSPORT_MonitorContext *  mc )

static

(re)connect our monitor to the transport service

Parameters

mc	handle to reconnect

Definition at line 206 of file transport_api_monitor.c.

{
  struct GNUNET_MQ_MessageHandler handlers[] =
  { GNUNET_MQ_hd_var_size (monitor_data,
                           GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_DATA,
                           struct GNUNET_TRANSPORT_MonitorData,
                           mc),
    GNUNET_MQ_hd_fixed_size (monitor_end,
                             GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_END,
                             struct GNUNET_MessageHeader,
                             mc),
    GNUNET_MQ_handler_end () };
 
  mc->mq =
    GNUNET_CLIENT_connect (mc->cfg, "transport", handlers, &error_handler, mc);
  if (NULL == mc->mq)
    return;
  send_start_monitor (mc);
}

References error_handler(), GNUNET_CLIENT_connect(), GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_DATA, GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_END, GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_hd_var_size, handlers, mc, and send_start_monitor().

Here is the call graph for this function:

send_start_monitor()

static void send_start_monitor ( struct GNUNET_TRANSPORT_MonitorContext *  mc )

static

Send message to the transport service about our monitoring desire.

Parameters

ai	address to delete

Definition at line 86 of file transport_api_monitor.c.

{
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_TRANSPORT_MonitorStart *smm;
 
  if (NULL == mc->mq)
    return;
  env = GNUNET_MQ_msg (smm, GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_START);
  smm->one_shot = htonl ((uint32_t) mc->one_shot);
  smm->peer = mc->peer;
  GNUNET_MQ_send (mc->mq, env);
}

References env, GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_START, GNUNET_MQ_msg, GNUNET_MQ_send(), mc, GNUNET_TRANSPORT_MonitorStart::one_shot, and GNUNET_TRANSPORT_MonitorStart::peer.

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

disconnect()

static void disconnect ( struct GNUNET_TRANSPORT_MonitorContext *  mc )

static

Disconnect from the transport service.

Parameters

mc	service to disconnect from

Definition at line 106 of file transport_api_monitor.c.

{
  if (NULL == mc->mq)
    return;
  GNUNET_MQ_destroy (mc->mq);
  mc->mq = NULL;
}

References GNUNET_MQ_destroy(), and mc.

Referenced by error_handler(), GNUNET_TRANSPORT_monitor_cancel(), and handle_monitor_end().

Here is the call graph for this function:

Here is the caller graph for this function:

error_handler()

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

static

Function called on MQ errors.

Reconnects to the service.

Parameters

cls	our struct GNUNET_TRANSPORT_MonitorContext *
error	what error happened?

Definition at line 122 of file transport_api_monitor.c.

{
  struct GNUNET_TRANSPORT_MonitorContext *mc = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "MQ failure %d, reconnecting to transport service.\n",
              error);
  disconnect (mc);
  /* TODO: maybe do this with exponential backoff/delay */
  reconnect (mc);
}

References disconnect(), GNUNET_ERROR_TYPE_INFO, GNUNET_log, mc, and reconnect().

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

check_monitor_data()

static int check_monitor_data ( void *  cls, const struct GNUNET_TRANSPORT_MonitorData *  md  )

static

Transport service sends us information about what is going on.

Check if md is well-formed.

Parameters

cls	our struct GNUNET_TRANSPORT_MonitorContext *
md	the monitor data we got

Returns

GNUNET_OK if smt is well-formed

Definition at line 144 of file transport_api_monitor.c.

{
  (void) cls;
  GNUNET_MQ_check_zero_termination (md);
  return GNUNET_OK;
}

References GNUNET_MQ_check_zero_termination, and GNUNET_OK.

handle_monitor_data()

static void handle_monitor_data ( void *  cls, const struct GNUNET_TRANSPORT_MonitorData *  md  )

static

Transport service sends us information about what is going on.

Parameters

cls	our struct GNUNET_TRANSPORT_MonitorContext *
md	monitor data

Definition at line 159 of file transport_api_monitor.c.

{
  struct GNUNET_TRANSPORT_MonitorContext *mc = cls;
  struct GNUNET_TRANSPORT_MonitorInformation mi;
 
  mi.address = (const char *) &md[1];
  mi.nt = ntohl (md->nt);
  mi.cs = ntohl (md->cs);
  mi.num_msg_pending = ntohl (md->num_msg_pending);
  mi.num_bytes_pending = ntohl (md->num_bytes_pending);
  mi.last_validation = GNUNET_TIME_absolute_ntoh (md->last_validation);
  mi.valid_until = GNUNET_TIME_absolute_ntoh (md->valid_until);
  mi.next_validation = GNUNET_TIME_absolute_ntoh (md->next_validation);
  mi.rtt = GNUNET_TIME_relative_ntoh (md->rtt);
  mc->cb (mc->cb_cls, &md->peer, &mi);
}

References GNUNET_TRANSPORT_MonitorInformation::address, GNUNET_TRANSPORT_MonitorInformation::cs, GNUNET_TRANSPORT_MonitorData::cs, GNUNET_TIME_absolute_ntoh(), GNUNET_TIME_relative_ntoh(), GNUNET_TRANSPORT_MonitorInformation::last_validation, GNUNET_TRANSPORT_MonitorData::last_validation, mc, GNUNET_TRANSPORT_MonitorInformation::next_validation, GNUNET_TRANSPORT_MonitorData::next_validation, GNUNET_TRANSPORT_MonitorInformation::nt, GNUNET_TRANSPORT_MonitorData::nt, GNUNET_TRANSPORT_MonitorInformation::num_bytes_pending, GNUNET_TRANSPORT_MonitorData::num_bytes_pending, GNUNET_TRANSPORT_MonitorInformation::num_msg_pending, GNUNET_TRANSPORT_MonitorData::num_msg_pending, GNUNET_TRANSPORT_MonitorData::peer, GNUNET_TRANSPORT_MonitorInformation::rtt, GNUNET_TRANSPORT_MonitorData::rtt, GNUNET_TRANSPORT_MonitorInformation::valid_until, and GNUNET_TRANSPORT_MonitorData::valid_until.

Here is the call graph for this function:

handle_monitor_end()

static void handle_monitor_end ( void *  cls, const struct GNUNET_MessageHeader *  me  )

static

One shot was requested, and transport service is done.

Parameters

cls	our struct GNUNET_TRANSPORT_MonitorContext *
me	end message

Definition at line 184 of file transport_api_monitor.c.

{
  struct GNUNET_TRANSPORT_MonitorContext *mc = cls;
 
  if (GNUNET_YES != mc->one_shot)
  {
    GNUNET_break (0);
    disconnect (mc);
    reconnect (mc);
    return;
  }
  mc->cb (mc->cb_cls, NULL, NULL);
  GNUNET_TRANSPORT_monitor_cancel (mc);
}

References disconnect(), GNUNET_break, GNUNET_TRANSPORT_monitor_cancel(), GNUNET_YES, mc, and reconnect().

Here is the call graph for this function: