gnunet_testing_netjail_lib.h File Reference

#include "gnunet_testing_ng_lib.h"
#include "gnunet_testing_plugin.h"

Include dependency graph for gnunet_testing_netjail_lib.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	GNUNET_TESTING_NetjailRouter
	API for writing an interpreter to test GNUnet components. More...
struct	GNUNET_TESTING_AddressPrefix
	Protocol address prefix für a connection between nodes. More...
struct	GNUNET_TESTING_NodeConnection
	Connection to another node. More...
struct	GNUNET_TESTING_NetjailNode
	Node in the netjail topology. More...
struct	GNUNET_TESTING_NetjailNamespace
	Subnet in a topology. More...
struct	GNUNET_TESTING_NetjailTopology
	Toplogy of our netjail setup. More...
struct	GNUNET_TESTING_BlockState
	Struct with information for callbacks. More...
struct	GNUNET_TESTING_LocalPreparedState
	Struct to hold information for callbacks. More...

Macros
#define	GNUNET_TESTING_SIMPLE_NETJAIL_TRAITS(op, prefix)
	Call op on all simple traits. More...

Enumerations
enum	GNUNET_TESTING_NodeType { GNUNET_TESTING_SUBNET_NODE , GNUNET_TESTING_GLOBAL_NODE }
	Enum for the different types of nodes. More...

Functions
struct GNUNET_TESTING_NetjailTopology *	GNUNET_TESTING_get_topo_from_file (const char *filename)
	Getting the topology from file. More...
struct GNUNET_TESTING_NetjailTopology *	GNUNET_TESTING_get_topo_from_string (const char *data)
	FIXME: this could use a "to_string". More...
unsigned int	GNUNET_TESTING_get_additional_connects (unsigned int num, struct GNUNET_TESTING_NetjailTopology *topology)
	Get the number of unintentional additional connections the node waits for. More...
struct GNUNET_TESTING_NetjailNode *	GNUNET_TESTING_get_node (unsigned int num, struct GNUNET_TESTING_NetjailTopology *topology)
	Get a node from the topology. More...
struct GNUNET_TESTING_NodeConnection *	GNUNET_TESTING_get_connections (unsigned int num, const struct GNUNET_TESTING_NetjailTopology *topology)
	Get the connections to other nodes for a specific node. More...
char *	GNUNET_TESTING_get_address (struct GNUNET_TESTING_NodeConnection *connection, const char *prefix)
	Get the address for a specific communicator from a connection. More...
void	GNUNET_TESTING_free_topology (struct GNUNET_TESTING_NetjailTopology *topology)
	Deallocate memory of the struct GNUNET_TESTING_NetjailTopology. More...
unsigned int	GNUNET_TESTING_calculate_num (struct GNUNET_TESTING_NodeConnection *node_connection, struct GNUNET_TESTING_NetjailTopology *topology)
	Calculate the unique id identifying a node from a given connection. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_system_destroy (const char *label, const char *create_label)
	This command destroys the ressources allocated for the test system setup. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_system_create (const char *label, const char *testdir)
	This command is setting up a test environment for a peer to start. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_netjail_start (const char *label, char *topology_config, unsigned int *read_file)
	This command executes a shell script to setup the netjail environment. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_netjail_stop (const char *label, char *topology_config, unsigned int *read_file)
	This command executes a shell script to remove the netjail environment. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_netjail_start_cmds_helper (const char *label, struct GNUNET_TESTING_NetjailTopology *topology, unsigned int *read_file, char *topology_data, struct GNUNET_TIME_Relative timeout)
	This command executes a shell script which starts a helper process. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_stop_cmds_helper (const char *label, const char *helper_start_label, struct GNUNET_TESTING_NetjailTopology *topology)
	Create command. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_block_until_external_trigger (const char *label)
	This command is used to block the loop, until the command is finished by other commands, using a trait to get this commands struct GNUNET_TESTING_AsyncContext. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_send_peer_ready (const char *label, GNUNET_TESTING_cmd_helper_write_cb write_message)
	DEPRECATED This command sends a GNUNET_MESSAGE_TYPE_CMDS_HELPER_PEER_STARTED message to the master loop. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_local_test_prepared (const char *label, GNUNET_TESTING_cmd_helper_write_cb write_message)
	This command sends a GNUNET_MESSAGE_TYPE_CMDS_HELPER_LOCAL_TESTS_PREPARED message to the master loop. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_cmd_start_peer (const char *label, const char *system_label, uint32_t no, const char *node_ip, const char *cfgname, unsigned int broadcast)
	Create command. More...
enum GNUNET_GenericReturnValue	GNUNET_TESTING_get_trait_test_system (const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_TESTING_System **ret)
struct GNUNET_TESTING_Trait	GNUNET_TESTING_make_trait_test_system (const struct GNUNET_TESTING_System *value)
enum GNUNET_GenericReturnValue	GNUNET_TESTING_get_trait_async_context (const struct GNUNET_TESTING_Command *cmd, struct GNUNET_TESTING_AsyncContext **ret)
struct GNUNET_TESTING_Trait	GNUNET_TESTING_make_trait_async_context (struct GNUNET_TESTING_AsyncContext *value)
enum GNUNET_GenericReturnValue	GNUNET_TESTING_get_trait_helper_handles (const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_HELPER_Handle ***ret)
struct GNUNET_TESTING_Trait	GNUNET_TESTING_make_trait_helper_handles (const struct GNUNET_HELPER_Handle **value)
enum GNUNET_GenericReturnValue	GNUNET_TESTING_get_trait_local_prepared_state (const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_TESTING_LocalPreparedState **ret)
struct GNUNET_TESTING_Trait	GNUNET_TESTING_make_trait_local_prepared_state (const struct GNUNET_TESTING_LocalPreparedState *value)
enum GNUNET_GenericReturnValue	GNUNET_TESTING_get_trait_block_state (const struct GNUNET_TESTING_Command *cmd, struct GNUNET_TESTING_BlockState **ret)
struct GNUNET_TESTING_Trait	GNUNET_TESTING_make_trait_block_state (struct GNUNET_TESTING_BlockState *value)

Macro Definition Documentation

GNUNET_TESTING_SIMPLE_NETJAIL_TRAITS

#define GNUNET_TESTING_SIMPLE_NETJAIL_TRAITS	(		op,
			prefix
	)

Value:

  op (prefix, test_system, const struct GNUNET_TESTING_System)                      \
  op (prefix, async_context, struct GNUNET_TESTING_AsyncContext)                    \
  op (prefix, helper_handles, const struct GNUNET_HELPER_Handle *)                  \
  op (prefix, local_prepared_state, const struct GNUNET_TESTING_LocalPreparedState) \
  op (prefix, block_state, struct GNUNET_TESTING_BlockState)

Call op on all simple traits.

Definition at line 536 of file gnunet_testing_netjail_lib.h.

Enumeration Type Documentation

GNUNET_TESTING_NodeType

enum GNUNET_TESTING_NodeType

Enum for the different types of nodes.

Enumerator
GNUNET_TESTING_SUBNET_NODE	Node in a subnet.
GNUNET_TESTING_GLOBAL_NODE	Global known node.

Definition at line 54 of file gnunet_testing_netjail_lib.h.

{
  GNUNET_TESTING_SUBNET_NODE,
 
  GNUNET_TESTING_GLOBAL_NODE
};

Function Documentation

GNUNET_TESTING_get_topo_from_file()

struct GNUNET_TESTING_NetjailTopology * GNUNET_TESTING_get_topo_from_file

(

const char *

filename

)

Getting the topology from file.

Parameters

filename

The name of the topology file.

Returns

The GNUNET_TESTING_NetjailTopology

Definition at line 2786 of file testing.c.

{
  uint64_t fs;
  char *data;
  struct GNUNET_TESTING_NetjailTopology *topo;
 
  if (GNUNET_YES != GNUNET_DISK_file_test (filename))
  {
    LOG (GNUNET_ERROR_TYPE_ERROR,
         _ ("Topology file %s not found\n"),
         filename);
    return NULL;
  }
  if (GNUNET_OK !=
      GNUNET_DISK_file_size (filename, &fs, GNUNET_YES, GNUNET_YES))
  {
    LOG (GNUNET_ERROR_TYPE_ERROR,
         _ ("Topology file %s has no data\n"),
         filename);
    return NULL;
  }
  data = GNUNET_malloc (fs + 1);
  if (fs != GNUNET_DISK_fn_read (filename, data, fs))
  {
    LOG (GNUNET_ERROR_TYPE_ERROR,
         _ ("Topology file %s cannot be read\n"),
         filename);
    GNUNET_free (data);
    return NULL;
  }
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "file length %" PRIu64 "\n",
       fs);
  data[fs] = '\0';
 
  topo = GNUNET_TESTING_get_topo_from_string (data);
 
  GNUNET_free (data);
 
  return topo;
}

References _, data, filename, fs, GNUNET_DISK_file_size(), GNUNET_DISK_file_test(), GNUNET_DISK_fn_read(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_malloc, GNUNET_OK, GNUNET_TESTING_get_topo_from_string(), GNUNET_YES, and LOG.

Here is the call graph for this function:

GNUNET_TESTING_get_topo_from_string()

struct GNUNET_TESTING_NetjailTopology * GNUNET_TESTING_get_topo_from_string

(

const char *

input

)

FIXME: this could use a "to_string".

Parse the topology data.

Parameters

data	The topology data.

Returns

The GNUNET_TESTING_NetjailTopology

FIXME: this could use a "to_string".

Parameters

data	The topology data.

Returns

The GNUNET_TESTING_NetjailTopology

Definition at line 2515 of file testing.c.

{
  char *token;
  char *key = NULL;
  unsigned int out;
  char *rest = NULL;
  char *value = NULL;
  char *value2;
  char *data;
  int ret;
  struct GNUNET_TESTING_NetjailTopology *topo;
  struct GNUNET_TESTING_NetjailRouter *router;
  struct GNUNET_TESTING_NetjailNamespace *namespace;
  struct GNUNET_HashCode hc;
 
  data = GNUNET_strdup (input);
  token = strtok_r (data, "\n", &rest);
  topo = GNUNET_new (struct GNUNET_TESTING_NetjailTopology);
  topo->map_namespaces =
    GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
  topo->map_globals =
    GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
 
  while (NULL != token)
  {
    if (NULL != key)
      GNUNET_free (key);
    key = get_key (token);
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "In the loop with token: %s beginning with %s\n",
         token,
         key);
    if (0 == strcmp (key, "M"))
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get first Value for M.\n");
      out = get_first_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "M: %u\n",
           out);
      topo->nodes_m = out;
    }
    else if (0 == strcmp (key, "N"))
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get first Value for N.\n");
      out = get_first_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "N: %u\n",
           out);
      topo->namespaces_n = out;
    }
    else if (0 == strcmp (key, "X"))
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get first Value for X.\n");
      out = get_first_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "X: %u\n",
           out);
      topo->nodes_x = out;
    }
    else if (0 == strcmp (key, "AC"))
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get first Value for AC.\n");
      out = get_first_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "AC: %u\n",
           out);
      topo->additional_connects = out;
    }
    else if (0 == strcmp (key, "T"))
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get first string value for T.\n");
      value = get_first_string_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "value: %s\n",
           value);
      topo->plugin = value;
    }
    else if (0 == strcmp (key, "K"))
    {
      struct GNUNET_ShortHashCode hkey_k;
      struct GNUNET_TESTING_NetjailNode *k_node = GNUNET_new (struct
                                                              GNUNET_TESTING_NetjailNode);
 
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get first Value for K.\n");
      out = get_first_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "K: %u\n",
           out);
      k_node->node_n = out;
      GNUNET_CRYPTO_hash (&out, sizeof(out), &hc);
      memcpy (&hkey_k,
              &hc,
              sizeof (hkey_k));
      k_node->is_global = GNUNET_YES;
 
      if (GNUNET_YES == GNUNET_CONTAINER_multishortmap_contains (
            topo->map_globals,
            &hkey_k))
        GNUNET_break (0);
      else
        GNUNET_CONTAINER_multishortmap_put (topo->map_globals,
                                            &hkey_k,
                                            k_node,
                                            GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get value for key value on K.\n");
      value = get_value ("plugin", token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "value: %s\n",
           value);
      k_node->plugin = value;
      parse_ac (k_node, token);
      node_connections (token, k_node);
      GNUNET_free (value);
    }
    else if (0 == strcmp (key, "R"))
    {
      struct GNUNET_ShortHashCode hkey_r;
      router = GNUNET_new (struct GNUNET_TESTING_NetjailRouter);
 
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get first Value for R.\n");
      out = get_first_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "R: %u\n",
           out);
      GNUNET_CRYPTO_hash (&out, sizeof(out), &hc);
      memcpy (&hkey_r,
              &hc,
              sizeof (hkey_r));
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get value for key tcp_port on R.\n");
      value = get_value ("tcp_port", token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "tcp_port: %s\n",
           value);
      ret = sscanf (value, "%u", &(router->tcp_port));
      GNUNET_free (value);
      GNUNET_break (0 != ret && 1 >= router->tcp_port);
 
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get value for key udp_port on R.\n");
      value2 = get_value ("udp_port", token);
      ret = sscanf (value2, "%u", &(router->udp_port));
      GNUNET_free (value2);
      GNUNET_break (0 != ret && 1 >= router->udp_port);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "udp_port: %s\n",
           value2);
      GNUNET_free (value2);
      if (GNUNET_YES == GNUNET_CONTAINER_multishortmap_contains (
            topo->map_namespaces,
            &hkey_r))
      {
        namespace = GNUNET_CONTAINER_multishortmap_get (topo->map_namespaces,
                                                        &hkey_r);
      }
      else
      {
        namespace = GNUNET_new (struct GNUNET_TESTING_NetjailNamespace);
        namespace->namespace_n = out;
        namespace->nodes = GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
        GNUNET_CONTAINER_multishortmap_put (topo->map_namespaces,
                                            &hkey_r,
                                            namespace,
                                            GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
      }
      namespace->router = router;
 
    }
    else if (0 == strcmp (key, "P"))
    {
      struct GNUNET_TESTING_NetjailNode *p_node = GNUNET_new (struct
                                                              GNUNET_TESTING_NetjailNode);
      struct GNUNET_ShortHashCode hkey_p;
 
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get first Value for P.\n");
      out = get_first_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "P: %u\n",
           out);
      GNUNET_CRYPTO_hash (&out, sizeof(out), &hc);
      memcpy (&hkey_p,
              &hc,
              sizeof (hkey_p));
 
      if (GNUNET_YES == GNUNET_CONTAINER_multishortmap_contains (
            topo->map_namespaces,
            &hkey_p))
      {
        namespace = GNUNET_CONTAINER_multishortmap_get (topo->map_namespaces,
                                                        &hkey_p);
      }
      else
      {
        namespace = GNUNET_new (struct GNUNET_TESTING_NetjailNamespace);
        namespace->nodes = GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
        namespace->namespace_n = out;
        GNUNET_CONTAINER_multishortmap_put (topo->map_namespaces,
                                            &hkey_p,
                                            namespace,
                                            GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
      }
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get second Value for P.\n");
      out = get_second_value (token);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "P: %u\n",
           out);
      GNUNET_CRYPTO_hash (&out, sizeof(out), &hc);
      memcpy (&hkey_p,
              &hc,
              sizeof (hkey_p));
      if (GNUNET_YES == GNUNET_CONTAINER_multishortmap_contains (
            namespace->nodes,
            &hkey_p))
      {
        GNUNET_break (0);
      }
      else
      {
 
        GNUNET_CONTAINER_multishortmap_put (namespace->nodes,
                                            &hkey_p,
                                            p_node,
                                            GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
        LOG (GNUNET_ERROR_TYPE_DEBUG,
             "Get value for key plugin on P.\n");
        value = get_value ("plugin", token);
        if (NULL != value)
        {
          LOG (GNUNET_ERROR_TYPE_DEBUG,
               "plugin: %s\n",
               value);
          p_node->plugin = value;
        }
        p_node->node_n = out;
        p_node->namespace_n = namespace->namespace_n;
      }
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Get AC Value for P.\n");
      parse_ac (p_node, token);
      node_connections (token, p_node);
    }
    token = strtok_r (NULL, "\n", &rest);
    if (NULL != token)
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Next token %s\n",
           token);
  }
  if (NULL != key)
    GNUNET_free (key);
  GNUNET_free (data);
  return topo;
}

References GNUNET_TESTING_NetjailTopology::additional_connects, data, get_first_string_value(), get_first_value(), get_key(), get_second_value(), get_value(), GNUNET_break, GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_CONTAINER_multishortmap_contains(), GNUNET_CONTAINER_multishortmap_create(), GNUNET_CONTAINER_multishortmap_get(), GNUNET_CONTAINER_multishortmap_put(), GNUNET_CRYPTO_hash(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_new, GNUNET_NO, GNUNET_strdup, GNUNET_YES, GNUNET_TESTING_NetjailNode::is_global, key, LOG, GNUNET_TESTING_NetjailTopology::map_globals, GNUNET_TESTING_NetjailTopology::map_namespaces, GNUNET_TESTING_NetjailNode::namespace_n, GNUNET_TESTING_NetjailTopology::namespaces_n, node_connections(), GNUNET_TESTING_NetjailNode::node_n, GNUNET_TESTING_NetjailTopology::nodes_m, GNUNET_TESTING_NetjailTopology::nodes_x, parse_ac(), GNUNET_TESTING_NetjailNode::plugin, GNUNET_TESTING_NetjailTopology::plugin, ret, GNUNET_TESTING_NetjailRouter::tcp_port, GNUNET_TESTING_NetjailRouter::udp_port, and value.

Referenced by GNUNET_TESTING_get_topo_from_file().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_get_additional_connects()

unsigned int GNUNET_TESTING_get_additional_connects	(	unsigned int	num,
		struct GNUNET_TESTING_NetjailTopology *	topology
	)

Get the number of unintentional additional connections the node waits for.

Parameters

num	The specific node we want the additional connects for.

Returns

The number of additional connects

Definition at line 2447 of file testing.c.

{
  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;
}

References GNUNET_TESTING_NetjailNode::additional_connects, get_node_info(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, LOG, and node_connections().

Referenced by GNUNET_CORE_cmd_connect_peers(), and GNUNET_TRANSPORT_cmd_connect_peers().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_get_node()

struct GNUNET_TESTING_NetjailNode * GNUNET_TESTING_get_node	(	unsigned int	num,
		struct GNUNET_TESTING_NetjailTopology *	topology
	)

Get a node from the topology.

Parameters

num	The specific node we want the connections for.
topology	The topology we get the connections from.

Returns

The connections of the node.

Definition at line 2229 of file testing.c.

{
  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;
 
}

References get_node_info(), GNUNET_TESTING_NodeConnection::node, and node_connections().

Here is the call graph for this function:

GNUNET_TESTING_get_connections()

struct GNUNET_TESTING_NodeConnection * GNUNET_TESTING_get_connections	(	unsigned int	num,
		const struct GNUNET_TESTING_NetjailTopology *	topology
	)

Get the connections to other nodes for a specific node.

Parameters

num	The specific node we want the connections for.
topology	The topology we get the connections from.

Returns

The connections of the node.

Definition at line 2251 of file testing.c.

{
  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;
}

References get_node_info(), GNUNET_ERROR_TYPE_DEBUG, LOG, GNUNET_TESTING_NodeConnection::node, and node_connections().

Referenced by backchannel_check_run(), and connect_peers_run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_get_address()

char * GNUNET_TESTING_get_address	(	struct GNUNET_TESTING_NodeConnection *	connection,
		const char *	prefix
	)

Get the address for a specific communicator from a connection.

Parameters

connection	The connection we like to have the address from.
prefix	The communicator protocol prefix.

Returns

The address of the communicator.

Definition at line 2387 of file testing.c.

{
  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;
}

References CONNECT_ADDRESS_TEMPLATE, GNUNET_asprintf(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, KNOWN_CONNECT_ADDRESS_TEMPLATE, LOG, GNUNET_TESTING_NodeConnection::namespace_n, GNUNET_TESTING_NetjailNode::namespace_n, GNUNET_TESTING_NodeConnection::node, GNUNET_TESTING_NodeConnection::node_n, GNUNET_TESTING_NetjailNode::node_n, prefix, PREFIX_TCP, PREFIX_TCP_NATTED, PREFIX_UDP, PREFIX_UDP_NATTED, and ROUTER_CONNECT_ADDRESS_TEMPLATE.

Referenced by connect_peers_run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_free_topology()

void GNUNET_TESTING_free_topology

(

struct GNUNET_TESTING_NetjailTopology *

topology

)

Deallocate memory of the struct GNUNET_TESTING_NetjailTopology.

Parameters

topology

The GNUNET_TESTING_NetjailTopology to be deallocated.

Definition at line 2347 of file testing.c.

{
  GNUNET_CONTAINER_multishortmap_iterate (topology->map_namespaces,
                                          free_namespaces_cb, NULL);
  GNUNET_CONTAINER_multishortmap_destroy (topology->map_namespaces);
  GNUNET_CONTAINER_multishortmap_iterate (topology->map_globals, free_nodes_cb,
                                          NULL);
  GNUNET_CONTAINER_multishortmap_destroy (topology->map_globals);
  GNUNET_free (topology->plugin);
  GNUNET_free (topology);
}

References free_namespaces_cb(), free_nodes_cb(), GNUNET_CONTAINER_multishortmap_destroy(), GNUNET_CONTAINER_multishortmap_iterate(), GNUNET_free, GNUNET_TESTING_NetjailTopology::map_globals, GNUNET_TESTING_NetjailTopology::map_namespaces, and GNUNET_TESTING_NetjailTopology::plugin.

Here is the call graph for this function:

GNUNET_TESTING_calculate_num()

unsigned int GNUNET_TESTING_calculate_num	(	struct GNUNET_TESTING_NodeConnection *	node_connection,
		struct GNUNET_TESTING_NetjailTopology *	topology
	)

Calculate the unique id identifying a node from a given connection.

Parameters

node_connection	The connection we calculate the id from.
topology	The topology we get all needed information from.

Returns

The unique id of the node from the connection.

Definition at line 2361 of file testing.c.

{
  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;
}

References m, GNUNET_TESTING_NodeConnection::namespace_n, GNUNET_TESTING_NodeConnection::node_n, GNUNET_TESTING_NetjailTopology::nodes_m, and GNUNET_TESTING_NetjailTopology::nodes_x.

Referenced by connect_peers_run(), and notify_connect().

Here is the caller graph for this function:

GNUNET_TESTING_cmd_system_destroy()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_system_destroy	(	const char *	label,
		const char *	create_label
	)

This command destroys the ressources allocated for the test system setup.

Parameters

label	Name for command.
create_label	Label of the cmd which started the test system.
write_message	Callback to write messages to the master loop.

Returns

command.

This command destroys the ressources allocated for the test system setup.

Parameters

label	name for command.
create_label	Label of the cmd which started the test system.

Returns

command.

Definition at line 101 of file testing_api_cmd_system_destroy.c.

{
  struct TestSystemState *tss;
 
  tss = GNUNET_new (struct TestSystemState);
  tss->create_label = create_label;
  return GNUNET_TESTING_command_new (tss, label, &system_destroy_run,
                                     &system_destroy_cleanup,
                                     &system_destroy_traits, NULL);
}

References TestSystemState::create_label, GNUNET_new, GNUNET_TESTING_command_new(), system_destroy_cleanup(), system_destroy_run(), and system_destroy_traits().

Here is the call graph for this function:

GNUNET_TESTING_cmd_system_create()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_system_create	(	const char *	label,
		const char *	testdir
	)

This command is setting up a test environment for a peer to start.

Parameters

label	Name for command.
testdir	Only the directory name without any path. Temporary directory used for all service homes.

This command is setting up a test environment for a peer to start.

Parameters

label	name for command.
label	name for the test environment directory.

Returns

command.

Definition at line 113 of file testing_api_cmd_system_create.c.

{
  struct TestSystemState *tss;
 
  tss = GNUNET_new (struct TestSystemState);
  tss->testdir = testdir;
 
  return GNUNET_TESTING_command_new (tss, label, &system_create_run,
                                     &system_create_cleanup,
                                     &system_create_traits, NULL);
}

References GNUNET_new, GNUNET_TESTING_command_new(), system_create_cleanup(), system_create_run(), system_create_traits(), and TestSystemState::testdir.

Here is the call graph for this function:

GNUNET_TESTING_cmd_netjail_start()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_netjail_start	(	const char *	label,
		char *	topology_config,
		unsigned int *	read_file
	)

This command executes a shell script to setup the netjail environment.

Parameters

label	name for command.
topology_config	Configuration file for the test topology.
read_file	Flag indicating if the the name of the topology file is send to the helper, or a string with the topology data.

Returns

command.

This command executes a shell script to setup the netjail environment.

Parameters

label	name for command.
topology_config	Configuration file for the test topology.

Returns

command.

Definition at line 218 of file testing_api_cmd_netjail_start.c.

{
  struct NetJailState *ns;
 
  ns = GNUNET_new (struct NetJailState);
  ns->topology_config = topology_config;
  ns->read_file = read_file;
  return GNUNET_TESTING_command_new (ns, label,
                                     &netjail_start_run,
                                     &netjail_start_cleanup,
                                     NULL, &ns->ac);
}

References GNUNET_new, GNUNET_TESTING_command_new(), netjail_start_cleanup(), netjail_start_run(), ns, read_file(), and NetJailState::topology_config.

Here is the call graph for this function:

GNUNET_TESTING_cmd_netjail_stop()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_netjail_stop	(	const char *	label,
		char *	topology_config,
		unsigned int *	read_file
	)

This command executes a shell script to remove the netjail environment.

Parameters

label	name for command.
topology_config	Configuration file for the test topology.
read_file	Flag indicating if the the name of the topology file is send to the helper, or a string with the topology data.

Returns

command.

Definition at line 187 of file testing_api_cmd_netjail_stop.c.

{
  struct NetJailState *ns;
 
  ns = GNUNET_new (struct NetJailState);
  ns->topology_config = topology_config;
  ns->read_file = read_file;
  return GNUNET_TESTING_command_new (ns, label,
                                     &netjail_stop_run,
                                     &netjail_stop_cleanup,
                                     NULL, &ns->ac);
}

References GNUNET_new, GNUNET_TESTING_command_new(), netjail_stop_cleanup(), netjail_stop_run(), ns, read_file(), and NetJailState::topology_config.

Here is the call graph for this function:

GNUNET_TESTING_cmd_netjail_start_cmds_helper()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_netjail_start_cmds_helper	(	const char *	label,
		struct GNUNET_TESTING_NetjailTopology *	topology,
		unsigned int *	read_file,
		char *	topology_data,
		struct GNUNET_TIME_Relative	timeout
	)

This command executes a shell script which starts a helper process.

This process is running on a netjail node, executing a defined test case.

Parameters

label	Name for the command.
topology	The complete topology information.
read_file	Flag indicating if the the name of the topology file is send to the helper, or a string with the topology data.
topology_data	If read_file is GNUNET_NO, topology_data holds the string with the topology.
timeout	Before this timeout is reached this cmd MUST finish.

Returns

command.

This command executes a shell script which starts a helper process.

Parameters

label	Name for the command.
topology	The complete topology information.
read_file	Flag indicating if the the name of the topology file is send to the helper, or a string with the topology data.
topology_data	If read_file is GNUNET_NO, topology_data holds the string with the topology.
timeout	Before this timeout is reached this cmd MUST finish.

Returns

command.

Definition at line 893 of file testing_api_cmd_netjail_start_cmds_helper.c.

{
  struct NetJailState *ns;
 
  ns = GNUNET_new (struct NetJailState);
  ns->local_m = topology->nodes_m;
  ns->global_n = topology->namespaces_n;
  ns->known = topology->nodes_x;
  ns->plugin_name = topology->plugin;
  ns->topology = topology;
  ns->read_file = read_file;
  ns->topology_data = topology_data;
  ns->timeout = GNUNET_TIME_relative_subtract (timeout, TIMEOUT);
 
  return GNUNET_TESTING_command_new (ns, label,
                                     &netjail_exec_run,
                                     &netjail_exec_cleanup,
                                     &netjail_exec_traits,
                                     &ns->ac);
}

References GNUNET_new, GNUNET_TESTING_command_new(), GNUNET_TIME_relative_subtract(), GNUNET_TESTING_NetjailTopology::namespaces_n, netjail_exec_cleanup(), netjail_exec_run(), netjail_exec_traits(), GNUNET_TESTING_NetjailTopology::nodes_m, GNUNET_TESTING_NetjailTopology::nodes_x, ns, GNUNET_TESTING_NetjailTopology::plugin, read_file(), timeout, TIMEOUT, NetJailState::topology, and NetJailState::topology_data.

Here is the call graph for this function:

GNUNET_TESTING_cmd_stop_cmds_helper()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_stop_cmds_helper	(	const char *	label,
		const char *	helper_start_label,
		struct GNUNET_TESTING_NetjailTopology *	topology
	)

Create command.

Parameters

label	name for command.
helper_start_label	label of the cmd to start the test system.
topology	The complete topology information.

Returns

command.

Definition at line 139 of file testing_api_cmd_netjail_stop_cmds_helper.c.

{
  struct StopHelperState *shs;
 
  shs = GNUNET_new (struct StopHelperState);
  shs->helper_start_label = helper_start_label;
  shs->local_m = topology->nodes_m;
  shs->global_n = topology->namespaces_n;
  shs->known = topology->nodes_x;
  shs->topology = topology;
 
  return GNUNET_TESTING_command_new (shs, label,
                                     &stop_testing_system_run,
                                     &stop_testing_system_cleanup,
                                     NULL, NULL);
}

References StopHelperState::global_n, GNUNET_new, GNUNET_TESTING_command_new(), StopHelperState::helper_start_label, StopHelperState::known, StopHelperState::local_m, GNUNET_TESTING_NetjailTopology::namespaces_n, GNUNET_TESTING_NetjailTopology::nodes_m, GNUNET_TESTING_NetjailTopology::nodes_x, stop_testing_system_cleanup(), stop_testing_system_run(), and StopHelperState::topology.

Here is the call graph for this function:

GNUNET_TESTING_cmd_block_until_external_trigger()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_block_until_external_trigger

(

const char *

label

)

This command is used to block the loop, until the command is finished by other commands, using a trait to get this commands struct GNUNET_TESTING_AsyncContext.

Parameters

label

name for command.

Returns

command.

This command is used to block the loop, until the command is finished by other commands, using a trait to get this commands struct GNUNET_TESTING_AsyncContext.

Parameters

label

name for command.

Returns

command.

Definition at line 106 of file testing_api_cmd_block_until_external_trigger.c.

{
  struct GNUNET_TESTING_BlockState *bs;
 
  bs = GNUNET_new (struct GNUNET_TESTING_BlockState);
  bs->label = label;
  return GNUNET_TESTING_command_new (bs,
                                     label,
                                     &block_until_all_peers_started_run,
                                     &block_until_all_peers_started_cleanup,
                                     &block_until_external_trigger_traits,
                                     &bs->ac);
}

References GNUNET_TESTING_BlockState::ac, block_until_all_peers_started_cleanup(), block_until_all_peers_started_run(), block_until_external_trigger_traits(), GNUNET_new, GNUNET_TESTING_command_new(), and GNUNET_TESTING_BlockState::label.

Here is the call graph for this function:

GNUNET_TESTING_cmd_send_peer_ready()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_send_peer_ready	(	const char *	label,
		GNUNET_TESTING_cmd_helper_write_cb	write_message
	)

DEPRECATED This command sends a GNUNET_MESSAGE_TYPE_CMDS_HELPER_PEER_STARTED message to the master loop.

Parameters

label	name for command.
write_message	Callback to write messages to the master loop.

Returns

command.

DEPRECATED This command sends a GNUNET_MESSAGE_TYPE_CMDS_HELPER_PEER_STARTED message to the master loop.

Parameters

label	name for command.
write_message	Callback to write messages to the master loop.

Returns

command.

Definition at line 111 of file testing_api_cmd_send_peer_ready.c.

{
  struct SendPeerReadyState *sprs;
 
  sprs = GNUNET_new (struct SendPeerReadyState);
  sprs->write_message = write_message;
  return GNUNET_TESTING_command_new (sprs, label,
                                     &send_peer_ready_run,
                                     &send_peer_ready_cleanup,
                                     &send_peer_ready_traits, NULL);
}

References GNUNET_new, GNUNET_TESTING_command_new(), send_peer_ready_cleanup(), send_peer_ready_run(), send_peer_ready_traits(), write_message(), and SendPeerReadyState::write_message.

Here is the call graph for this function:

GNUNET_TESTING_cmd_local_test_prepared()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_local_test_prepared	(	const char *	label,
		GNUNET_TESTING_cmd_helper_write_cb	write_message
	)

This command sends a GNUNET_MESSAGE_TYPE_CMDS_HELPER_LOCAL_TESTS_PREPARED message to the master loop.

Parameters

label	name for command.
write_message	Callback to write messages to the master loop.

Returns

command.

Definition at line 98 of file testing_api_cmd_local_test_prepared.c.

{
  struct GNUNET_TESTING_LocalPreparedState *lfs;
 
  lfs = GNUNET_new (struct GNUNET_TESTING_LocalPreparedState);
  lfs->write_message = write_message;
 
  return GNUNET_TESTING_command_new (lfs, label,
                                     &local_test_prepared_run,
                                     &local_test_prepared_cleanup,
                                     &local_test_prepared_traits,
                                     &lfs->ac);
}

References GNUNET_TESTING_LocalPreparedState::ac, GNUNET_new, GNUNET_TESTING_command_new(), local_test_prepared_cleanup(), local_test_prepared_run(), local_test_prepared_traits(), GNUNET_TESTING_LocalPreparedState::write_message, and write_message().

Here is the call graph for this function:

GNUNET_TESTING_cmd_start_peer()

struct GNUNET_TESTING_Command GNUNET_TESTING_cmd_start_peer	(	const char *	label,
		const char *	system_label,
		uint32_t	no,
		const char *	node_ip,
		const char *	cfgname,
		unsigned int	broadcast
	)

Create command.

Parameters

label	name for command.
system_label	Label of the cmd to setup a test environment.
no	Decimal number representing the last byte of the IP address of this peer.
node_ip	The IP address of this node.
cfgname	Configuration file name for this peer.
broadcast	Flag indicating, if broadcast should be switched on.

Returns

command.

Definition at line 271 of file testing_api_cmd_start_peer.c.

{
  struct GNUNET_TESTING_StartPeerState *sps;
  struct GNUNET_CONTAINER_MultiShortmap *connected_peers_map =
    GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
 
  sps = GNUNET_new (struct GNUNET_TESTING_StartPeerState);
  sps->no = no;
  sps->system_label = GNUNET_strdup (system_label);
  sps->connected_peers_map = connected_peers_map;
  sps->cfgname = GNUNET_strdup (cfgname);
  sps->node_ip = GNUNET_strdup (node_ip);
  sps->broadcast = broadcast;
 
  return GNUNET_TESTING_command_new (sps,
                                     label,
                                     &start_peer_run,
                                     &start_peer_cleanup,
                                     &start_peer_traits,
                                     NULL);
}

References GNUNET_TESTING_StartPeerState::broadcast, GNUNET_TESTING_StartPeerState::cfgname, GNUNET_TESTING_StartPeerState::connected_peers_map, GNUNET_CONTAINER_multishortmap_create(), GNUNET_new, GNUNET_NO, GNUNET_strdup, GNUNET_TESTING_command_new(), GNUNET_TESTING_StartPeerState::no, GNUNET_TESTING_StartPeerState::node_ip, start_peer_cleanup(), start_peer_run(), start_peer_traits(), and GNUNET_TESTING_StartPeerState::system_label.

Here is the call graph for this function:

GNUNET_TESTING_get_trait_test_system()

enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait_test_system	(	const struct GNUNET_TESTING_Command *	cmd,
		const struct GNUNET_TESTING_System **	ret
	)

Referenced by backchannel_check_run(), connect_peers_run(), send_simple_run(), start_peer_run(), start_service_run(), and system_destroy_run().

Here is the caller graph for this function:

GNUNET_TESTING_make_trait_test_system()

struct GNUNET_TESTING_Trait GNUNET_TESTING_make_trait_test_system

(

const struct GNUNET_TESTING_System *

value

)

Referenced by system_create_traits().

Here is the caller graph for this function:

GNUNET_TESTING_get_trait_async_context()

enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait_async_context	(	const struct GNUNET_TESTING_Command *	cmd,
		struct GNUNET_TESTING_AsyncContext **	ret
	)

GNUNET_TESTING_make_trait_async_context()

struct GNUNET_TESTING_Trait GNUNET_TESTING_make_trait_async_context

(

struct GNUNET_TESTING_AsyncContext *

value

)

Referenced by barrier_reached_traits(), and block_until_external_trigger_traits().

Here is the caller graph for this function:

GNUNET_TESTING_get_trait_helper_handles()

enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait_helper_handles	(	const struct GNUNET_TESTING_Command *	cmd,
		const struct GNUNET_HELPER_Handle ***	ret
	)

Referenced by stop_testing_system_run().

Here is the caller graph for this function:

GNUNET_TESTING_make_trait_helper_handles()

struct GNUNET_TESTING_Trait GNUNET_TESTING_make_trait_helper_handles

(

const struct GNUNET_HELPER_Handle **

value

)

Referenced by netjail_exec_traits().

Here is the caller graph for this function:

GNUNET_TESTING_get_trait_local_prepared_state()

enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait_local_prepared_state	(	const struct GNUNET_TESTING_Command *	cmd,
		const struct GNUNET_TESTING_LocalPreparedState **	ret
	)

GNUNET_TESTING_make_trait_local_prepared_state()

struct GNUNET_TESTING_Trait GNUNET_TESTING_make_trait_local_prepared_state

(

const struct GNUNET_TESTING_LocalPreparedState *

value

)

Referenced by local_test_prepared_traits().

Here is the caller graph for this function:

GNUNET_TESTING_get_trait_block_state()

enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait_block_state	(	const struct GNUNET_TESTING_Command *	cmd,
		struct GNUNET_TESTING_BlockState **	ret
	)

GNUNET_TESTING_make_trait_block_state()

struct GNUNET_TESTING_Trait GNUNET_TESTING_make_trait_block_state

(

struct GNUNET_TESTING_BlockState *

value

)

Referenced by block_until_external_trigger_traits().

Here is the caller graph for this function: