peerstore_api_monitor.c File Reference

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_protocols.h"
#include "peerstore.h"
#include "peerstore_common.h"
#include "gnunet_peerstore_service.h"

Include dependency graph for peerstore_api_monitor.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_PEERSTORE_Monitor
	Context for a monitor. More...

Macros
#define	LOG(kind, ...)

Functions
static void	handle_sync (void *cls, const struct GNUNET_MessageHeader *msg)
static int	check_result (void *cls, const struct PeerstoreRecordMessage *msg)
	When a response for iterate request is received, check the message is well-formed. More...
static void	handle_result (void *cls, const struct PeerstoreRecordMessage *msg)
	When a response to monitor is received. More...
static void	reconnect (struct GNUNET_PEERSTORE_Monitor *mc)
static void	mq_error_handler (void *cls, enum GNUNET_MQ_Error err)
struct GNUNET_PEERSTORE_Monitor *	GNUNET_PEERSTORE_monitor_start (const struct GNUNET_CONFIGURATION_Handle *cfg, int iterate_first, const char *sub_system, const struct GNUNET_PeerIdentity *peer, const char *key, GNUNET_SCHEDULER_TaskCallback error_cb, void *error_cb_cls, GNUNET_SCHEDULER_TaskCallback sync_cb, void *sync_cb_cls, GNUNET_PEERSTORE_Processor callback, void *callback_cls)
	Request watching a given key The monitoring can be filtered to contain only records matching peer and/or key. More...
void	GNUNET_PEERSTORE_monitor_stop (struct GNUNET_PEERSTORE_Monitor *zm)
	Stop monitoring. More...
void	GNUNET_PEERSTORE_monitor_next (struct GNUNET_PEERSTORE_Monitor *zm, uint64_t limit)
	Calls the monitor processor specified in GNUNET_PEERSTORE_monitor_start for the next record(s). More...

Macro Definition Documentation

LOG

#define LOG	(		kind,
			...
	)

Value:

                                        GNUNET_log_from (kind, "peerstore-monitor-api", \
                                        __VA_ARGS__)

Definition at line 32 of file peerstore_api_monitor.c.

Function Documentation

handle_sync()

static void handle_sync ( void *  cls, const struct GNUNET_MessageHeader *  msg  )

static

Definition at line 121 of file peerstore_api_monitor.c.

{
  struct GNUNET_PEERSTORE_Monitor *mc = cls;
 
  if (NULL != mc->sync_cb)
    mc->sync_cb (mc->sync_cb_cls);
}

References mc.

check_result()

static int check_result ( void *  cls, const struct PeerstoreRecordMessage *  msg  )

static

When a response for iterate request is received, check the message is well-formed.

Parameters

cls	a struct GNUNET_PEERSTORE_Handle *
msg	message received

Definition at line 138 of file peerstore_api_monitor.c.

{
  /* we defer validation to #handle_result */
  return GNUNET_OK;
}

References GNUNET_OK.

handle_result()

static void handle_result ( void *  cls, const struct PeerstoreRecordMessage *  msg  )

static

When a response to monitor is received.

Parameters

cls	a struct GNUNET_PEERSTORE_Handle *
msg	message received

Definition at line 152 of file peerstore_api_monitor.c.

{
  struct GNUNET_PEERSTORE_Monitor *mc = cls;
  struct GNUNET_PEERSTORE_Record *record;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG, "Monitor received RecordMessage\n");
  record = PEERSTORE_parse_record_message (msg);
  if (NULL == record)
  {
    mc->callback (mc->callback_cls,
                  NULL,
                  _ ("Received a malformed response from service."));
  }
  else
  {
    mc->callback (mc->callback_cls, record, NULL);
    PEERSTORE_destroy_record (record);
  }
}

References _, GNUNET_ERROR_TYPE_DEBUG, LOG, mc, msg, PEERSTORE_destroy_record(), PEERSTORE_parse_record_message(), and record().

Here is the call graph for this function:

reconnect()

static void reconnect ( struct GNUNET_PEERSTORE_Monitor *  mc )

static

Definition at line 185 of file peerstore_api_monitor.c.

{
  struct GNUNET_MQ_MessageHandler handlers[] = {
    GNUNET_MQ_hd_fixed_size (sync,
                             GNUNET_MESSAGE_TYPE_PEERSTORE_MONITOR_SYNC,
                             struct GNUNET_MessageHeader,
                             mc),
    GNUNET_MQ_hd_var_size (result,
                           GNUNET_MESSAGE_TYPE_PEERSTORE_RECORD,
                           struct PeerstoreRecordMessage, mc),
    GNUNET_MQ_handler_end ()
  };
  struct GNUNET_MQ_Envelope *env;
  struct PeerstoreMonitorStartMessage *sm;
  size_t key_len = 0;
  size_t ss_size = 0;
 
  if (NULL != mc->mq)
  {
    GNUNET_MQ_destroy (mc->mq);
    mc->error_cb (mc->error_cb_cls);
  }
  mc->mq = GNUNET_CLIENT_connect (mc->cfg,
                                  "peerstore",
                                  handlers,
                                  &mq_error_handler,
                                  mc);
  if (NULL == mc->mq)
    return;
  if (NULL != mc->key)
    key_len = strlen (mc->key) + 1;
  if (NULL != mc->sub_system)
    ss_size = strlen (mc->sub_system) + 1;
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending MONITOR_START\n");
  env = GNUNET_MQ_msg_extra (sm,
                             htons (key_len) + htons (ss_size),
                             GNUNET_MESSAGE_TYPE_PEERSTORE_MONITOR_START);
  sm->iterate_first = htons (mc->iterate_first);
  if (NULL != mc->peer)
  {
    sm->peer = *mc->peer;
    sm->peer_set = htons (GNUNET_YES);
  }
  if (NULL != mc->sub_system)
    GNUNET_memcpy (&sm[1], mc->sub_system, ss_size);
  sm->sub_system_size = htons (ss_size);
  if (NULL != mc->key)
    GNUNET_memcpy (((char*) &sm[1]) + ss_size, mc->key, key_len);
  sm->key_size = htons (key_len);
  GNUNET_MQ_send (mc->mq, env);
}

References env, GNUNET_CLIENT_connect(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_PEERSTORE_MONITOR_START, GNUNET_MESSAGE_TYPE_PEERSTORE_MONITOR_SYNC, GNUNET_MESSAGE_TYPE_PEERSTORE_RECORD, GNUNET_MQ_destroy(), GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_hd_var_size, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_YES, handlers, PeerstoreMonitorStartMessage::iterate_first, PeerstoreMonitorStartMessage::key_size, mc, mq_error_handler(), PeerstoreMonitorStartMessage::peer, PeerstoreMonitorStartMessage::peer_set, result, and PeerstoreMonitorStartMessage::sub_system_size.

Referenced by GNUNET_PEERSTORE_monitor_start(), and mq_error_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

mq_error_handler()

static void mq_error_handler ( void *  cls, enum GNUNET_MQ_Error  err  )

static

Definition at line 176 of file peerstore_api_monitor.c.

{
  struct GNUNET_PEERSTORE_Monitor *mc = cls;
 
  reconnect (mc);
}

References mc, and reconnect().

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function: