transport_api_cmd_send_simple_performance.c File Reference

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_testing_ng_lib.h"
#include "gnunet_testing_netjail_lib.h"
#include "transport-testing2.h"
#include "transport-testing-cmds.h"

Include dependency graph for transport_api_cmd_send_simple_performance.c:

Go to the source code of this file.

Data Structures
struct	SendSimplePerfState
	Struct to hold information for callbacks. More...
struct	MQWrapper

Macros
#define	LOG(kind, ...)   GNUNET_log (kind, __VA_ARGS__)
	Generic logging shortcut. More...

Functions
static void	send_simple_cleanup (void *cls)
	The cleanup function of this cmd frees resources the cmd allocated. More...
static void	send_simple_single (void *cls)
static int	send_simple_cb (void *cls, const struct GNUNET_ShortHashCode *key, void *value)
static void	send_simple_run (void *cls, struct GNUNET_TESTING_Interpreter *is)
	The run method of this cmd will send a simple message to the connected peers. 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)

Macro Definition Documentation

LOG

#define LOG	(		kind,
			...
	)		GNUNET_log (kind, __VA_ARGS__)

Generic logging shortcut.

Definition at line 36 of file transport_api_cmd_send_simple_performance.c.

Function Documentation

send_simple_cleanup()

static void send_simple_cleanup ( void *  cls )

static

The cleanup function of this cmd frees resources the cmd allocated.

Definition at line 100 of file transport_api_cmd_send_simple_performance.c.

{
  struct SendSimpleState *sss = cls;
 
  GNUNET_free (sss);
}

References GNUNET_free.

send_simple_single()

static void send_simple_single ( void *  cls )

static

Definition at line 109 of file transport_api_cmd_send_simple_performance.c.

{
  struct MQWrapper *mq_wrapper = cls;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_TRANSPORT_TESTING_PerformanceTestMessage *test;
  struct GNUNET_TIME_Absolute now;
 
  now = GNUNET_TIME_absolute_get ();
  mq_wrapper->num_send++;
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Sending simple test message with size %u number %u with mq %p max %u\n",
       mq_wrapper->sss->size,
       mq_wrapper->num_send,
       mq_wrapper->mq,
       mq_wrapper->sss->max_send);
 
  env = GNUNET_MQ_msg_extra (test,
                             mq_wrapper->sss->size - sizeof(*test),
                             GNUNET_TRANSPORT_TESTING_SIMPLE_PERFORMANCE_MTYPE);
  test->num = htonl (mq_wrapper->num_send);
  test->time_send = GNUNET_TIME_absolute_hton (now);
  memset (&test[1],
          '1',
          mq_wrapper->sss->size - sizeof(*test));
  GNUNET_MQ_send (mq_wrapper->mq,
                  env);
  if (mq_wrapper->sss->max_send > mq_wrapper->num_send)
    GNUNET_SCHEDULER_add_now (&send_simple_single, mq_wrapper);
  else
    GNUNET_TESTING_async_finish (&mq_wrapper->sss->ac);
}

References SendSimplePerfState::ac, env, GNUNET_ERROR_TYPE_DEBUG, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_SCHEDULER_add_now(), GNUNET_TESTING_async_finish(), GNUNET_TIME_absolute_get(), GNUNET_TIME_absolute_hton(), GNUNET_TRANSPORT_TESTING_SIMPLE_PERFORMANCE_MTYPE, LOG, SendSimplePerfState::max_send, MQWrapper::mq, GNUNET_TRANSPORT_TESTING_PerformanceTestMessage::num, MQWrapper::num_send, SendSimplePerfState::size, MQWrapper::sss, and GNUNET_TRANSPORT_TESTING_PerformanceTestMessage::time_send.

Referenced by send_simple_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

send_simple_cb()

static int send_simple_cb ( void *  cls, const struct GNUNET_ShortHashCode *  key, void *  value  )

static

Definition at line 143 of file transport_api_cmd_send_simple_performance.c.

{
  struct SendSimplePerfState *sss = cls;
  struct GNUNET_MQ_Handle *mq = value;
  struct MQWrapper *mq_wrapper = GNUNET_new (struct MQWrapper);
 
  mq_wrapper->sss = sss;
  mq_wrapper->mq = mq;
  send_simple_single (mq_wrapper);
 
  return GNUNET_OK;
}

References GNUNET_new, GNUNET_OK, mq, MQWrapper::mq, send_simple_single(), MQWrapper::sss, and value.

Here is the call graph for this function:

send_simple_run()

static void send_simple_run ( void *  cls, struct GNUNET_TESTING_Interpreter *  is  )

static

The run method of this cmd will send a simple message to the connected peers.

Definition at line 164 of file transport_api_cmd_send_simple_performance.c.

{
  struct SendSimplePerfState *sss = cls;
  const struct GNUNET_CONTAINER_MultiShortmap *connected_peers_map;
  const struct GNUNET_TESTING_Command *peer1_cmd;
  const struct GNUNET_TESTING_Command *system_cmd;
  const struct GNUNET_TESTING_System *tl_system;
 
 
  peer1_cmd = GNUNET_TESTING_interpreter_lookup_command (is,
                                                         sss->start_peer_label);
  GNUNET_TRANSPORT_get_trait_connected_peers_map (peer1_cmd,
                                                  &connected_peers_map);
 
  system_cmd = GNUNET_TESTING_interpreter_lookup_command (is,
                                                          sss->create_label);
  GNUNET_TESTING_get_trait_test_system (system_cmd,
                                        &tl_system);
 
  GNUNET_CONTAINER_multishortmap_iterate (
    (struct GNUNET_CONTAINER_MultiShortmap *)
    connected_peers_map, send_simple_cb,
    sss);
}

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 164 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 (sss,
                                    label,
                                    &send_simple_run,
                                    &send_simple_cleanup,
                                    NULL,
                                    &sss->ac);
  cmd.asynchronous_finish = GNUNET_YES;
  return cmd;
}