#include "platform.h"
#include "testing_messenger_setup.h"
#include <stdio.h>
#include "gnunet_util_lib.h"
#include "gnunet_testbed_logger_service.h"
#include "gnunet_testbed_service.h"
#include "gnunet_testing_lib.h"
#include "gnunet_messenger_service.h"
#include "testing_messenger_barrier.h"

Include dependency graph for testing_messenger_setup.c:

Data Structures
struct	test_peer

struct	test_properties

Macros
#define	TEST_ROOM "test"

#define	TEST_NAME "tester"

Functions
static void	shutdown_cb (void *cls)

static void	end_cb (void *cls)

static void	end_badly_cb (void *cls)

static void	end_operation_cb (void *cls)

static void	end_error_cb (void *cls)

static void	barrier2_wait_cb (void cls, struct GNUNET_BarrierWaitHandle waiting, int status)

static void	barrier_wait_cb (void cls, struct GNUNET_BarrierWaitHandle waiting, int status)

static void	on_message (void cls, struct GNUNET_MESSENGER_Room room, const struct GNUNET_MESSENGER_Contact sender, const struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode *hash, enum GNUNET_MESSENGER_MessageFlags flags)
	Function called whenever a message is received or sent. More...

static void	second_stage (void *cls)

static void	on_peer (void cb_cls, struct GNUNET_TESTBED_Operation op, const struct GNUNET_TESTBED_PeerInformation pinfo, const char emsg)

static void	run (void cls, const struct GNUNET_TESTBED_EventInformation event)
	Main function for a peer of the testcase. More...

static void	barrier2_cb (void cls, struct GNUNET_BarrierHandle barrier, int status)

static void	barrier_cb (void cls, struct GNUNET_BarrierHandle barrier, int status)

static void	init (void cls, struct GNUNET_TESTBED_RunHandle h, unsigned int num_peers, struct GNUNET_TESTBED_Peer **peers, unsigned int links_succeeded, unsigned int links_failed)

int	GNUNET_run_messenger_setup (const char test_name, const struct test_configuration cfg)

Macro Definition Documentation

◆ TEST_ROOM

#define TEST_ROOM "test"

Definition at line 37 of file testing_messenger_setup.c.

◆ TEST_NAME

#define TEST_NAME "tester"

Definition at line 38 of file testing_messenger_setup.c.

Function Documentation

◆ shutdown_cb()

static void shutdown_cb ( void * cls )

static

Definition at line 78 of file testing_messenger_setup.c.

 {
   struct test_properties *properties = cls;
  
  
   for (unsigned int i = 0; i < properties->num_peer; i++)
   {
     struct test_peer *peer = &properties->peers[i];
  
     GNUNET_assert(peer != NULL);
  
     if (peer->op_task)
       GNUNET_SCHEDULER_cancel(peer->op_task);
  
     peer->op_task = NULL;
  
     if (peer->op)
       GNUNET_TESTBED_operation_done (peer->op);
  
     peer->op = NULL;
  
     if (peer->wait)
       GNUNET_cancel_wait_barrier(peer->wait);
  
     peer->wait = NULL;
  
     if (peer->room)
       GNUNET_MESSENGER_close_room (peer->room);
  
     peer->room = NULL;
  
     if (peer->handle)
       GNUNET_MESSENGER_disconnect (peer->handle);
  
     peer->handle = NULL;
   }
  
   if (properties->die_task)
     GNUNET_SCHEDULER_cancel(properties->die_task);
  
   properties->die_task = NULL;
   properties->end_task = NULL;
  
   if (properties->barrier)
     GNUNET_cancel_barrier(properties->barrier);
  
   properties->barrier = NULL;
 }

References test_properties::barrier, test_properties::die_task, test_properties::end_task, GNUNET_assert, GNUNET_cancel_barrier(), GNUNET_cancel_wait_barrier(), GNUNET_MESSENGER_close_room(), GNUNET_MESSENGER_disconnect(), GNUNET_SCHEDULER_cancel(), GNUNET_TESTBED_operation_done(), test_properties::num_peer, peer, and test_properties::peers.

Referenced by init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ end_cb()

static void end_cb ( void * cls )

static

Definition at line 130 of file testing_messenger_setup.c.

 {
   struct test_properties *properties = cls;
  
   GNUNET_assert(properties != NULL);
  
   properties->die_task = NULL;
  
   int status = 0;
  
   for (unsigned int i = 0; i < properties->num_peer; i++)
   {
     struct test_peer *peer = &properties->peers[i];
  
     GNUNET_assert(peer != NULL);
  
     const int members = GNUNET_MESSENGER_iterate_members(peer->room, NULL, NULL);
  
     GNUNET_assert (members >= 0);
  
     if (peer->props->num_peer != (unsigned int) members)
     {
       fprintf (stderr, "Testcase failed (members: %d/%u).\n", members, peer->props->num_peer);
       status = 1;
       break;
     }
   }
  
   GNUNET_SCHEDULER_shutdown ();
  
   properties->status = status;
 }

References test_properties::die_task, GNUNET_assert, GNUNET_MESSENGER_iterate_members(), GNUNET_SCHEDULER_shutdown(), test_properties::num_peer, peer, test_properties::peers, test_properties::status, and status.

Referenced by barrier2_cb(), and end_badly_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ end_badly_cb()

static void end_badly_cb ( void * cls )

static

Definition at line 164 of file testing_messenger_setup.c.

 {
   struct test_properties *properties = cls;
  
   GNUNET_assert(properties != NULL);
  
   fprintf (stderr, "Testcase failed (timeout).\n");
  
   end_cb (properties);
  
   properties->status = 1;
 }

References end_cb(), GNUNET_assert, and test_properties::status.

Referenced by init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ end_operation_cb()

static void end_operation_cb ( void * cls )

static

Definition at line 178 of file testing_messenger_setup.c.

 {
   struct test_peer *peer = cls;
  
   GNUNET_assert(peer != NULL);
  
   peer->op_task = NULL;
  
   fprintf (stderr, "Testcase failed (operation: '%s').\n", peer->message);
  
   GNUNET_SCHEDULER_shutdown ();
 }

References GNUNET_assert, GNUNET_SCHEDULER_shutdown(), and peer.

Referenced by on_message(), and on_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ end_error_cb()

static void end_error_cb ( void * cls )

static

Definition at line 192 of file testing_messenger_setup.c.

 {
   struct test_peer *peer = cls;
  
   GNUNET_assert(peer != NULL);
  
   peer->op_task = NULL;
  
   fprintf (stderr, "Testcase failed (error: '%s').\n", peer->message);
   GNUNET_free (peer);
  
   GNUNET_SCHEDULER_shutdown ();
 }

References GNUNET_assert, GNUNET_free, GNUNET_SCHEDULER_shutdown(), and peer.

Referenced by on_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ barrier2_wait_cb()

static void barrier2_wait_cb	(	void *	cls,
		struct GNUNET_BarrierWaitHandle *	waiting,
		int	status
	)

static

Definition at line 207 of file testing_messenger_setup.c.

 {
   struct test_peer *peer = cls;
  
   GNUNET_assert(peer != NULL);
  
   if (peer->wait == waiting)
     peer->wait = NULL;
 }

References GNUNET_assert, and peer.

Referenced by on_message().

Here is the caller graph for this function:

◆ barrier_wait_cb()

static void barrier_wait_cb	(	void *	cls,
		struct GNUNET_BarrierWaitHandle *	waiting,
		int	status
	)

static

Definition at line 220 of file testing_messenger_setup.c.

 {
   struct test_peer *peer = cls;
  
   GNUNET_assert(peer != NULL);
  
   if (peer->wait == waiting)
     peer->wait = NULL;
  
   if (0 != (peer->props->cfg->stages[peer->num - 1] & 0x02))
   {
     unsigned int door = peer->props->cfg->doors[peer->num - 1];
  
     if (door == 0)
       door = GNUNET_CRYPTO_random_u32(GNUNET_CRYPTO_QUALITY_WEAK, peer->props->cfg->count);
     else
       door = door - 1;
  
     struct GNUNET_HashCode hash;
     GNUNET_CRYPTO_hash (TEST_ROOM, sizeof(TEST_ROOM), &hash);
  
     struct GNUNET_MESSENGER_Room *room;
     room = GNUNET_MESSENGER_enter_room(peer->handle, &(peer->props->peers[door].peer_id), &hash);
  
     if (peer->room)
       GNUNET_assert(room == peer->room);
     else
       GNUNET_assert(room != NULL);
  
     peer->room = room;
   }
 }

References GNUNET_assert, GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u32(), GNUNET_MESSENGER_enter_room(), peer, and TEST_ROOM.

Referenced by on_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ on_message()

static void on_message	(	void *	cls,
		struct GNUNET_MESSENGER_Room *	room,
		const struct GNUNET_MESSENGER_Contact *	sender,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash,
		enum GNUNET_MESSENGER_MessageFlags	flags
	)

static

Function called whenever a message is received or sent.

Parameters

cls	Closure
room	Room
sender	Sender
message	Message
hash	Hash of message
flags	Flags of message

Definition at line 266 of file testing_messenger_setup.c.

 {
   struct test_peer *peer = cls;
  
   GNUNET_assert(peer != NULL);
  
   fprintf (stderr, "Peer: %s; [%s] Message: %s (%s)\n",
            GNUNET_i2s(&(peer->peer_id)),
            GNUNET_sh2s(&(message->header.sender_id)),
            GNUNET_MESSENGER_name_of_kind(message->header.kind),
            GNUNET_h2s(hash));
  
   if (GNUNET_MESSENGER_KIND_PEER == message->header.kind)
     peer->peer_messages++;
  
   if (peer->props->num_hosts == peer->peer_messages)
     peer->wait = GNUNET_wait_barrier (peer->props->barrier, &barrier2_wait_cb, peer);
   else if (peer->props->num_hosts < peer->peer_messages)
   {
     if (peer->wait)
       GNUNET_cancel_wait_barrier(peer->wait);
  
     peer->wait = NULL;
  
     if (peer->op_task)
       GNUNET_SCHEDULER_cancel(peer->op_task);
  
     peer->message = "peer";
     peer->op_task = GNUNET_SCHEDULER_add_now (&end_operation_cb, peer);
   }
 }

References barrier2_wait_cb(), end_operation_cb(), GNUNET_assert, GNUNET_cancel_wait_barrier(), GNUNET_h2s(), GNUNET_i2s(), GNUNET_MESSENGER_KIND_PEER, GNUNET_MESSENGER_name_of_kind(), GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_cancel(), GNUNET_sh2s(), GNUNET_wait_barrier(), test_peer::message, and peer.

Referenced by on_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ second_stage()

static void second_stage ( void * cls )

static

Definition at line 304 of file testing_messenger_setup.c.

 {
   struct test_peer *peer = cls;
  
   GNUNET_assert(peer != NULL);
  
   peer->op_task = NULL;
  
   struct GNUNET_HashCode hash;
   GNUNET_CRYPTO_hash (TEST_ROOM, sizeof(TEST_ROOM), &hash);
  
   if (0 != (peer->props->cfg->stages[peer->num - 1] & 0x10))
   {
     struct GNUNET_MESSENGER_Room *room;
     room = GNUNET_MESSENGER_open_room (peer->handle, &hash);
  
     if (peer->room)
       GNUNET_assert(room == peer->room);
     else
       GNUNET_assert(room != NULL);
  
     peer->room = room;
   }
  
   if (0 != (peer->props->cfg->stages[peer->num - 1] & 0x20))
   {
     unsigned int door = peer->props->cfg->doors[peer->num - 1];
  
     if (door == 0)
       door = GNUNET_CRYPTO_random_u32(GNUNET_CRYPTO_QUALITY_WEAK, peer->props->cfg->count);
     else
       door = door - 1;
  
     struct GNUNET_MESSENGER_Room *room;
     room = GNUNET_MESSENGER_enter_room(peer->handle, &(peer->props->peers[door].peer_id), &hash);
  
     if (peer->room)
       GNUNET_assert(room == peer->room);
     else
       GNUNET_assert(room != NULL);
  
     peer->room = room;
   }
 }

References GNUNET_assert, GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u32(), GNUNET_MESSENGER_enter_room(), GNUNET_MESSENGER_open_room(), peer, and TEST_ROOM.

Referenced by barrier_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ on_peer()

static void on_peer	(	void *	cb_cls,
		struct GNUNET_TESTBED_Operation *	op,
		const struct GNUNET_TESTBED_PeerInformation *	pinfo,
		const char *	emsg
	)

static

Definition at line 350 of file testing_messenger_setup.c.

 {
   struct test_peer *peer = cb_cls;
  
   GNUNET_assert(peer != NULL);
  
   if (emsg)
   {
     peer->message = GNUNET_strdup(emsg);
     peer->op_task = GNUNET_SCHEDULER_add_now (&end_error_cb, peer);
     return;
   }
  
   if (!pinfo)
   {
     peer->message = "info";
     peer->op_task = GNUNET_SCHEDULER_add_now (&end_operation_cb, peer);
     return;
   }
  
   if (pinfo->pit != GNUNET_TESTBED_PIT_CONFIGURATION)
   {
     peer->message = "config";
     peer->op_task = GNUNET_SCHEDULER_add_now (&end_operation_cb, peer);
     return;
   }
  
   peer->handle = GNUNET_MESSENGER_connect (pinfo->result.cfg, TEST_NAME, NULL, NULL, &on_message, peer);
  
   GNUNET_assert(GNUNET_OK == GNUNET_CRYPTO_get_peer_identity(
       pinfo->result.cfg, &(peer->peer_id)
   ));
  
   if (0 != (peer->props->cfg->stages[peer->num - 1] & 0x01))
   {
     struct GNUNET_HashCode hash;
     GNUNET_CRYPTO_hash (TEST_ROOM, sizeof(TEST_ROOM), &hash);
  
     peer->room = GNUNET_MESSENGER_open_room (peer->handle, &hash);
  
     GNUNET_assert(peer->room != NULL);
   }
   else
     peer->room = NULL;
  
   peer->wait = GNUNET_wait_barrier (peer->props->barrier, &barrier_wait_cb, peer);
 }

References barrier_wait_cb(), GNUNET_TESTBED_PeerInformation::cfg, end_error_cb(), end_operation_cb(), GNUNET_assert, GNUNET_CRYPTO_get_peer_identity(), GNUNET_CRYPTO_hash(), GNUNET_MESSENGER_connect(), GNUNET_MESSENGER_open_room(), GNUNET_OK, GNUNET_SCHEDULER_add_now(), GNUNET_strdup, GNUNET_TESTBED_PIT_CONFIGURATION, GNUNET_wait_barrier(), on_message(), peer, GNUNET_TESTBED_PeerInformation::pit, GNUNET_TESTBED_PeerInformation::result, TEST_NAME, and TEST_ROOM.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ run()

static void run	(	void *	cls,
		const struct GNUNET_TESTBED_EventInformation *	event
	)

static

Main function for a peer of the testcase.

Parameters

cls	Closure
event	Information about the event

Definition at line 408 of file testing_messenger_setup.c.

 {
   struct test_properties *properties = cls;
  
   GNUNET_assert(properties != NULL);
  
   if (GNUNET_TESTBED_ET_PEER_START != event->type)
   {
     fprintf (stderr, "Testcase failed (operation: 'start').\n");
  
     GNUNET_SCHEDULER_shutdown ();
     return;
   }
  
   struct test_peer *peer = &(properties->peers[properties->num_peer++]);
  
   peer->props = properties;
   peer->num = properties->num_peer;
  
   peer->peer = event->details.peer_start.peer;
   peer->op = GNUNET_TESTBED_peer_get_information (peer->peer, GNUNET_TESTBED_PIT_CONFIGURATION, on_peer, peer);
 }

References GNUNET_assert, GNUNET_SCHEDULER_shutdown(), GNUNET_TESTBED_ET_PEER_START, GNUNET_TESTBED_peer_get_information(), GNUNET_TESTBED_PIT_CONFIGURATION, test_properties::num_peer, on_peer(), peer, test_properties::peers, and GNUNET_TESTBED_EventInformation::type.

Referenced by GNUNET_run_messenger_setup().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ barrier2_cb()

static void barrier2_cb	(	void *	cls,
		struct GNUNET_BarrierHandle *	barrier,
		int	status
	)

static

Definition at line 433 of file testing_messenger_setup.c.

 {
   struct test_properties *properties = cls;
  
   GNUNET_assert(properties != NULL);
  
   if (properties->barrier == barrier)
     properties->barrier = NULL;
  
   if (GNUNET_SYSERR == status)
   {
     fprintf (stderr, "Testcase failed (operation: 'barrier2').\n");
  
     GNUNET_SCHEDULER_shutdown ();
     return;
   }
   else if (GNUNET_OK == status)
   {
     if (properties->die_task)
       GNUNET_SCHEDULER_cancel(properties->die_task);
  
     properties->die_task = GNUNET_SCHEDULER_add_delayed (
         GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, properties->cfg->count),
         &end_cb, properties
     );
   }
 }

References test_properties::barrier, test_properties::cfg, test_configuration::count, test_properties::die_task, end_cb(), GNUNET_assert, GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_cancel(), GNUNET_SCHEDULER_shutdown(), GNUNET_SYSERR, GNUNET_TIME_relative_multiply(), GNUNET_TIME_UNIT_SECONDS, and status.

Referenced by barrier_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ barrier_cb()

static void barrier_cb	(	void *	cls,
		struct GNUNET_BarrierHandle *	barrier,
		int	status
	)

static

Definition at line 464 of file testing_messenger_setup.c.

 {
   struct test_properties *properties = cls;
  
   GNUNET_assert(properties != NULL);
  
   if (properties->barrier == barrier)
     properties->barrier = NULL;
   else if (!properties->barrier)
     return;
  
   if (properties->num_peer != properties->cfg->count)
   {
     fprintf (stderr, "Testcase failed (operation: 'process').\n");
  
     GNUNET_SCHEDULER_shutdown ();
     return;
   }
  
   if (GNUNET_SYSERR == status)
   {
     fprintf (stderr, "Testcase failed (operation: 'barrier').\n");
  
     GNUNET_SCHEDULER_shutdown ();
     return;
   }
   else if (GNUNET_OK == status)
   {
     properties->barrier = GNUNET_init_barrier (properties->num_peer, &barrier2_cb, properties);
  
     for (unsigned int i = 0; i < properties->num_peer; i++)
       properties->peers[i].op_task = GNUNET_SCHEDULER_add_now (&second_stage, &(properties->peers[i]));
   }
 }

References test_properties::barrier, barrier2_cb(), test_properties::cfg, test_configuration::count, GNUNET_assert, GNUNET_init_barrier(), GNUNET_OK, GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_shutdown(), GNUNET_SYSERR, test_properties::num_peer, test_peer::op_task, test_properties::peers, second_stage(), and status.

Referenced by GNUNET_run_messenger_setup().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ init()

static void init	(	void *	cls,
		struct GNUNET_TESTBED_RunHandle *	h,
		unsigned int	num_peers,
		struct GNUNET_TESTBED_Peer **	peers,
		unsigned int	links_succeeded,
		unsigned int	links_failed
	)

static

Definition at line 502 of file testing_messenger_setup.c.

 {
   struct test_properties *properties = cls;
  
   GNUNET_assert(properties != NULL);
  
   properties->end_task = GNUNET_SCHEDULER_add_shutdown(&shutdown_cb, properties);
   properties->die_task = GNUNET_SCHEDULER_add_delayed (
       GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, properties->cfg->count * 5),
       &end_badly_cb, properties
   );
 }

References test_properties::cfg, test_configuration::count, test_properties::die_task, end_badly_cb(), test_properties::end_task, GNUNET_assert, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_add_shutdown(), GNUNET_TIME_relative_multiply(), GNUNET_TIME_UNIT_SECONDS, and shutdown_cb().

Referenced by GNUNET_run_messenger_setup().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_run_messenger_setup()

int GNUNET_run_messenger_setup	(	const char *	test_name,
		const struct test_configuration *	cfg
	)

Definition at line 521 of file testing_messenger_setup.c.

 {
   struct test_properties properties;
   memset(&properties, 0, sizeof(properties));
  
   properties.cfg = cfg;
   properties.peers = GNUNET_new_array(cfg->count, struct test_peer);
  
   for (unsigned int i = 0; i < cfg->count; i++)
     if (0 != (cfg->stages[i] & 0x11))
       properties.num_hosts++;
  
   properties.status = 1;
   properties.barrier = GNUNET_init_barrier (cfg->count, &barrier_cb, &properties);
  
   if (GNUNET_OK != GNUNET_TESTBED_test_run (test_name, "test_messenger_api.conf",
                                             cfg->count,
                                             (1LL << GNUNET_TESTBED_ET_PEER_START),
                                             &run, &properties,
                                             &init, &properties))
     return 1;
  
   GNUNET_free(properties.peers);
  
   return properties.status;
 }

References test_properties::barrier, barrier_cb(), cfg, test_properties::cfg, GNUNET_free, GNUNET_init_barrier(), GNUNET_new_array, GNUNET_OK, GNUNET_TESTBED_ET_PEER_START, GNUNET_TESTBED_test_run(), init(), test_properties::num_hosts, test_properties::peers, run(), and test_properties::status.

Here is the call graph for this function:

Data Structures

Macros

Functions

Macro Definition Documentation

◆ TEST_ROOM

◆ TEST_NAME

Function Documentation

◆ shutdown_cb()

◆ end_cb()

◆ end_badly_cb()

◆ end_operation_cb()

◆ end_error_cb()

◆ barrier2_wait_cb()

◆ barrier_wait_cb()

◆ on_message()

◆ second_stage()

◆ on_peer()

◆ run()

◆ barrier2_cb()

◆ barrier_cb()

◆ init()

◆ GNUNET_run_messenger_setup()