gnunet_testing_core_lib.h File Reference

#include "gnunet_util_lib.h"
#include "gnunet_testing_lib.h"

Include dependency graph for gnunet_testing_core_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_ConnectPeersState
	Struct to store information needed in callbacks. More...
struct	GNUNET_TESTING_CORE_Channel
struct	GNUNET_TESTING_CORE_Message
struct	GNUNET_TESTING_CORE_ConnectCb
struct	GNUNET_TESTING_CORE_ConnectState

Macros
#define	MTYPE   12345
	API for cmds working with core sub system provided by libgnunetcoretesting.
#define	NODE_ID_LEN   16
#define	GNUNET_CORE_TESTING_SIMPLE_TRAITS(op, prefix)
	Call op on all simple traits.

Typedefs
typedef void *(*	GNUNET_TESTING_CORE_connect_cb) (void *cls, const struct GNUNET_PeerIdentity *peer_id, struct GNUNET_MQ_Handle *mq)
typedef void(*	GNUNET_TESTING_CORE_handle_msg) (void *cls, struct GNUNET_TESTING_CORE_Channel *channel, const struct GNUNET_TESTING_CORE_Message *msg)

Functions
struct GNUNET_TESTING_Command	GNUNET_CORE_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, struct GNUNET_MQ_MessageHandler *handlers)
	FIXME: document properly! Create command.
const struct GNUNET_TESTING_Command	GNUNET_TESTING_CORE_cmd_connect (const char *label, const char *node_id, char *arm_service_label)
const struct GNUNET_TESTING_Command	GNUNET_TESTING_CORE_cmd_recv (const char *label, uint64_t num_messages)
const struct GNUNET_TESTING_Command	GNUNET_TESTING_CORE_cmd_send (const char *label, uint64_t num_messages, enum GNUNET_GenericReturnValue await_new_connection)
enum GNUNET_GenericReturnValue	GNUNET_CORE_TESTING_get_trait_connect_peer_state (const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_TESTING_ConnectPeersState **ret)
struct GNUNET_TESTING_Trait	GNUNET_CORE_TESTING_make_trait_connect_peer_state (const struct GNUNET_TESTING_ConnectPeersState *value)
enum GNUNET_GenericReturnValue	GNUNET_CORE_TESTING_get_trait_connect (const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_TESTING_CORE_ConnectState **ret)
struct GNUNET_TESTING_Trait	GNUNET_CORE_TESTING_make_trait_connect (const struct GNUNET_TESTING_CORE_ConnectState *value)

Macro Definition Documentation

MTYPE

#define MTYPE   12345

API for cmds working with core sub system provided by libgnunetcoretesting.

Author

t3sserakt

Definition at line 33 of file gnunet_testing_core_lib.h.

NODE_ID_LEN

#define NODE_ID_LEN   16

Definition at line 35 of file gnunet_testing_core_lib.h.

GNUNET_CORE_TESTING_SIMPLE_TRAITS

#define GNUNET_CORE_TESTING_SIMPLE_TRAITS	(		op,
			prefix
	)

Value:

        op (prefix, connect_peer_state, const struct \
            GNUNET_TESTING_ConnectPeersState) \
        op (prefix, connect, const struct \
            GNUNET_TESTING_CORE_ConnectState)

Call op on all simple traits.

Definition at line 250 of file gnunet_testing_core_lib.h.

Typedef Documentation

GNUNET_TESTING_CORE_connect_cb

typedef void *(* GNUNET_TESTING_CORE_connect_cb) (void *cls, const struct GNUNET_PeerIdentity *peer_id, struct GNUNET_MQ_Handle *mq)

Definition at line 153 of file gnunet_testing_core_lib.h.

GNUNET_TESTING_CORE_handle_msg

typedef void(* GNUNET_TESTING_CORE_handle_msg) (void *cls, struct GNUNET_TESTING_CORE_Channel *channel, const struct GNUNET_TESTING_CORE_Message *msg)

Definition at line 167 of file gnunet_testing_core_lib.h.

Function Documentation

GNUNET_CORE_cmd_connect_peers()

struct GNUNET_TESTING_Command GNUNET_CORE_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,
		struct GNUNET_MQ_MessageHandler *	handlers
	)

FIXME: document properly! 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 212 of file testing_core_cmd_connecting_peers.c.

{
  struct GNUNET_TESTING_ConnectPeersState *cps;
  unsigned int node_additional_connects;
  struct GNUNET_CONTAINER_MultiShortmap *connected_peers_map =
    GNUNET_CONTAINER_multishortmap_create (1,GNUNET_NO);
  unsigned int i;
 
  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 GNUNET_TESTING_ConnectPeersState);
  cps->start_peer_label = start_peer_label;
  cps->num = num;
  cps->create_label = create_label;
  cps->topology = topology;
  cps->additional_connects = additional_connects;
  cps->wait_for_connect = wait_for_connect;
  cps->connected_peers_map = connected_peers_map;
 
  if (NULL != handlers)
  {
    for (i = 0; NULL != handlers[i].cb; i++)
      ;
    cps->handlers = GNUNET_new_array (i + 1,
                                      struct GNUNET_MQ_MessageHandler);
    GNUNET_memcpy (cps->handlers,
                   handlers,
                   i * sizeof(struct GNUNET_MQ_MessageHandler));
  }
  // 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 GNUNET_TESTING_ConnectPeersState::ac, GNUNET_TESTING_ConnectPeersState::additional_connects, connect_peers_cleanup(), connect_peers_run(), connect_peers_traits(), GNUNET_TESTING_ConnectPeersState::connected_peers_map, GNUNET_TESTING_ConnectPeersState::create_label, GNUNET_CONTAINER_multishortmap_create(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_memcpy, GNUNET_new, GNUNET_new_array, GNUNET_NO, GNUNET_TESTING_command_new, GNUNET_TESTING_command_new_ac(), GNUNET_TESTING_get_additional_connects(), GNUNET_YES, handlers, GNUNET_TESTING_ConnectPeersState::handlers, LOG, GNUNET_TESTING_ConnectPeersState::num, GNUNET_TESTING_ConnectPeersState::start_peer_label, GNUNET_TESTING_ConnectPeersState::topology, and GNUNET_TESTING_ConnectPeersState::wait_for_connect.

Here is the call graph for this function:

GNUNET_TESTING_CORE_cmd_connect()

const struct GNUNET_TESTING_Command GNUNET_TESTING_CORE_cmd_connect	(	const char *	label,
		const char *	node_id,
		char *	arm_service_label
	)

Definition at line 297 of file testing_core_cmd_connect.c.

{
  struct GNUNET_TESTING_CORE_ConnectState *connect_state;
 
  // TODO get handler from caller to call on new connections
 
  connect_state = GNUNET_new (struct GNUNET_TESTING_CORE_ConnectState);
  connect_state->node_id = GNUNET_strdup (node_id);
  connect_state->arm_service_label = GNUNET_strdup (arm_service_label);
  connect_state->recv_handlers_len = 0;
  connect_state->recv_handlers =
    GNUNET_new_array (connect_state->recv_handlers_len,
                      GNUNET_TESTING_CORE_handle_msg);
  connect_state->connect_cbs_len = 0;
  connect_state->connect_cbs =
    GNUNET_new_array (connect_state->connect_cbs_len,
                      struct GNUNET_TESTING_CORE_ConnectCb);
  connect_state->finished = GNUNET_NO;
  LOG (GNUNET_ERROR_TYPE_DEBUG, "(Setting up _cmd_connect)\n");
  return GNUNET_TESTING_command_new_ac ( // TODO make this sync?
      connect_state, // state
      label,
      &exec_connect_run,
      &exec_connect_cleanup,
      &connect_traits,
      &connect_state->ac); // TODO make this sync?
}

References GNUNET_TESTING_CORE_ConnectState::ac, GNUNET_TESTING_CORE_ConnectState::arm_service_label, GNUNET_TESTING_CORE_ConnectState::connect_cbs, GNUNET_TESTING_CORE_ConnectState::connect_cbs_len, connect_traits(), exec_connect_cleanup(), exec_connect_run(), GNUNET_TESTING_CORE_ConnectState::finished, GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_new_array, GNUNET_NO, GNUNET_strdup, GNUNET_TESTING_command_new_ac(), LOG, GNUNET_TESTING_CORE_ConnectState::node_id, GNUNET_TESTING_CORE_ConnectState::recv_handlers, and GNUNET_TESTING_CORE_ConnectState::recv_handlers_len.

Here is the call graph for this function:

GNUNET_TESTING_CORE_cmd_recv()

const struct GNUNET_TESTING_Command GNUNET_TESTING_CORE_cmd_recv	(	const char *	label,
		uint64_t	num_messages
	)

Definition at line 251 of file testing_core_cmd_recv.c.

{
  struct RecvState *rs;
 
  // TODO this could be a static global variable
  rs = GNUNET_new (struct RecvState);
  rs->num_channels = 0;
  rs->channel_count = GNUNET_new_array (rs->num_channels, struct ChannelCount);
  rs->num_messages_target = num_messages;
  LOG (GNUNET_ERROR_TYPE_DEBUG, "(Setting up _cmd_recv)\n");
  return GNUNET_TESTING_command_new_ac (
      rs, // state
      label,
      &exec_recv_run,
      &exec_recv_cleanup,
      NULL, // traits
      &rs->ac); // FIXME
}

References RecvState::ac, RecvState::channel_count, exec_recv_cleanup(), exec_recv_run(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_new_array, GNUNET_TESTING_command_new_ac(), LOG, RecvState::num_channels, and RecvState::num_messages_target.

Here is the call graph for this function:

GNUNET_TESTING_CORE_cmd_send()

const struct GNUNET_TESTING_Command GNUNET_TESTING_CORE_cmd_send	(	const char *	label,
		uint64_t	num_messages,
		enum GNUNET_GenericReturnValue	await_new_connection
	)

Definition at line 198 of file testing_core_cmd_send.c.

{
  struct SendState *send_state;
 
  // TODO make struct static global?
  send_state = GNUNET_new (struct SendState);
  send_state->num_messages = num_messages;
  send_state->await_new_connection = await_new_connection;
  LOG (GNUNET_ERROR_TYPE_DEBUG, "(Setting up _cmd_send)\n");
  return GNUNET_TESTING_command_new (
      send_state, // state
      label,
      &exec_send_run,
      &exec_send_cleanup,
      NULL);
}

References SendState::await_new_connection, exec_send_cleanup(), exec_send_run(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_TESTING_command_new, LOG, and SendState::num_messages.

Here is the call graph for this function:

GNUNET_CORE_TESTING_get_trait_connect_peer_state()

enum GNUNET_GenericReturnValue GNUNET_CORE_TESTING_get_trait_connect_peer_state	(	const struct GNUNET_TESTING_Command *	cmd,
		const struct GNUNET_TESTING_ConnectPeersState **	ret
	)

GNUNET_CORE_TESTING_make_trait_connect_peer_state()

struct GNUNET_TESTING_Trait GNUNET_CORE_TESTING_make_trait_connect_peer_state

(

const struct GNUNET_TESTING_ConnectPeersState *

value

)

Referenced by connect_peers_traits().

Here is the caller graph for this function:

GNUNET_CORE_TESTING_get_trait_connect()

enum GNUNET_GenericReturnValue GNUNET_CORE_TESTING_get_trait_connect	(	const struct GNUNET_TESTING_Command *	cmd,
		const struct GNUNET_TESTING_CORE_ConnectState **	ret
	)

Referenced by exec_recv_run(), and exec_send_run().

Here is the caller graph for this function:

GNUNET_CORE_TESTING_make_trait_connect()

struct GNUNET_TESTING_Trait GNUNET_CORE_TESTING_make_trait_connect

(

const struct GNUNET_TESTING_CORE_ConnectState *

value

)

Referenced by connect_traits().

Here is the caller graph for this function: