*/
#include "platform.h"
#include "gnunet_testbed_service.h"
+#include "testbed_api.h"
+#include "testbed_api_peers.h"
+#include "testbed_api_operations.h"
+
+/**
+ * Generic loggins shorthand
+ */
+#define LOG(kind,...) \
+ GNUNET_log_from (kind, "testbed-api-topology", __VA_ARGS__)
+
+
+/**
+ * Context information for topology operations
+ */
+struct TopologyContext;
+
+
+/**
+ * Representation of an overlay link
+ */
+struct OverlayLink
+{
+
+ /**
+ * An operation corresponding to this link
+ */
+ struct GNUNET_TESTBED_Operation *op;
+
+ /**
+ * The topology context this link is a part of
+ */
+ struct TopologyContext *tc;
+
+ /**
+ * position of peer A's handle in peers array
+ */
+ uint32_t A;
+
+ /**
+ * position of peer B's handle in peers array
+ */
+ uint32_t B;
+
+};
+
+
+/**
+ * Context information for topology operations
+ */
+struct TopologyContext
+{
+ /**
+ * The array of peers
+ */
+ struct GNUNET_TESTBED_Peer **peers;
+
+ /**
+ * An array of links; this array is of size link_array_size
+ */
+ struct OverlayLink *link_array;
+
+ /**
+ * The operation closure
+ */
+ void *op_cls;
+
+ /**
+ * The size of the link array
+ */
+ unsigned int link_array_size;
+
+ /**
+ * should the automatic retry be disabled
+ */
+ int disable_retry;
+
+};
+
+
+/**
+ * Callback to be called when an overlay_link operation complete
+ *
+ * @param cls element of the link_op array which points to the corresponding operation
+ * @param op the operation that has been finished
+ * @param emsg error message in case the operation has failed; will be NULL if
+ * operation has executed successfully.
+ */
+static void
+overlay_link_completed (void *cls,
+ struct GNUNET_TESTBED_Operation *op,
+ const char *emsg)
+{
+ struct OverlayLink *link = cls;
+ struct TopologyContext *tc;
+
+ GNUNET_assert (op == link->op);
+ GNUNET_TESTBED_operation_done (op);
+ link->op = NULL;
+ tc = link->tc;
+ if ((NULL != emsg) && (GNUNET_NO == tc->disable_retry))
+ {
+ LOG (GNUNET_ERROR_TYPE_WARNING,
+ "Error while establishing a link: %s -- Retrying\n", emsg);
+ link->op =
+ GNUNET_TESTBED_overlay_connect (tc->op_cls,
+ &overlay_link_completed,
+ link,
+ tc->peers[link->A],
+ tc->peers[link->B]);
+ return;
+ }
+}
+
+
+
+/**
+ * Function called when a overlay connect operation is ready
+ *
+ * @param cls the Topology context
+ */
+static void
+opstart_overlay_configure_topology (void *cls)
+{
+ struct TopologyContext *tc = cls;
+ unsigned int p;
+
+ for (p = 0; p < tc->link_array_size; p++)
+ {
+ tc->link_array[p].op =
+ GNUNET_TESTBED_overlay_connect (tc->op_cls, &overlay_link_completed,
+ &tc->link_array[p],
+ tc->peers[tc->link_array[p].A],
+ tc->peers[tc->link_array[p].B]);
+ }
+}
+
+
+/**
+ * Callback which will be called when overlay connect operation is released
+ *
+ * @param cls the Topology context
+ */
+static void
+oprelease_overlay_configure_topology (void *cls)
+{
+ struct TopologyContext *tc = cls;
+ unsigned int p;
+
+ if (NULL != tc->link_array)
+ {
+ for (p = 0; p < tc->link_array_size; p++)
+ if (NULL != tc->link_array[p].op)
+ GNUNET_TESTBED_operation_done (tc->link_array[p].op);
+ GNUNET_free (tc->link_array);
+ }
+ GNUNET_free (tc);
+}
/**
*/
struct GNUNET_TESTBED_Operation *
GNUNET_TESTBED_underlay_configure_topology_va (void *op_cls,
- unsigned int num_peers,
- struct GNUNET_TESTBED_Peer **peers,
- enum GNUNET_TESTBED_TopologyOption topo,
- va_list ap)
+ unsigned int num_peers,
+ struct GNUNET_TESTBED_Peer
+ **peers,
+ enum
+ GNUNET_TESTBED_TopologyOption
+ topo, va_list ap)
{
GNUNET_break (0);
return NULL;
*/
struct GNUNET_TESTBED_Operation *
GNUNET_TESTBED_underlay_configure_topology (void *op_cls,
- unsigned int num_peers,
- struct GNUNET_TESTBED_Peer **peers,
- enum GNUNET_TESTBED_TopologyOption topo,
- ...)
+ unsigned int num_peers,
+ struct GNUNET_TESTBED_Peer **peers,
+ enum GNUNET_TESTBED_TopologyOption
+ topo, ...)
{
GNUNET_break (0);
return NULL;
* @param peers array of 'num_peers' with the peers to configure
* @param topo desired underlay topology to use
* @param va topology-specific options
- * @return handle to the operation, NULL if connecting these
+ * @return handle to the operation, NULL if connecting these
* peers is fundamentally not possible at this time (peers
- * not running or underlay disallows)
+ * not running or underlay disallows) or if num_peers is less than 2
*/
struct GNUNET_TESTBED_Operation *
GNUNET_TESTBED_overlay_configure_topology_va (void *op_cls,
- unsigned int num_peers,
- struct GNUNET_TESTBED_Peer *peers,
- enum GNUNET_TESTBED_TopologyOption topo,
- va_list va)
+ unsigned int num_peers,
+ struct GNUNET_TESTBED_Peer **peers,
+ enum GNUNET_TESTBED_TopologyOption
+ topo, va_list va)
{
- GNUNET_break (0);
- return NULL;
+ struct TopologyContext *tc;
+ struct GNUNET_TESTBED_Operation *op;
+ struct GNUNET_TESTBED_Controller *c;
+ enum GNUNET_TESTBED_TopologyOption secondary_option;
+ unsigned int cnt;
+
+ if (num_peers < 2)
+ return NULL;
+ c = peers[0]->controller;
+ tc = GNUNET_malloc (sizeof (struct TopologyContext));
+ tc->peers = peers;
+ tc->op_cls = op_cls;
+ switch (topo)
+ {
+ case GNUNET_TESTBED_TOPOLOGY_LINE:
+ tc->link_array_size = num_peers - 1;
+ tc->link_array = GNUNET_malloc (sizeof (struct OverlayLink) *
+ tc->link_array_size);
+ for (cnt=1; cnt < num_peers; cnt++)
+ {
+ tc->link_array[cnt-1].A = cnt-1;
+ tc->link_array[cnt-1].B = cnt;
+ tc->link_array[cnt-1].tc = tc;
+ }
+ break;
+ case GNUNET_TESTBED_TOPOLOGY_ERDOS_RENYI:
+ tc->link_array_size = va_arg (va, unsigned int);
+ tc->link_array = GNUNET_malloc (sizeof (struct OverlayLink) *
+ tc->link_array_size);
+ for (cnt = 0; cnt < tc->link_array_size; cnt++)
+ {
+ uint32_t A_rand;
+ uint32_t B_rand;
+
+ do {
+ A_rand = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
+ num_peers);
+ B_rand = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
+ num_peers);
+ } while (A_rand == B_rand);
+ tc->link_array[cnt].A = A_rand;
+ tc->link_array[cnt].B = B_rand;
+ tc->link_array[cnt].tc = tc;
+ }
+ break;
+ case GNUNET_TESTBED_TOPOLOGY_CLIQUE:
+ tc->link_array_size = num_peers * (num_peers - 1);
+ tc->link_array = GNUNET_malloc (sizeof (struct OverlayLink) *
+ tc->link_array_size);
+ {
+ unsigned int offset;
+
+ offset = 0;
+ for (cnt=0; cnt < num_peers; cnt++)
+ {
+ unsigned int neighbour;
+
+ for (neighbour=0; neighbour < num_peers; neighbour++)
+ {
+ if (neighbour == cnt)
+ continue;
+ tc->link_array[offset].A = cnt;
+ tc->link_array[offset].B = neighbour;
+ tc->link_array[offset].tc = tc;
+ offset++;
+ }
+ }
+ }
+ break;
+ default:
+ GNUNET_break (0);
+ return NULL;
+ }
+ do
+ {
+ secondary_option = va_arg (va, enum GNUNET_TESTBED_TopologyOption);
+ switch (secondary_option)
+ {
+ case GNUNET_TESTBED_TOPOLOGY_DISABLE_AUTO_RETRY:
+ tc->disable_retry = GNUNET_YES;
+ break;
+ case GNUNET_TESTBED_TOPOLOGY_OPTION_END:
+ break;
+ default:
+ GNUNET_break (0); /* Should not use any other option apart from
+ the ones handled here */
+ GNUNET_free_non_null (tc->link_array);
+ GNUNET_free (tc);
+ return NULL;
+ }
+ } while (GNUNET_TESTBED_TOPOLOGY_OPTION_END != secondary_option);
+ op = GNUNET_TESTBED_operation_create_ (tc,
+ &opstart_overlay_configure_topology,
+ &oprelease_overlay_configure_topology);
+ GNUNET_TESTBED_operation_queue_insert_
+ (c->opq_parallel_topology_config_operations, op);
+ GNUNET_TESTBED_operation_begin_wait_ (op);
+ return op;
}
* @param peers array of 'num_peers' with the peers to configure
* @param topo desired underlay topology to use
* @param ... topology-specific options
- * @return handle to the operation, NULL if connecting these
+ * @return handle to the operation, NULL if connecting these
* peers is fundamentally not possible at this time (peers
- * not running or underlay disallows)
+ * not running or underlay disallows) or if num_peers is less than 2
*/
struct GNUNET_TESTBED_Operation *
-GNUNET_TESTBED_overlay_configure_topology (void *op_cls,
- unsigned int num_peers,
- struct GNUNET_TESTBED_Peer *peers,
- enum GNUNET_TESTBED_TopologyOption topo,
- ...)
+GNUNET_TESTBED_overlay_configure_topology (void *op_cls, unsigned int num_peers,
+ struct GNUNET_TESTBED_Peer **peers,
+ enum GNUNET_TESTBED_TopologyOption
+ topo, ...)
{
- GNUNET_break (0);
- return NULL;
+ struct GNUNET_TESTBED_Operation *op;
+ va_list vargs;
+
+ GNUNET_assert (topo < GNUNET_TESTBED_TOPOLOGY_OPTION_END);
+ va_start (vargs, topo);
+ op = GNUNET_TESTBED_overlay_configure_topology_va (op_cls, num_peers, peers,
+ topo, vargs);
+ va_end (vargs);
+ return op;
}
/* end of testbed_api_topology.c */