testing_api_topology.c

Go to the documentation of this file.

/*
      This file is part of GNUnet
      Copyright (C) 2008, 2009, 2012 GNUnet e.V.
 
      GNUnet is free software: you can redistribute it and/or modify it
      under the terms of the GNU Affero General Public License as published
      by the Free Software Foundation, either version 3 of the License,
      or (at your option) any later version.
 
      GNUnet is distributed in the hope that it will be useful, but
      WITHOUT ANY WARRANTY; without even the implied warranty of
      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
      Affero General Public License for more details.
 
      You should have received a copy of the GNU Affero General Public License
      along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
     SPDX-License-Identifier: AGPL3.0-or-later
 */
 
#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_testing_lib.h"
#include "testing_api_topology.h"
#include "testing_cmds.h"
 
#define LOG(kind, ...) GNUNET_log_from (kind, "testing-api", __VA_ARGS__)
 
#define CONNECT_ADDRESS_TEMPLATE "%s-192.168.15.%u"
 
#define ROUTER_CONNECT_ADDRESS_TEMPLATE "%s-92.68.150.%u"
 
#define KNOWN_CONNECT_ADDRESS_TEMPLATE "%s-92.68.151.%u"
 
#define PREFIX_TCP "tcp"
 
#define PREFIX_UDP "udp"
 
#define PREFIX_TCP_NATTED "tcp_natted"
 
#define PREFIX_UDP_NATTED "udp_natted"
 
 
static unsigned int
get_first_value (const char *line)
{
  const char *colon = strchr (line, ':');
  char dummy;
  int ret;
 
  GNUNET_assert (NULL != colon);
  ret = sscanf (colon + 1,
                "%u%c",
                &ret,
                &dummy);
  if (2 == ret)
    GNUNET_assert (':' == dummy);
  else
    GNUNET_assert (1 == ret);
  return ret;
}
 
 
static char *
get_key (const char *line)
{
  const char *colon = strchr (line, ':');
 
  GNUNET_assert (NULL != colon);
  return GNUNET_strndup (line,
                         colon - line);
}
 
 
// FIXME: avoid strdup, return const?
static char *
get_first_string_value (const char *line)
{
  const char *colon = strchr (line, ':');
 
  GNUNET_assert (NULL != colon);
  return GNUNET_strdup (colon + 1);
}
 
 
static unsigned int
get_second_value (const char *line)
{
  const char *colon;
  char dummy;
  int ret;
 
  colon = strchr (line, ':');
  GNUNET_assert (NULL != colon);
  colon = strchr (colon + 1, ':');
  GNUNET_assert (NULL != colon);
  GNUNET_assert (1 ==
                 sscanf (colon + 1,
                         "%u%c",
                         &ret,
                         &dummy));
  return ret;
}
 
 
static char *
get_value (const char *key, const char *line)
{
  char copy[strlen (line) + 1];
  size_t slen;
  char *token;
  char *token2;
  char *temp;
  char *rest = NULL;
 
  slen = strlen (line) + 1;
  memcpy (copy, line, slen);
  temp = strstr (copy, key);
  if (NULL == temp)
    return NULL;
  token = strtok_r (temp, ":", &rest);
  if (NULL == token)
    return NULL;
  token = strtok_r (NULL, ":", &rest);
  if (NULL == token)
    return NULL;
  token2 = strtok_r (token, "}", &rest);
  if (NULL == token2)
    return NULL;
  return GNUNET_strdup (token2);
}
 
 
static struct GNUNET_TESTING_NodeConnection *
get_connect_value (const char *line,
                   struct GNUNET_TESTING_NetjailNode *node)
{
  struct GNUNET_TESTING_NodeConnection *node_connection;
  char *copy;
  char *token;
  char *token2;
  unsigned int node_n;
  unsigned int namespace_n;
  char *rest = NULL;
  char *rest2 = NULL;
  struct GNUNET_TESTING_AddressPrefix *prefix;
  unsigned int sscanf_ret;
 
  node_connection = GNUNET_new (struct GNUNET_TESTING_NodeConnection);
  node_connection->node = node;
 
  copy = GNUNET_strdup (line);
  token = strtok_r (copy, ":", &rest);
  if (0 == strcmp ("{K", token))
  {
    node_connection->node_type = GNUNET_TESTING_GLOBAL_NODE;
    token = strtok_r (NULL, ":", &rest);
    GNUNET_assert (1 == sscanf (token, "%u", &node_n));
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "node_n %u\n",
         node_n);
    node_connection->node_n = node_n;
    node_connection->namespace_n = 0;
  }
  else if (0 == strcmp ("{P", token))
  {
    node_connection->node_type = GNUNET_TESTING_SUBNET_NODE;
    token = strtok_r (NULL, ":", &rest);
    errno = 0;
    sscanf_ret = sscanf (token, "%u", &namespace_n);
    if (errno != 0)
    {
      GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "sscanf");
    }
    GNUNET_assert (0 < sscanf_ret);
    node_connection->namespace_n = namespace_n;
    token = strtok_r (NULL, ":", &rest);
    errno = 0;
    sscanf_ret = sscanf (token, "%u", &node_n);
    if (errno != 0)
    {
      GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "sscanf");
    }
    GNUNET_assert (0 < sscanf_ret);
    node_connection->node_n = node_n;
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "node_n %u namespace_n %u node->node_n %u node->namespace_n %u\n",
         node_n,
         namespace_n,
         node->node_n,
         node->namespace_n);
  }
  else
  {
    GNUNET_break (0);
    GNUNET_free (node_connection);
    GNUNET_free (copy);
    return NULL;
  }
 
  while (NULL != (token = strtok_r (NULL, ":", &rest)))
  {
    prefix = GNUNET_new (struct GNUNET_TESTING_AddressPrefix);
    token2 = strtok_r (token, "}", &rest2);
    if (NULL != token2)
      prefix->address_prefix = GNUNET_strdup (token2);
    else
      prefix->address_prefix = GNUNET_strdup (token);
 
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "address_prefix %s\n",
         prefix->address_prefix);
 
    GNUNET_CONTAINER_DLL_insert (node_connection->address_prefixes_head,
                                 node_connection->address_prefixes_tail,
                                 prefix);
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "address_prefix %s\n",
         prefix->address_prefix);
  }
 
  GNUNET_free (copy);
  return node_connection;
}
 
 
static void
node_connections (const char *line,
                  struct GNUNET_TESTING_NetjailNode *node)
{
  char *value, *value2;
  char *temp;
  char *copy;
  char *rest = NULL;
  char *rest2 = NULL;
  struct GNUNET_TESTING_NodeConnection *node_connection;
 
  temp = strstr (line, "connect");
  if (NULL != temp)
  {
    copy = GNUNET_strdup (temp);
    strtok_r (copy, ":", &rest);
    value = strtok_r (rest, "|", &rest2);
 
    while (NULL != value)
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "node_connections value %s\n",
           value);
      node_connection = get_connect_value (value, node);
      if (NULL == node_connection)
      {
        LOG (GNUNET_ERROR_TYPE_WARNING,
             "connect key was not expected in this configuration line: %s\n",
             line);
        break;
      }
      GNUNET_CONTAINER_DLL_insert (node->node_connections_head,
                                   node->node_connections_tail,
                                   node_connection);
      value2 = strstr (value, "}}");
      if (NULL != value2)
        break;
      value = strtok_r (NULL, "|", &rest2);
 
    }
    GNUNET_free (copy);
  }
}
 
 
static int
log_nodes (void *cls,
           const struct GNUNET_ShortHashCode *id,
           void *value)
{
  struct GNUNET_TESTING_NetjailNode *node = value;
  struct GNUNET_TESTING_NodeConnection *pos_connection;
  struct GNUNET_TESTING_AddressPrefix *pos_prefix;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "plugin: %s space: %u node: %u global: %u\n",
       node->plugin,
       node->namespace_n,
       node->node_n,
       node->is_global);
 
  for (pos_connection = node->node_connections_head; NULL != pos_connection;
       pos_connection = pos_connection->next)
  {
 
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "namespace_n: %u node_n: %u node_type: %u\n",
         pos_connection->namespace_n,
         pos_connection->node_n,
         pos_connection->node_type);
 
    for (pos_prefix = pos_connection->address_prefixes_head; NULL != pos_prefix;
         pos_prefix =
           pos_prefix->next)
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "prefix: %s\n",
           pos_prefix->address_prefix);
    }
  }
  return GNUNET_YES;
}
 
 
static int
log_namespaces (void *cls,
                const struct GNUNET_ShortHashCode *id,
                void *value)
{
  struct GNUNET_TESTING_NetjailNamespace *namespace = value;
 
  GNUNET_CONTAINER_multishortmap_iterate (namespace->nodes,
                                          &log_nodes,
                                          NULL);
  return GNUNET_YES;
}
 
 
static int
log_topo (const struct GNUNET_TESTING_NetjailTopology *topology)
{
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "plugin: %s spaces: %u nodes: %u known: %u\n",
       topology->plugin,
       topology->namespaces_n,
       topology->nodes_m,
       topology->nodes_x);
 
  GNUNET_CONTAINER_multishortmap_iterate (topology->map_namespaces,
                                          log_namespaces, NULL);
  GNUNET_CONTAINER_multishortmap_iterate (topology->map_globals, &log_nodes,
                                          NULL);
  return GNUNET_YES;
}
 
 
static void
get_node_info (unsigned int num,
               const struct GNUNET_TESTING_NetjailTopology *topology,
               struct GNUNET_TESTING_NetjailNode **node_ex,
               struct GNUNET_TESTING_NetjailNamespace **namespace_ex,
               struct GNUNET_TESTING_NodeConnection **node_connections_ex)
{
  struct GNUNET_ShortHashCode hkey;
  struct GNUNET_HashCode hc;
  unsigned int namespace_n;
  unsigned int node_m;
  struct GNUNET_TESTING_NetjailNode *node;
  struct GNUNET_TESTING_NetjailNamespace *namespace;
  struct GNUNET_TESTING_NodeConnection *node_connections = NULL;
 
  log_topo (topology);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "num: %u \n",
       num);
  if (topology->nodes_x >= num)
  {
 
    GNUNET_CRYPTO_hash (&num, sizeof(num), &hc);
    memcpy (&hkey,
            &hc,
            sizeof (hkey));
    node = GNUNET_CONTAINER_multishortmap_get (topology->map_globals,
                                               &hkey);
    if (NULL != node)
    {
      *node_ex = node;
      *node_connections_ex = node->node_connections_head;
    }
  }
  else
  {
    namespace_n = (unsigned int) ceil ((double) (num - topology->nodes_x)
                                       / topology->nodes_m);
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "ceil num: %u nodes_x: %u nodes_m: %u namespace_n: %u\n",
         num,
         topology->nodes_x,
         topology->nodes_m,
         namespace_n);
    GNUNET_CRYPTO_hash (&namespace_n, sizeof(namespace_n), &hc);
    memcpy (&hkey,
            &hc,
            sizeof (hkey));
    namespace = GNUNET_CONTAINER_multishortmap_get (topology->map_namespaces,
                                                    &hkey);
    if (NULL != namespace)
    {
      node_m = num - topology->nodes_x - topology->nodes_m * (namespace_n - 1);
      GNUNET_CRYPTO_hash (&node_m, sizeof(node_m), &hc);
      memcpy (&hkey,
              &hc,
              sizeof (hkey));
      node = GNUNET_CONTAINER_multishortmap_get (namespace->nodes,
                                                 &hkey);
      if (NULL != node)
      {
        LOG (GNUNET_ERROR_TYPE_DEBUG,
             "node additional_connects: %u %p\n",
             node->additional_connects,
             node);
        node_connections = node->node_connections_head;
      }
      *node_ex = node;
      *namespace_ex = namespace;
      *node_connections_ex = node_connections;
    }
  }
}
 
 
struct GNUNET_TESTING_NetjailNode *
GNUNET_TESTING_get_node (unsigned int num,
                         struct GNUNET_TESTING_NetjailTopology *topology)
{
  struct GNUNET_TESTING_NetjailNode *node;
  struct GNUNET_TESTING_NetjailNamespace *namespace;
  struct GNUNET_TESTING_NodeConnection *node_connections;
 
  get_node_info (num, topology, &node, &namespace, &node_connections);
 
  return node;
 
}
 
 
struct GNUNET_TESTING_NodeConnection *
GNUNET_TESTING_get_connections (unsigned int num,
                                const struct
                                GNUNET_TESTING_NetjailTopology *topology)
{
  struct GNUNET_TESTING_NetjailNode *node;
  struct GNUNET_TESTING_NetjailNamespace *namespace;
  struct GNUNET_TESTING_NodeConnection *node_connections;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "get_connections\n");
 
  get_node_info (num, topology, &node, &namespace, &node_connections);
 
  return node_connections;
}
 
 
int
free_nodes_cb (void *cls,
               const struct GNUNET_ShortHashCode *key,
               void *value)
{
  (void) cls;
  struct GNUNET_TESTING_NetjailNode *node = value;
  struct GNUNET_TESTING_NodeConnection *pos_connection;
  struct GNUNET_TESTING_AddressPrefix *pos_prefix;
 
  while (NULL != (pos_connection = node->node_connections_head))
  {
    while (NULL != (pos_prefix = pos_connection->address_prefixes_head))
    {
      GNUNET_CONTAINER_DLL_remove (pos_connection->address_prefixes_head,
                                   pos_connection->address_prefixes_tail,
                                   pos_prefix);
      GNUNET_free (pos_prefix->address_prefix);
      GNUNET_free (pos_prefix);
    }
    GNUNET_CONTAINER_DLL_remove (node->node_connections_head,
                                 node->node_connections_tail,
                                 pos_connection);
    GNUNET_free (pos_connection);
  }
 
  GNUNET_free (node->plugin);
  GNUNET_free (node);
  return GNUNET_OK;
}
 
 
int
free_namespaces_cb (void *cls,
                    const struct GNUNET_ShortHashCode *key,
                    void *value)
{
  (void) cls;
  struct GNUNET_TESTING_NetjailNamespace *namespace = value;
 
  GNUNET_free (namespace->router);
  GNUNET_CONTAINER_multishortmap_iterate (namespace->nodes, free_nodes_cb,
                                          namespace->nodes);
  return GNUNET_OK;
 
}
 
 
static int
free_value_cb (void *cls,
                    const struct GNUNET_ShortHashCode *key,
                    void *value)
{
  (void) cls;
 
  GNUNET_free (value);
 
  return GNUNET_OK;
}
 
 
static int
free_subnets_cb (void *cls,
                    const struct GNUNET_ShortHashCode *key,
                    void *value)
{
  (void) cls;
  struct GNUNET_TESTING_NetjailSubnet *subnet = value;
 
  GNUNET_CONTAINER_multishortmap_iterate (subnet->peers,
                                          &free_value_cb,
                                          NULL);
 
  GNUNET_free (subnet);
 
  return GNUNET_OK;
}
 
 
static int
free_carriers_cb (void *cls,
                    const struct GNUNET_ShortHashCode *key,
                    void *value)
{
  (void) cls;
  struct GNUNET_TESTING_NetjailCarrier *carrier = value;
 
  GNUNET_CONTAINER_multishortmap_iterate (carrier->peers,
                                          &free_value_cb,
                                          NULL);
  GNUNET_CONTAINER_multishortmap_iterate (carrier->subnets,
                                          &free_subnets_cb,
                                          NULL);
 
  GNUNET_free (carrier);
 
  return GNUNET_OK;
}
 
 
void
GNUNET_TESTING_free_topology (struct GNUNET_TESTING_NetjailTopology *topology)
{
  GNUNET_CONTAINER_multishortmap_iterate (topology->backbone_peers,
                                          &free_value_cb,
                                          NULL);
  GNUNET_CONTAINER_multishortmap_iterate (topology->carriers,
                                          &free_carriers_cb,
                                          NULL);
  GNUNET_free (topology->plugin);
  GNUNET_free (topology);
}
 
 
unsigned int
GNUNET_TESTING_calculate_num (
  struct GNUNET_TESTING_NodeConnection *node_connection,
  struct GNUNET_TESTING_NetjailTopology *topology)
{
  unsigned int n, m, num;
 
  n = node_connection->namespace_n;
  m = node_connection->node_n;
 
  if (0 == n)
    num = m;
  else
    num = (n - 1) * topology->nodes_m + m + topology->nodes_x;
 
  return num;
}
 
 
char *
GNUNET_TESTING_get_address (struct GNUNET_TESTING_NodeConnection *connection,
                            const char *prefix)
{
  struct GNUNET_TESTING_NetjailNode *node;
  char *addr;
  char *template;
  unsigned int node_n;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "get address prefix: %s node_n: %u\n",
       prefix,
       connection->node_n);
 
  node = connection->node;
  if (connection->namespace_n == node->namespace_n)
  {
    template = CONNECT_ADDRESS_TEMPLATE;
    node_n = connection->node_n;
  }
  else if (0 == connection->namespace_n)
  {
    template = KNOWN_CONNECT_ADDRESS_TEMPLATE;
    node_n = connection->node_n;
  }
  else if (1 == connection->node_n)
  {
    template = ROUTER_CONNECT_ADDRESS_TEMPLATE;
    node_n = connection->namespace_n;
  }
  else
  {
    return NULL;
  }
 
  if (0 == strcmp (PREFIX_TCP, prefix) ||
      0 == strcmp (PREFIX_UDP, prefix) ||
      0 == strcmp (PREFIX_UDP_NATTED, prefix) ||
      0 == strcmp (PREFIX_TCP_NATTED, prefix))
  {
    GNUNET_asprintf (&addr,
                     template,
                     prefix,
                     node_n);
  }
  else
  {
    GNUNET_assert (0);
  }
 
  return addr;
}
 
 
unsigned int
GNUNET_TESTING_get_additional_connects (unsigned int num,
                                        struct GNUNET_TESTING_NetjailTopology *
                                        topology)
{
  struct GNUNET_TESTING_NetjailNode *node;
  struct GNUNET_TESTING_NetjailNamespace *namespace;
  struct GNUNET_TESTING_NodeConnection *node_connections;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "get_additional_connects\n");
 
  get_node_info (num, topology, &node, &namespace, &node_connections);
 
  if (NULL == node)
  {
    LOG (GNUNET_ERROR_TYPE_WARNING,
         "No info found for node %d\n", num);
    return 0;
  }
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "node additional_connects for node %p\n",
       node);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "node additional_connects: %u\n",
       node->additional_connects);
 
  return node->additional_connects;
}
 
char *
GNUNET_TESTING_get_plugin_from_topo (
  struct GNUNET_TESTING_NetjailTopology *njt,
  const char *my_node_id)
{
  return njt->plugin;
}
 
 
static void
create_subnet_peers (struct GNUNET_CONFIGURATION_Handle *cfg,
               struct GNUNET_TESTING_NetjailTopology *topology,
               struct GNUNET_TESTING_NetjailSubnet *subnet)
{
  struct GNUNET_HashCode hc;
  subnet->peers = GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
 
  for (int i = 1; i < subnet->number_peers; i++)
  {
    struct GNUNET_ShortHashCode hkey;
    struct GNUNET_TESTING_NetjailSubnetPeer *subnet_peer = GNUNET_new (struct GNUNET_TESTING_NetjailSubnetPeer);
 
    topology->total++;
    GNUNET_CRYPTO_hash (&topology->total, sizeof(topology->total), &hc);
      memcpy (&hkey,
              &hc,
              sizeof (hkey));
    GNUNET_CONTAINER_multishortmap_put (subnet->peers,
                                        &hkey,
                                        subnet_peer,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
  }
}
 
 
static void
create_subnets (struct GNUNET_CONFIGURATION_Handle *cfg,
               struct GNUNET_TESTING_NetjailTopology *topology,
               struct GNUNET_TESTING_NetjailCarrier *carrier)
{
  struct GNUNET_HashCode hc;
  carrier->subnets = GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
  
  for (int i = 1; i < carrier->number_subnets; i++)
  {
    struct GNUNET_ShortHashCode hkey;
    struct GNUNET_TESTING_NetjailSubnet *subnet = GNUNET_new (struct GNUNET_TESTING_NetjailSubnet);
    char *section;
 
    topology->total++;
    subnet->number = topology->total;
    subnet->index = i;
    GNUNET_CRYPTO_hash (&topology->total, sizeof(topology->total), &hc);
      memcpy (&hkey,
              &hc,
              sizeof (hkey));
    GNUNET_CONTAINER_multishortmap_put (carrier->subnets,
                                        &hkey,
                                        subnet,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
    GNUNET_asprintf (&section, "CARRIER-%u-SUBNET-%u", carrier->index, i);
    if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
                                                          section,
                                                          "SUBNET_PEERS",
                                                          (unsigned long long *) &subnet->number_peers))
    {
      subnet->number_peers = topology->default_subnet_peers;
    }
 
    create_subnet_peers (cfg, topology, subnet);
 
    GNUNET_free (section);
  }
}
 
 
static void
create_peers (struct GNUNET_CONFIGURATION_Handle *cfg,
               struct GNUNET_TESTING_NetjailTopology *topology,
               struct GNUNET_TESTING_NetjailCarrier *carrier)
{
  struct GNUNET_HashCode hc;
  carrier->peers = GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
 
  for (int i = 1; i < carrier->number_peers; i++)
  {
    struct GNUNET_ShortHashCode hkey;
    struct GNUNET_TESTING_NetjailCarrierPeer *peer = GNUNET_new (struct GNUNET_TESTING_NetjailCarrierPeer);
 
    topology->total++;
    peer->number = topology->total;
    GNUNET_CRYPTO_hash (&topology->total, sizeof(topology->total), &hc);
      memcpy (&hkey,
              &hc,
              sizeof (hkey));
    GNUNET_CONTAINER_multishortmap_put (carrier->peers,
                                        &hkey,
                                        peer,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
    //GNUNET_asprintf (&section, "CARRIER-%u-PEER-%u", carrier->index, i);
  }
}
 
 
struct GNUNET_TESTING_NetjailTopology *
GNUNET_TESTING_get_topo_from_string_ (const char *input)
{
  struct GNUNET_CONFIGURATION_Handle *cfg;
  struct GNUNET_TESTING_NetjailTopology *topology = GNUNET_new (struct GNUNET_TESTING_NetjailTopology);
  topology->backbone_peers = GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
  topology->carriers = GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
  struct GNUNET_HashCode hc;
 
  cfg = GNUNET_CONFIGURATION_create ();
  GNUNET_assert (NULL != topology->carriers);
 
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_deserialize (cfg,
                                        input,
                                        strlen (input),
                                        NULL))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                _ ("Failed to parse configuration.\n"));
    GNUNET_CONFIGURATION_destroy (cfg);
    return NULL;
  }
  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
                                                          "DEFAULTS",
                                                          "SUBNETS",
                                                          &(topology->default_subnets)))
  {
    LOG (GNUNET_ERROR_TYPE_ERROR,
         "Missing default SUBNETS!\n");
    return NULL;
  }
  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_string (cfg,
                                                          "DEFAULTS",
                                                          "TESTBED_PLUGIN",
                                                          &topology->plugin))
  {
    LOG (GNUNET_ERROR_TYPE_ERROR,
         "Missing default TESTBED_PLUGIN!\n");
    return NULL;
  }
  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
                                                          "DEFAULTS",
                                                          "CARRIER_PEERS",
                                                          &(topology->default_carrier_peers)))
  {
    LOG (GNUNET_ERROR_TYPE_ERROR,
         "Missing default CARRIER_PEERS!\n");
    return NULL;
  }
  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
                                                          "DEFAULTS",
                                                          "SUBNET_PEERS",
                                                          &(topology->default_subnet_peers)))
  {
    LOG (GNUNET_ERROR_TYPE_ERROR,
         "Missing default SUBNET_PEERS!\n");
    return NULL;
  }
  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
                                                          "BACKBONE",
                                                          "CARRIERS",
                                                          &(topology->num_carriers)))
  {
    LOG (GNUNET_ERROR_TYPE_INFO,
         "No carrier configured!\n");
    return NULL;
  }
  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
                                                          "BACKBONE",
                                                          "BACKBONE_PEERS",
                                                          &(topology->num_backbone_peers)))
  {
    LOG (GNUNET_ERROR_TYPE_INFO,
         "No backbone peers configured!\n");
    return NULL;
  }
  for (int i = 0;i < topology->num_backbone_peers; i++)
  {
    struct GNUNET_TESTING_NetjailBackbonePeer *peer = GNUNET_new (struct GNUNET_TESTING_NetjailBackbonePeer);
    struct GNUNET_ShortHashCode hkey;
 
    topology->total++;
    peer->number = topology->total;
    GNUNET_CRYPTO_hash (&topology->total, sizeof(topology->total), &hc);
      memcpy (&hkey,
              &hc,
              sizeof (hkey));
    GNUNET_CONTAINER_multishortmap_put (topology->backbone_peers,
                                        &hkey,
                                        peer,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
  }
  GNUNET_assert (NULL != topology->carriers);
  for (int i = 0;i < topology->num_carriers; i++)
  {
    struct GNUNET_TESTING_NetjailCarrier *carrier = GNUNET_new (struct GNUNET_TESTING_NetjailCarrier);
    struct GNUNET_ShortHashCode hkey;
    char *section;
 
    topology->total++;
    carrier->number = topology->total;
    GNUNET_CRYPTO_hash (&topology->total, sizeof(topology->total), &hc);
    memcpy (&hkey,
              &hc,
              sizeof (hkey));
    GNUNET_assert (NULL != topology->carriers);
    GNUNET_CONTAINER_multishortmap_put (topology->carriers,
                                        &hkey,
                                        carrier,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
    GNUNET_asprintf (&section, "CARRIER-%u", i); 
    if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
                                                          section,
                                                          "SUBNETS",
                                                          (unsigned long long *) &carrier->number_subnets))
    {
      carrier->number_subnets = topology->default_subnets;
    }
    if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
                                                          section,
                                                          "CARRIER_PEERS",
                                                          (unsigned long long *) &carrier->number_peers))
    {
      carrier->number_peers = topology->default_carrier_peers;
    }
    create_peers  (cfg, topology, carrier);
    create_subnets (cfg, topology, carrier);
 
    GNUNET_free (section);
  }
 
  GNUNET_free (cfg);
  
  return topology;
}
 
 
GNUNET_TESTING_SIMPLE_NETJAIL_TRAITS (
  GNUNET_TESTING_MAKE_IMPL_SIMPLE_TRAIT,
  GNUNET_TESTING)
 
 
/* end of netjail.c */