testbed_api_barriers.c File Reference

API implementation for testbed barriers. More...

#include "platform.h"
#include "gnunet_testbed_service.h"
#include "testbed_api.h"

Include dependency graph for testbed_api_barriers.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_TESTBED_BarrierWaitHandle
	Barrier wait handle. More...

Macros
#define	LOG(type, ...)    GNUNET_log_from (type, "testbed-api-barriers", __VA_ARGS__);
	Logging shorthand. More...
#define	LOG_DEBUG(...)    LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__);
	Debug logging shorthand. More...

Functions
static int	check_status (void *cls, const struct GNUNET_TESTBED_BarrierStatusMsg *msg)
	Check if barrier status message is well-formed. More...
static void	handle_status (void *cls, const struct GNUNET_TESTBED_BarrierStatusMsg *msg)
	Type of a function to call when we receive a message from the service. More...
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. More...
struct GNUNET_TESTBED_BarrierWaitHandle *	GNUNET_TESTBED_barrier_wait (const char *name, GNUNET_TESTBED_barrier_wait_cb cb, void *cb_cls)
	Wait for a barrier to be crossed. More...
void	GNUNET_TESTBED_barrier_wait_cancel (struct GNUNET_TESTBED_BarrierWaitHandle *h)
	Cancel a barrier wait handle. More...

Detailed Description

API implementation for testbed barriers.

Author

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

Definition in file testbed_api_barriers.c.

Macro Definition Documentation

LOG

#define LOG	(		type,
			...
	)		GNUNET_log_from (type, "testbed-api-barriers", __VA_ARGS__);

Logging shorthand.

Definition at line 33 of file testbed_api_barriers.c.

LOG_DEBUG

#define LOG_DEBUG

(

...

)

LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__);

Debug logging shorthand.

Definition at line 39 of file testbed_api_barriers.c.

Function Documentation

check_status()

static int check_status ( void *  cls, const struct GNUNET_TESTBED_BarrierStatusMsg *  msg  )

static

Check if barrier status message is well-formed.

Parameters

cls	closure
msg	received message

Returns

GNUNET_OK if the message is well-formed.

Definition at line 83 of file testbed_api_barriers.c.

{
  /* FIXME: this fails to actually check that the message
     follows the protocol spec (0-terminations!).  However,
     not critical as #handle_status() doesn't interpret the
     variable-size part anyway right now. */
  return GNUNET_OK;
}

References GNUNET_OK.

handle_status()

static void handle_status ( void *  cls, const struct GNUNET_TESTBED_BarrierStatusMsg *  msg  )

static

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

Parameters

cls	closure
msg	received message

Definition at line 102 of file testbed_api_barriers.c.

{
  struct GNUNET_TESTBED_BarrierWaitHandle *h = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Got barrier status %d\n",
              (int) ntohs (msg->status));
  switch (ntohs (msg->status))
  {
  case GNUNET_TESTBED_BARRIERSTATUS_ERROR:
    h->cb (h->cb_cls,
           h->name,
           GNUNET_SYSERR);
    break;
 
  case GNUNET_TESTBED_BARRIERSTATUS_INITIALISED:
    h->cb (h->cb_cls,
           h->name,
           GNUNET_SYSERR);
    GNUNET_break (0);
    break;
 
  case GNUNET_TESTBED_BARRIERSTATUS_CROSSED:
    h->cb (h->cb_cls,
           h->name,
           GNUNET_OK);
    break;
 
  default:
    GNUNET_break_op (0);
    h->cb (h->cb_cls,
           h->name,
           GNUNET_SYSERR);
    break;
  }
  GNUNET_TESTBED_barrier_wait_cancel (h);
}

References GNUNET_break, GNUNET_break_op, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_OK, GNUNET_SYSERR, GNUNET_TESTBED_barrier_wait_cancel(), GNUNET_TESTBED_BARRIERSTATUS_CROSSED, GNUNET_TESTBED_BARRIERSTATUS_ERROR, GNUNET_TESTBED_BARRIERSTATUS_INITIALISED, h, and msg.

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_TESTBED_BarrierWaitHandle *
error	error code

Definition at line 151 of file testbed_api_barriers.c.

{
  struct GNUNET_TESTBED_BarrierWaitHandle *h = cls;
 
  h->cb (h->cb_cls,
         h->name,
         GNUNET_SYSERR);
  GNUNET_TESTBED_barrier_wait_cancel (h);
}

References GNUNET_SYSERR, GNUNET_TESTBED_barrier_wait_cancel(), and h.

Referenced by GNUNET_TESTBED_barrier_wait().

Here is the call graph for this function:

Here is the caller graph for this function: