/*
This file is part of GNUnet.
- (C) 2008--2013 Christian Grothoff (and other contributing authors)
+ Copyright (C) 2008--2013 Christian Grothoff (and other contributing authors)
GNUnet is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published
/**
* @file testbed/testbed_api_barriers.c
* @brief API implementation for testbed barriers
- * @author Sree Harsha Totakura <sreeharsha@totakura.in>
+ * @author Sree Harsha Totakura <sreeharsha@totakura.in>
*/
#include "platform.h"
* The controller handle given while initiliasing this barrier
*/
struct GNUNET_TESTBED_Controller *c;
-
+
/**
* The name of the barrier
*/
* the closure for the above callback
*/
void *cls;
-
+
/**
* Should the barrier crossed status message be echoed back to the controller?
*/
struct GNUNET_TESTBED_Barrier *barrier;
char *emsg;
const char *name;
- struct GNUNET_HashCode key;
+ struct GNUNET_HashCode key;
size_t emsg_len;
int status;
uint16_t msize;
uint16_t name_len;
-
+
emsg = NULL;
barrier = NULL;
- msize = ntohs (msg->header.size);
+ msize = ntohs (msg->header.size);
name = msg->data;
name_len = ntohs (msg->name_len);
LOG_DEBUG ("Received BARRIER_STATUS msg\n");
struct GNUNET_HashCode key;
size_t name_len;
uint16_t msize;
-
+
GNUNET_assert (quorum <= 100);
GNUNET_assert (NULL != cb);
name_len = strlen (name);
return NULL;
}
LOG_DEBUG ("Initialising barrier `%s'\n", name);
- barrier = GNUNET_malloc (sizeof (struct GNUNET_TESTBED_Barrier));
+ barrier = GNUNET_new (struct GNUNET_TESTBED_Barrier);
barrier->c = controller;
barrier->name = GNUNET_strdup (name);
barrier->cb = cb;
* The name of the barrier
*/
char *name;
-
+
/**
* Then configuration used for the client connection
*/
- struct GNUNET_CONFIGURATION_Handle *cfg;
+ struct GNUNET_CONFIGURATION_Handle *cfg;
/**
* The client connection
struct GNUNET_TESTBED_BarrierWaitHandle *h = cls;
const struct GNUNET_TESTBED_BarrierStatusMsg *msg;
uint16_t msize;
-
+
if (NULL == message)
{
GNUNET_break_op (0);
{
GNUNET_break_op (0);
goto fail;
- }
+ }
msize = ntohs (message->size);
if (msize <= sizeof (struct GNUNET_TESTBED_BarrierStatusMsg))
{
GNUNET_break_op (0);
goto fail;
- }
+ }
msg = (const struct GNUNET_TESTBED_BarrierStatusMsg *) message;
switch (ntohs (msg->status))
{
{
struct GNUNET_TESTBED_BarrierWaitHandle *h = cls;
uint16_t msize;
-
+
h->tx = NULL;
if ((0 == size) || (NULL == buf))
{
GNUNET_CONFIGURATION_destroy (cfg);
return NULL;
}
- h = GNUNET_malloc (sizeof (struct GNUNET_TESTBED_BarrierWaitHandle));
+ h = GNUNET_new (struct GNUNET_TESTBED_BarrierWaitHandle);
h->name = GNUNET_strdup (name);
h->cfg = cfg;
h->conn = GNUNET_CLIENT_connect ("testbed-barrier", h->cfg);
msg->header.size = htons (msize);
(void) memcpy (msg->name, name, name_len);
h->msg = &msg->header;
- h->tx =
+ h->tx =
GNUNET_CLIENT_notify_transmit_ready (h->conn, msize,
GNUNET_TIME_UNIT_FOREVER_REL,
GNUNET_NO,