transport_api_cmd_send_simple.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.c:

Go to the source code of this file.

Data Structures
struct	SendSimpleState
	Struct to hold information for callbacks. More...

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 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 (const char *label, const char *start_peer_label, const char *create_label, uint32_t num, 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.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 74 of file transport_api_cmd_send_simple.c.

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

References GNUNET_free.

Referenced by GNUNET_TRANSPORT_cmd_send_simple().

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 83 of file transport_api_cmd_send_simple.c.

{
  struct SendSimpleState *sss = cls;
  struct GNUNET_MQ_Handle *mq = value;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_TRANSPORT_TESTING_TestMessage *test;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Sending simple test message with mq %p\n",
       mq);
 
  env = GNUNET_MQ_msg_extra (test,
                             1000 - sizeof(*test),
                             GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE);
  test->num = htonl (sss->num);
  memset (&test[1],
          sss->num,
          1000 - sizeof(*test));
  GNUNET_MQ_send (mq,
                  env);
  return GNUNET_OK;
}

References env, GNUNET_ERROR_TYPE_DEBUG, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_OK, GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE, LOG, mq, SendSimpleState::num, GNUNET_TRANSPORT_TESTING_TestMessage::num, and value.

Referenced by send_simple_run().

Here is the call graph for this function:

Here is the caller 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 114 of file transport_api_cmd_send_simple.c.

{
  struct SendSimpleState *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_TESTBED_System *tl_system;
 
  peer1_cmd = GNUNET_TESTING_interpreter_lookup_command (is,
                                                         sss->start_peer_label);
  GNUNET_TRANSPORT_TESTING_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);
}

References SendSimpleState::create_label, GNUNET_CONTAINER_multishortmap_iterate(), GNUNET_TESTING_interpreter_lookup_command(), GNUNET_TRANSPORT_TESTING_get_trait_connected_peers_map(), is, send_simple_cb(), and SendSimpleState::start_peer_label.

Referenced by GNUNET_TRANSPORT_cmd_send_simple().

Here is the call graph for this function:

Here is the caller 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
	)

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: