transport-testing-cmds.h File Reference

#include "gnunet_testing_lib.h"
#include "gnunet_testing_transport_lib.h"

Include dependency graph for transport-testing-cmds.h:

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

Go to the source code of this file.

Data Structures
struct	ConnectPeersState
	Struct to store information needed in callbacks. More...
struct	TestState

Macros
#define	GNUNET_TRANSPORT_SIMPLE_TRAITS(op, prefix)    op (prefix, connect_peer_state, const struct ConnectPeersState)
	Call op on all simple traits. More...

Typedefs
typedef void *(*	GNUNET_TRANSPORT_notify_connect_cb) (struct GNUNET_TESTING_Interpreter *is, const struct GNUNET_PeerIdentity *peer)

Functions
struct GNUNET_TESTING_Command	GNUNET_TRANSPORT_cmd_start_peer (const char *label, const char *system_label, uint32_t no, const char *node_ip, struct GNUNET_MQ_MessageHandler *handlers, const char *cfgname, GNUNET_TRANSPORT_notify_connect_cb notify_connect, unsigned int broadcast)
	Create command. More...
struct GNUNET_TESTING_Command	GNUNET_TRANSPORT_cmd_stop_peer (const char *label, const char *start_label)
	Create command. More...
struct GNUNET_TESTING_Command	GNUNET_TRANSPORT_cmd_connect_peers (const char *label, const char *start_peer_label, const char *create_label, uint32_t num, struct GNUNET_TESTING_NetjailTopology *topology, unsigned int additional_connects, unsigned int wait_for_connect)
	Create command. More...
struct GNUNET_TESTING_Command	GNUNET_TRANSPORT_cmd_send_simple (const char *label, const char *start_peer_label, const char *create_label, uint32_t num, struct GNUNET_TESTING_NetjailTopology *topology)
	Create command. More...
struct GNUNET_TESTING_Command	GNUNET_TRANSPORT_cmd_send_simple_performance (const char *label, const char *start_peer_label, const char *create_label, uint32_t num, int size, int max_send, struct GNUNET_TESTING_NetjailTopology *topology)
struct GNUNET_TESTING_Command	GNUNET_TRANSPORT_cmd_backchannel_check (const char *label, const char *start_peer_label, const char *create_label, uint32_t num, unsigned int node_n, unsigned int namespace_n, struct GNUNET_TESTING_NetjailTopology *topology)
	Create command. More...

Macro Definition Documentation

GNUNET_TRANSPORT_SIMPLE_TRAITS

#define GNUNET_TRANSPORT_SIMPLE_TRAITS	(		op,
			prefix
	)		op (prefix, connect_peer_state, const struct ConnectPeersState)

Call op on all simple traits.

Definition at line 253 of file transport-testing-cmds.h.

Typedef Documentation

GNUNET_TRANSPORT_notify_connect_cb

typedef void *(* GNUNET_TRANSPORT_notify_connect_cb) (struct GNUNET_TESTING_Interpreter *is, const struct GNUNET_PeerIdentity *peer)

Definition at line 107 of file transport-testing-cmds.h.

Function Documentation

GNUNET_TRANSPORT_cmd_start_peer()

struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_start_peer	(	const char *	label,
		const char *	system_label,
		uint32_t	no,
		const char *	node_ip,
		struct GNUNET_MQ_MessageHandler *	handlers,
		const char *	cfgname,
		GNUNET_TRANSPORT_notify_connect_cb	notify_connect,
		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.
handlers	Handler for messages received by this peer.
cfgname	Configuration file name for this peer.
notify_connect	Method which will be called, when a peer connects.
broadcast	Flag indicating, if broadcast should be switched on.

Returns

command.

Definition at line 444 of file transport_api_cmd_start_peer.c.

{
  struct GNUNET_TESTING_StartPeerState *sps;
  struct GNUNET_CONTAINER_MultiShortmap *connected_peers_map =
    GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
  unsigned int i;
 
  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->notify_connect = notify_connect;
  sps->broadcast = broadcast;
 
  if (NULL != handlers)
  {
    for (i = 0; NULL != handlers[i].cb; i++)
      ;
    sps->handlers = GNUNET_new_array (i + 1,
                                      struct GNUNET_MQ_MessageHandler);
    GNUNET_memcpy (sps->handlers,
                   handlers,
                   i * sizeof(struct GNUNET_MQ_MessageHandler));
  }
  return GNUNET_TESTING_command_new_ac (sps,
                                        label,
                                        &start_peer_run,
                                        &start_peer_cleanup,
                                        &start_peer_traits,
                                        &sps->ac);
}

References GNUNET_TESTING_StartPeerState::ac, GNUNET_TESTING_StartPeerState::broadcast, GNUNET_TESTING_StartPeerState::cfgname, GNUNET_TESTING_StartPeerState::connected_peers_map, GNUNET_CONTAINER_multishortmap_create(), GNUNET_memcpy, GNUNET_new, GNUNET_new_array, GNUNET_NO, GNUNET_strdup, GNUNET_TESTING_command_new_ac(), handlers, GNUNET_TESTING_StartPeerState::handlers, GNUNET_TESTING_StartPeerState::no, GNUNET_TESTING_StartPeerState::node_ip, GNUNET_TESTING_StartPeerState::notify_connect, notify_connect(), start_peer_cleanup(), start_peer_run(), start_peer_traits(), and GNUNET_TESTING_StartPeerState::system_label.

Here is the call graph for this function:

GNUNET_TRANSPORT_cmd_stop_peer()

struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_stop_peer	(	const char *	label,
		const char *	start_label
	)

Create command.

Parameters

label	name for command.
start_label	Label of the cmd to start the peer.

Returns

command.

Definition at line 141 of file transport_api_cmd_stop_peer.c.

{
  struct StopPeerState *sps;
 
  sps = GNUNET_new (struct StopPeerState);
  sps->start_label = start_label;
  return GNUNET_TESTING_command_new (sps,
                                     label,
                                     &stop_peer_run,
                                     &stop_peer_cleanup,
                                     &stop_peer_traits);
}

References GNUNET_new, GNUNET_TESTING_command_new, StopPeerState::label, StopPeerState::start_label, stop_peer_cleanup(), stop_peer_run(), and stop_peer_traits().

Here is the call graph for this function:

GNUNET_TRANSPORT_cmd_connect_peers()

struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_connect_peers	(	const char *	label,
		const char *	start_peer_label,
		const char *	create_label,
		uint32_t	num,
		struct GNUNET_TESTING_NetjailTopology *	topology,
		unsigned int	additional_connects,
		unsigned int	wait_for_connect
	)

Create command.

Parameters

label	name for command
start_peer_label	Label of the cmd to start a peer.
create_label	Label of the cmd which started the test system.
num	Number globally identifying the node.
topology	The topology for the test setup.
additional_connects	Number of additional connects this cmd will wait for not triggered by this cmd.

Returns

command.

Definition at line 264 of file transport_api_cmd_connecting_peers.c.

{
  struct ConnectPeersState *cps;
  unsigned int node_additional_connects;
 
  node_additional_connects = GNUNET_TESTING_get_additional_connects (num,
                                                                     topology);
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "global: %u and local: %u additional_connects\n",
       additional_connects,
       node_additional_connects);
 
  if (0 != node_additional_connects)
    additional_connects = node_additional_connects;
 
  cps = GNUNET_new (struct ConnectPeersState);
  cps->start_peer_label = start_peer_label;
  cps->num = num;
  cps->create_label = create_label;
  cps->topology = topology;
  cps->notify_connect = notify_connect;
  cps->additional_connects = additional_connects;
  cps->wait_for_connect = wait_for_connect;
 
  // FIXME: wrap with cmd_make_unblocking!
  if (GNUNET_YES == wait_for_connect)
    return GNUNET_TESTING_command_new_ac (cps,
                                          label,
                                          &connect_peers_run,
                                          &connect_peers_cleanup,
                                          &connect_peers_traits,
                                          &cps->ac);
  else
    return GNUNET_TESTING_command_new (cps,
                                       label,
                                       &connect_peers_run,
                                       &connect_peers_cleanup,
                                       &connect_peers_traits);
}

References ConnectPeersState::ac, ConnectPeersState::additional_connects, connect_peers_cleanup(), connect_peers_run(), connect_peers_traits(), ConnectPeersState::create_label, GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_TESTING_command_new, GNUNET_TESTING_command_new_ac(), GNUNET_TESTING_get_additional_connects(), GNUNET_YES, LOG, ConnectPeersState::notify_connect, notify_connect(), ConnectPeersState::num, ConnectPeersState::start_peer_label, ConnectPeersState::topology, and ConnectPeersState::wait_for_connect.

Here is the call graph for this function:

GNUNET_TRANSPORT_cmd_send_simple()

struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_send_simple	(	const char *	label,
		const char *	start_peer_label,
		const char *	create_label,
		uint32_t	num,
		struct GNUNET_TESTING_NetjailTopology *	topology
	)

Create command.

Parameters

label	name for command.
start_peer_label	Label of the cmd to start a peer.
create_label	Label of the cmd which started the test system.
num	Number globally identifying the node.
topology	The topology for the test setup.

Returns

command.

Definition at line 141 of file transport_api_cmd_send_simple.c.

{
  struct SendSimpleState *sss;
 
  sss = GNUNET_new (struct SendSimpleState);
  sss->num = num;
  sss->start_peer_label = start_peer_label;
  sss->create_label = create_label;
  sss->topology = topology;
 
  return GNUNET_TESTING_command_new (sss,
                                     label,
                                     &send_simple_run,
                                     &send_simple_cleanup,
                                     NULL);
}

References SendSimpleState::create_label, GNUNET_new, GNUNET_TESTING_command_new, SendSimpleState::num, send_simple_cleanup(), send_simple_run(), SendSimpleState::start_peer_label, and SendSimpleState::topology.

Here is the call graph for this function:

GNUNET_TRANSPORT_cmd_send_simple_performance()

struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_send_simple_performance	(	const char *	label,
		const char *	start_peer_label,
		const char *	create_label,
		uint32_t	num,
		int	size,
		int	max_send,
		struct GNUNET_TESTING_NetjailTopology *	topology
	)

Parameters

label	name for command.
start_peer_label	Label of the cmd to start a peer.
create_label	Label of the cmd which started the test system.
num	Number globally identifying the node.
size	The size of the test message to send.
max_send	The number of messages to send.
topology	The topology for the test setup.

Returns

command.

Definition at line 192 of file transport_api_cmd_send_simple_performance.c.

{
  struct SendSimplePerfState *sss;
  struct GNUNET_TESTING_Command cmd;
 
  sss = GNUNET_new (struct SendSimplePerfState);
  sss->start_peer_label = start_peer_label;
  sss->create_label = create_label;
  sss->topology = topology;
  sss->size = size;
  sss->max_send = max_send;
  cmd = GNUNET_TESTING_command_new_ac (sss,
                                       label,
                                       &send_simple_run,
                                       &send_simple_cleanup,
                                       NULL,
                                       &sss->ac);
  cmd.asynchronous_finish = GNUNET_YES;
  return cmd;
}

References SendSimplePerfState::ac, GNUNET_TESTING_Command::asynchronous_finish, SendSimplePerfState::create_label, GNUNET_new, GNUNET_TESTING_command_new_ac(), GNUNET_YES, GNUNET_TESTING_Command::label, SendSimplePerfState::max_send, send_simple_cleanup(), send_simple_run(), size, SendSimplePerfState::size, SendSimplePerfState::start_peer_label, and SendSimplePerfState::topology.

Here is the call graph for this function:

GNUNET_TRANSPORT_cmd_backchannel_check()

struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_backchannel_check	(	const char *	label,
		const char *	start_peer_label,
		const char *	create_label,
		uint32_t	num,
		unsigned int	node_n,
		unsigned int	namespace_n,
		struct GNUNET_TESTING_NetjailTopology *	topology
	)

Create command.

Parameters

label	name for command.
start_peer_label	Label of the cmd to start a peer.
create_label	Label of the cmd to create the testing system.
num	Number globally identifying the node.
node_n	The number of the node in a network namespace.
namespace_n	The number of the network namespace.
topology	The topology for the test setup.

Returns

command.

Definition at line 529 of file transport_api_cmd_backchannel_check.c.

{
  struct CheckState *cs;
 
  cs = GNUNET_new (struct CheckState);
  cs->start_peer_label = start_peer_label;
  cs->num = num;
  cs->create_label = create_label;
  cs->topology = topology;
  cs->node_n = node_n;
  cs->namespace_n = namespace_n;
 
  return GNUNET_TESTING_command_new_ac (cs,
                                        label,
                                        &backchannel_check_run,
                                        &backchannel_check_cleanup,
                                        &backchannel_check_traits,
                                        &cs->ac);
}

References CheckState::ac, backchannel_check_cleanup(), backchannel_check_run(), backchannel_check_traits(), CheckState::create_label, GNUNET_new, GNUNET_TESTING_command_new_ac(), CheckState::namespace_n, CheckState::node_n, CheckState::num, CheckState::start_peer_label, and CheckState::topology.

Here is the call graph for this function: