testbed_logger_api.c File Reference

Client-side routines for communicating with the tesbted logger service. More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_testbed_logger_service.h"

Include dependency graph for testbed_logger_api.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_TESTBED_LOGGER_Handle
	Connection handle for the logger service. More...

Macros
#define	LOG(kind, ...)    GNUNET_log_from (kind, "testbed-logger-api", __VA_ARGS__)
	Generic logging shorthand. More...
#define	BUFFER_SIZE
	The size of the buffer we fill before sending out the message. More...

Functions
static void	call_flush_completion (void *cls)
	Task to call the flush completion notification. More...
static void	trigger_flush_notification (struct GNUNET_TESTBED_LOGGER_Handle *h)
	Schedule the flush completion notification task. More...
static void	dispatch_buffer (struct GNUNET_TESTBED_LOGGER_Handle *h)
	Send the buffered data to the service. More...
static void	notify_sent (void *cls)
	MQ successfully sent a message. More...
static void	mq_error_handler (void *cls, enum GNUNET_MQ_Error error)
	We got disconnected from the logger. More...
struct GNUNET_TESTBED_LOGGER_Handle *	GNUNET_TESTBED_LOGGER_connect (const struct GNUNET_CONFIGURATION_Handle *cfg)
	Connect to the testbed logger service. More...
void	GNUNET_TESTBED_LOGGER_disconnect (struct GNUNET_TESTBED_LOGGER_Handle *h)
	Disconnect from the logger service. More...
void	GNUNET_TESTBED_LOGGER_write (struct GNUNET_TESTBED_LOGGER_Handle *h, const void *data, size_t size)
	Send data to be logged to the logger service. More...
void	GNUNET_TESTBED_LOGGER_flush (struct GNUNET_TESTBED_LOGGER_Handle *h, GNUNET_TESTBED_LOGGER_FlushCompletion cb, void *cb_cls)
	Flush the buffered data to the logger service. More...
void	GNUNET_TESTBED_LOGGER_flush_cancel (struct GNUNET_TESTBED_LOGGER_Handle *h)
	Cancel notification upon flush. More...

Detailed Description

Client-side routines for communicating with the tesbted logger service.

Author

Sree Harsha Totakura sreeh.nosp@m.arsh.nosp@m.a@tot.nosp@m.akur.nosp@m.a.in

Christian Grothoff

Definition in file testbed_logger_api.c.

Macro Definition Documentation

LOG

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

Generic logging shorthand.

Definition at line 35 of file testbed_logger_api.c.

BUFFER_SIZE

#define BUFFER_SIZE

Value:

                                                      (GNUNET_MAX_MESSAGE_SIZE - sizeof(struct \
                                                      GNUNET_MessageHeader))

The size of the buffer we fill before sending out the message.

Definition at line 42 of file testbed_logger_api.c.

Function Documentation

call_flush_completion()

static void call_flush_completion ( void *  cls )

static

Task to call the flush completion notification.

Parameters

cls	the logger handle

Definition at line 103 of file testbed_logger_api.c.

{
  struct GNUNET_TESTBED_LOGGER_Handle *h = cls;
  GNUNET_TESTBED_LOGGER_FlushCompletion cb;
  void *cb_cls;
  size_t bw;
 
  h->flush_completion_task = NULL;
  bw = h->bwrote;
  h->bwrote = 0;
  cb = h->cb;
  h->cb = NULL;
  cb_cls = h->cb_cls;
  h->cb_cls = NULL;
  if (NULL != cb)
    cb (cb_cls, bw);
}

References bw, GNUNET_TESTBED_LOGGER_Handle::cb, GNUNET_TESTBED_LOGGER_Handle::cb_cls, and h.

Referenced by trigger_flush_notification().

Here is the caller graph for this function:

trigger_flush_notification()

static void trigger_flush_notification ( struct GNUNET_TESTBED_LOGGER_Handle *  h )

static

Schedule the flush completion notification task.

Parameters

h	logger handle

Definition at line 128 of file testbed_logger_api.c.

{
  if (NULL != h->flush_completion_task)
    GNUNET_SCHEDULER_cancel (h->flush_completion_task);
  h->flush_completion_task
    = GNUNET_SCHEDULER_add_now (&call_flush_completion,
                                h);
}

References call_flush_completion(), GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_cancel(), and h.

Referenced by GNUNET_TESTBED_LOGGER_flush(), and notify_sent().

Here is the call graph for this function:

Here is the caller graph for this function:

dispatch_buffer()

static void dispatch_buffer ( struct GNUNET_TESTBED_LOGGER_Handle *  h )

static

Send the buffered data to the service.

Parameters

h	the logger handle

Definition at line 175 of file testbed_logger_api.c.

{
  struct GNUNET_MessageHeader *msg;
  struct GNUNET_MQ_Envelope *env;
 
  env = GNUNET_MQ_msg_extra (msg,
                             h->buse,
                             GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG);
  GNUNET_memcpy (&msg[1],
                 h->buf,
                 h->buse);
  h->bwrote += h->buse;
  h->buse = 0;
  h->mq_len++;
  GNUNET_MQ_notify_sent (env,
                         &notify_sent,
                         h);
  GNUNET_MQ_send (h->mq,
                  env);
}

References env, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG, GNUNET_MQ_msg_extra, GNUNET_MQ_notify_sent(), GNUNET_MQ_send(), h, GNUNET_ARM_Handle::mq, msg, and notify_sent().

Referenced by GNUNET_TESTBED_LOGGER_flush(), GNUNET_TESTBED_LOGGER_write(), and notify_sent().

Here is the call graph for this function:

Here is the caller graph for this function:

notify_sent()

static void notify_sent ( void *  cls )

static

MQ successfully sent a message.

Parameters

cls	our handle

Definition at line 153 of file testbed_logger_api.c.

{
  struct GNUNET_TESTBED_LOGGER_Handle *h = cls;
 
  h->mq_len--;
  if ((0 == h->mq_len) &&
      (NULL != h->cb))
  {
    if (0 == h->buse)
      trigger_flush_notification (h);
    else
      dispatch_buffer (h);
  }
}

References dispatch_buffer(), h, and trigger_flush_notification().

Referenced by dispatch_buffer().

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  error  )

static

We got disconnected from the logger.

Stop logging.

Parameters

cls	the struct GNUNET_TESTBED_LOGGER_Handle
error	error code

Definition at line 204 of file testbed_logger_api.c.

{
  struct GNUNET_TESTBED_LOGGER_Handle *h = cls;
 
  GNUNET_break (0);
  GNUNET_MQ_destroy (h->mq);
  h->mq = NULL;
}

References GNUNET_break, GNUNET_MQ_destroy(), h, and GNUNET_ARM_Handle::mq.

Referenced by GNUNET_TESTBED_LOGGER_connect().

Here is the call graph for this function:

Here is the caller graph for this function: