nse_api.c File Reference

api to get information from the network size estimation service More...

#include "platform.h"
#include "gnunet_constants.h"
#include "gnunet_arm_service.h"
#include "gnunet_protocols.h"
#include "gnunet_util_lib.h"
#include "gnunet_nse_service.h"
#include "nse.h"

Include dependency graph for nse_api.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_NSE_Handle
	Handle for talking with the NSE service. More...

Macros
#define	LOG(kind, ...)   GNUNET_log_from (kind, "nse-api", __VA_ARGS__)

Functions
static void	reconnect (void *cls)
	Try again to connect to network size estimation service.
static void	mq_error_handler (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.
static void	handle_estimate (void *cls, const struct GNUNET_NSE_ClientMessage *client_msg)
	Type of a function to call when we receive a message from the service.
struct GNUNET_NSE_Handle *	GNUNET_NSE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg, GNUNET_NSE_Callback func, void *func_cls)
	Connect to the network size estimation service.
void	GNUNET_NSE_disconnect (struct GNUNET_NSE_Handle *h)
	Disconnect from network size estimation service.

Detailed Description

api to get information from the network size estimation service

Author

Nathan Evans

Definition in file nse_api.c.

Macro Definition Documentation

LOG

#define LOG	(		kind,
			...
	)		GNUNET_log_from (kind, "nse-api", __VA_ARGS__)

Definition at line 34 of file nse_api.c.

Function Documentation

reconnect()

static void reconnect ( void *  cls )

static

Try again to connect to network size estimation service.

Parameters

cls	closure with the struct GNUNET_NSE_Handle *
cls	the struct GNUNET_NSE_Handle *

Definition at line 131 of file nse_api.c.

{
  struct GNUNET_NSE_Handle *h = cls;
  struct GNUNET_MQ_MessageHandler handlers[] =
  { GNUNET_MQ_hd_fixed_size (estimate,
                             GNUNET_MESSAGE_TYPE_NSE_ESTIMATE,
                             struct GNUNET_NSE_ClientMessage,
                             h),
    GNUNET_MQ_handler_end () };
  struct GNUNET_MessageHeader *msg;
  struct GNUNET_MQ_Envelope *env;
 
  h->reconnect_task = NULL;
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Connecting to network size estimation service.\n");
  GNUNET_assert (NULL == h->mq);
  h->mq = GNUNET_CLIENT_connect (h->cfg, "nse", handlers, &mq_error_handler, h);
  if (NULL == h->mq)
    return;
  env = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_NSE_START);
  GNUNET_MQ_send (h->mq, env);
}

References GNUNET_ARM_Handle::cfg, env, GNUNET_assert, GNUNET_CLIENT_connect(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_MESSAGE_TYPE_NSE_ESTIMATE, GNUNET_MESSAGE_TYPE_NSE_START, GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_msg, GNUNET_MQ_send(), h, handlers, LOG, GNUNET_ARM_Handle::mq, mq_error_handler(), msg, and GNUNET_ARM_Handle::reconnect_task.

Here is the call graph for this function:

mq_error_handler()

static void mq_error_handler ( 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 with the struct GNUNET_NSE_Handle *
error	error code

Definition at line 92 of file nse_api.c.

{
  struct GNUNET_NSE_Handle *h = cls;
 
  (void) error;
  GNUNET_MQ_destroy (h->mq);
  h->mq = NULL;
  h->reconnect_task =
    GNUNET_SCHEDULER_add_delayed (h->reconnect_delay, &reconnect, h);
  h->reconnect_delay = GNUNET_TIME_STD_BACKOFF (h->reconnect_delay);
}

References GNUNET_MQ_destroy(), GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_STD_BACKOFF, h, GNUNET_ARM_Handle::mq, reconnect(), and GNUNET_ARM_Handle::reconnect_task.

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_estimate()

static void handle_estimate ( void *  cls, const struct GNUNET_NSE_ClientMessage *  client_msg  )

static

Type of a function to call when we receive a message from the service.

Parameters

cls	closure
client_msg	message received

Definition at line 113 of file nse_api.c.

{
  struct GNUNET_NSE_Handle *h = cls;
 
  h->reconnect_delay = GNUNET_TIME_UNIT_ZERO;
  h->recv_cb (h->recv_cb_cls,
              GNUNET_TIME_absolute_ntoh (client_msg->timestamp),
              GNUNET_ntoh_double (client_msg->size_estimate),
              GNUNET_ntoh_double (client_msg->std_deviation));
}

References GNUNET_ntoh_double(), GNUNET_TIME_absolute_ntoh(), GNUNET_TIME_UNIT_ZERO, h, GNUNET_NSE_ClientMessage::size_estimate, GNUNET_NSE_ClientMessage::std_deviation, and GNUNET_NSE_ClientMessage::timestamp.

Here is the call graph for this function: