#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_statistics_service.h"
#include "gnunet_seti_service.h"
#include "gnunet_testbed_service.h"

Include dependency graph for gnunet-seti-profiler.c:

Data Structures
struct	SetInfo

Functions
static int	map_remove_iterator (void cls, const struct GNUNET_HashCode key, void *value)

static int	statistics_result (void cls, const char subsystem, const char *name, uint64_t value, int is_persistent)
	Callback function to process statistic values. More...

static void	statistics_done (void *cls, int success)

static void	check_all_done (void)

static void	set_result_cb (void cls, const struct GNUNET_SETI_Element element, uint64_t current_size, enum GNUNET_SETI_Status status)

static void	set_listen_cb (void cls, const struct GNUNET_PeerIdentity other_peer, const struct GNUNET_MessageHeader context_msg, struct GNUNET_SETI_Request request)

static int	set_insert_iterator (void cls, const struct GNUNET_HashCode key, void *value)

static void	handle_shutdown (void *cls)

static void	run (void cls, const struct GNUNET_CONFIGURATION_Handle cfg, struct GNUNET_TESTING_Peer *peer)

static void	pre_run (void cls, char const args, const char cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg)

int	main (int argc, char **argv)

Variables
static int	ret

static unsigned int	num_a = 5

static unsigned int	num_b = 5

static unsigned int	num_c = 20

static const struct GNUNET_CONFIGURATION_Handle *	config

struct SetInfo	info1

struct SetInfo	info2

static struct GNUNET_CONTAINER_MultiHashMap *	common_sent

static struct GNUNET_HashCode	app_id

static struct GNUNET_PeerIdentity	local_peer

static struct GNUNET_SETI_ListenHandle *	set_listener

static unsigned int	use_intersection

static unsigned int	element_size = 32

static struct GNUNET_STATISTICS_Handle *	statistics
	Handle to the statistics service. More...

static char *	statistics_filename
	The profiler will write statistics for all peers to the file with this name. More...

static FILE *	statistics_file
	The profiler will write statistics for all peers to this file. More...

Function Documentation

◆ map_remove_iterator()

static int map_remove_iterator	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Definition at line 82 of file gnunet-seti-profiler.c.

 {
   struct GNUNET_CONTAINER_MultiHashMap *m = cls;
   int ret;
  
   GNUNET_assert (NULL != key);
  
   ret = GNUNET_CONTAINER_multihashmap_remove_all (m, key);
   if (GNUNET_OK != ret)
     printf ("spurious element\n");
   return GNUNET_YES;
 }

References GNUNET_assert, GNUNET_CONTAINER_multihashmap_remove_all(), GNUNET_OK, GNUNET_YES, key, m, and ret.

Referenced by check_all_done().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ statistics_result()

static int statistics_result	(	void *	cls,
		const char *	subsystem,
		const char *	name,
		uint64_t	value,
		int	is_persistent
	)

static

Callback function to process statistic values.

Parameters

cls	closure
subsystem	name of subsystem that created the statistic
name	the name of the datum
value	the current value
is_persistent	GNUNET_YES if the value is persistent, GNUNET_NO if not

Returns: GNUNET_OK to continue, GNUNET_SYSERR to abort iteration

Definition at line 109 of file gnunet-seti-profiler.c.

 {
   if (NULL != statistics_file)
   {
     fprintf (statistics_file, "%s\t%s\t%lu\n", subsystem, name, (unsigned
                                                                  long) value);
   }
   return GNUNET_OK;
 }

References GNUNET_OK, name, statistics_file, subsystem, and value.

Referenced by check_all_done().

Here is the caller graph for this function:

◆ statistics_done()

static void statistics_done	(	void *	cls,
		int	success
	)

static

Definition at line 125 of file gnunet-seti-profiler.c.

 {
   GNUNET_assert (GNUNET_YES == success);
   if (NULL != statistics_file)
     fclose (statistics_file);
   GNUNET_SCHEDULER_shutdown ();
 }

References GNUNET_assert, GNUNET_SCHEDULER_shutdown(), GNUNET_YES, and statistics_file.

Referenced by check_all_done().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ check_all_done()

static void check_all_done ( void )

static

Definition at line 136 of file gnunet-seti-profiler.c.

 {
   if ((info1.done == GNUNET_NO) || (info2.done == GNUNET_NO))
     return;
  
   GNUNET_CONTAINER_multihashmap_iterate (info1.received, map_remove_iterator,
                                          info2.sent);
   GNUNET_CONTAINER_multihashmap_iterate (info2.received, map_remove_iterator,
                                          info1.sent);
  
   printf ("set a: %d missing elements\n", GNUNET_CONTAINER_multihashmap_size (
             info1.sent));
   printf ("set b: %d missing elements\n", GNUNET_CONTAINER_multihashmap_size (
             info2.sent));
  
   if (NULL == statistics_filename)
   {
     GNUNET_SCHEDULER_shutdown ();
     return;
   }
  
   statistics_file = fopen (statistics_filename, "w");
   GNUNET_STATISTICS_get (statistics, NULL, NULL,
                          &statistics_done,
                          &statistics_result, NULL);
 }

References SetInfo::done, GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_CONTAINER_multihashmap_size(), GNUNET_NO, GNUNET_SCHEDULER_shutdown(), GNUNET_STATISTICS_get(), info1, info2, map_remove_iterator(), SetInfo::received, SetInfo::sent, statistics, statistics_done(), statistics_file, statistics_filename, and statistics_result().

Referenced by set_result_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ set_result_cb()

static void set_result_cb	(	void *	cls,
		const struct GNUNET_SETI_Element *	element,
		uint64_t	current_size,
		enum GNUNET_SETI_Status	status
	)

static

Definition at line 165 of file gnunet-seti-profiler.c.

 {
   struct SetInfo *info = cls;
   struct GNUNET_HashCode hash;
  
   GNUNET_assert (GNUNET_NO == info->done);
   switch (status)
   {
   case GNUNET_SETI_STATUS_DONE:
     info->done = GNUNET_YES;
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "set intersection done\n");
     check_all_done ();
     info->oh = NULL;
     return;
   case GNUNET_SETI_STATUS_FAILURE:
     info->oh = NULL;
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "failure\n");
     GNUNET_SCHEDULER_shutdown ();
     return;
   case GNUNET_SETI_STATUS_ADD_LOCAL:
     GNUNET_CRYPTO_hash (element->data,
                         element->size,
                         &hash);
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "set %s: keep element %s\n",
                 info->id,
                 GNUNET_h2s (&hash));
     break;
   case GNUNET_SETI_STATUS_DEL_LOCAL:
     GNUNET_CRYPTO_hash (element->data,
                         element->size,
                         &hash);
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "set %s: remove element %s\n",
                 info->id,
                 GNUNET_h2s (&hash));
     return;
   default:
     GNUNET_assert (0);
   }
  
   if (element->size != element_size)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "wrong element size: %u, expected %u\n",
                 element->size,
                 (unsigned int) sizeof(struct GNUNET_HashCode));
     GNUNET_assert (0);
   }
  
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "set %s: got element (%s)\n",
               info->id, GNUNET_h2s (element->data));
   GNUNET_assert (NULL != element->data);
   {
     struct GNUNET_HashCode data_hash;
  
     GNUNET_CRYPTO_hash (element->data,
                         element_size,
                         &data_hash);
     GNUNET_CONTAINER_multihashmap_put (info->received,
                                        &data_hash,
                                        NULL,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE);
   }
 }

References check_all_done(), GNUNET_SETI_Element::data, element_size, GNUNET_assert, GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE, GNUNET_CRYPTO_hash(), GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_h2s(), GNUNET_log, GNUNET_NO, GNUNET_SCHEDULER_shutdown(), GNUNET_SETI_STATUS_ADD_LOCAL, GNUNET_SETI_STATUS_DEL_LOCAL, GNUNET_SETI_STATUS_DONE, GNUNET_SETI_STATUS_FAILURE, GNUNET_YES, info, GNUNET_SETI_Element::size, and status.

Referenced by run(), and set_listen_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ set_listen_cb()

static void set_listen_cb	(	void *	cls,
		const struct GNUNET_PeerIdentity *	other_peer,
		const struct GNUNET_MessageHeader *	context_msg,
		struct GNUNET_SETI_Request *	request
	)

static

Definition at line 239 of file gnunet-seti-profiler.c.

 {
   /* max. 1 option plus terminator */
   struct GNUNET_SETI_Option opts[2] = { { 0 } };
   unsigned int n_opts = 0;
  
   if (NULL == request)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "listener failed\n");
     return;
   }
   GNUNET_assert (NULL == info2.oh);
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "set listen cb called\n");
   if (use_intersection)
   {
     opts[n_opts++] = (struct GNUNET_SETI_Option) { .type =
                                                      GNUNET_SETI_OPTION_RETURN_INTERSECTION };
   }
   opts[n_opts].type = GNUNET_SETI_OPTION_END;
   info2.oh = GNUNET_SETI_accept (request,
                                  opts,
                                  &set_result_cb,
                                  &info2);
   GNUNET_SETI_commit (info2.oh,
                       info2.set);
 }

References GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_SETI_accept(), GNUNET_SETI_commit(), GNUNET_SETI_OPTION_END, GNUNET_SETI_OPTION_RETURN_INTERSECTION, info2, SetInfo::oh, gnunet-chk::opts, request, SetInfo::set, set_result_cb(), and use_intersection.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ set_insert_iterator()

static int set_insert_iterator	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Definition at line 273 of file gnunet-seti-profiler.c.

 {
   struct GNUNET_SETI_Handle *set = cls;
   struct GNUNET_SETI_Element el;
  
   el.element_type = 0;
   el.data = value;
   el.size = element_size;
   GNUNET_SETI_add_element (set, &el, NULL, NULL);
   return GNUNET_YES;
 }

References el, element_size, GNUNET_SETI_add_element(), GNUNET_YES, and value.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ handle_shutdown()

static void handle_shutdown ( void * cls )

static

Definition at line 289 of file gnunet-seti-profiler.c.

 {
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "Shutting down set profiler\n");
   if (NULL != set_listener)
   {
     GNUNET_SETI_listen_cancel (set_listener);
     set_listener = NULL;
   }
   if (NULL != info1.oh)
   {
     GNUNET_SETI_operation_cancel (info1.oh);
     info1.oh = NULL;
   }
   if (NULL != info2.oh)
   {
     GNUNET_SETI_operation_cancel (info2.oh);
     info2.oh = NULL;
   }
   if (NULL != info1.set)
   {
     GNUNET_SETI_destroy (info1.set);
     info1.set = NULL;
   }
   if (NULL != info2.set)
   {
     GNUNET_SETI_destroy (info2.set);
     info2.set = NULL;
   }
   GNUNET_STATISTICS_destroy (statistics, GNUNET_NO);
 }

References GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_NO, GNUNET_SETI_destroy(), GNUNET_SETI_listen_cancel(), GNUNET_SETI_operation_cancel(), GNUNET_STATISTICS_destroy(), info1, info2, SetInfo::oh, SetInfo::set, set_listener, and statistics.

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_CONFIGURATION_Handle *	cfg,
		struct GNUNET_TESTING_Peer *	peer
	)

static

Definition at line 323 of file gnunet-seti-profiler.c.

 {
   unsigned int i;
   struct GNUNET_HashCode hash;
   /* max. 1 option plus terminator */
   struct GNUNET_SETI_Option opts[2] = { { 0 } };
   unsigned int n_opts = 0;
  
   config = cfg;
  
   GNUNET_assert (element_size > 0);
  
   if (GNUNET_OK != GNUNET_CRYPTO_get_peer_identity (cfg, &local_peer))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "could not retrieve host identity\n");
     ret = 0;
     return;
   }
   statistics = GNUNET_STATISTICS_create ("set-profiler", cfg);
   GNUNET_SCHEDULER_add_shutdown (&handle_shutdown, NULL);
   info1.id = "a";
   info2.id = "b";
   info1.sent = GNUNET_CONTAINER_multihashmap_create (num_a + 1, GNUNET_NO);
   info2.sent = GNUNET_CONTAINER_multihashmap_create (num_b + 1, GNUNET_NO);
   common_sent = GNUNET_CONTAINER_multihashmap_create (num_c + 1, GNUNET_NO);
   info1.received = GNUNET_CONTAINER_multihashmap_create (num_a + 1, GNUNET_NO);
   info2.received = GNUNET_CONTAINER_multihashmap_create (num_b + 1, GNUNET_NO);
   for (i = 0; i < num_a; i++)
   {
     char *data = GNUNET_malloc (element_size);
     GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, data, element_size);
     GNUNET_CRYPTO_hash (data, element_size, &hash);
     GNUNET_CONTAINER_multihashmap_put (info1.sent, &hash, data,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE);
   }
  
   for (i = 0; i < num_b; i++)
   {
     char *data = GNUNET_malloc (element_size);
     GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, data, element_size);
     GNUNET_CRYPTO_hash (data, element_size, &hash);
     GNUNET_CONTAINER_multihashmap_put (info2.sent, &hash, data,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE);
   }
  
   for (i = 0; i < num_c; i++)
   {
     char *data = GNUNET_malloc (element_size);
     GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, data, element_size);
     GNUNET_CRYPTO_hash (data, element_size, &hash);
     GNUNET_CONTAINER_multihashmap_put (common_sent, &hash, data,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE);
   }
  
   GNUNET_CRYPTO_hash_create_random (GNUNET_CRYPTO_QUALITY_STRONG, &app_id);
  
   info1.set = GNUNET_SETI_create (config);
   info2.set = GNUNET_SETI_create (config);
   GNUNET_CONTAINER_multihashmap_iterate (info1.sent,
                                          &set_insert_iterator,
                                          info1.set);
   GNUNET_CONTAINER_multihashmap_iterate (info2.sent,
                                          &set_insert_iterator,
                                          info2.set);
   GNUNET_CONTAINER_multihashmap_iterate (common_sent,
                                          &set_insert_iterator,
                                          info1.set);
   GNUNET_CONTAINER_multihashmap_iterate (common_sent,
                                          &set_insert_iterator,
                                          info2.set);
  
   set_listener = GNUNET_SETI_listen (config,
                                      &app_id,
                                      &set_listen_cb,
                                      NULL);
   if (use_intersection)
   {
     opts[n_opts++] = (struct GNUNET_SETI_Option) { .type =
                                                      GNUNET_SETI_OPTION_RETURN_INTERSECTION };
   }
   opts[n_opts].type = GNUNET_SETI_OPTION_END;
  
   info1.oh = GNUNET_SETI_prepare (&local_peer,
                                   &app_id,
                                   NULL,
                                   opts,
                                   set_result_cb,
                                   &info1);
   GNUNET_SETI_commit (info1.oh,
                       info1.set);
   GNUNET_SETI_destroy (info1.set);
   info1.set = NULL;
 }

References app_id, cfg, common_sent, config, data, element_size, GNUNET_assert, GNUNET_CONTAINER_multihashmap_create(), GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE, GNUNET_CRYPTO_get_peer_identity(), GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_hash_create_random(), GNUNET_CRYPTO_QUALITY_STRONG, GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_block(), GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_malloc, GNUNET_NO, GNUNET_OK, GNUNET_SCHEDULER_add_shutdown(), GNUNET_SETI_commit(), GNUNET_SETI_create(), GNUNET_SETI_destroy(), GNUNET_SETI_listen(), GNUNET_SETI_OPTION_END, GNUNET_SETI_OPTION_RETURN_INTERSECTION, GNUNET_SETI_prepare(), GNUNET_STATISTICS_create(), handle_shutdown(), SetInfo::id, info1, info2, local_peer, num_a, num_b, num_c, SetInfo::oh, gnunet-chk::opts, SetInfo::received, ret, SetInfo::sent, SetInfo::set, set_insert_iterator(), set_listen_cb(), set_listener, set_result_cb(), statistics, and use_intersection.

Referenced by pre_run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ pre_run()

static void pre_run	(	void *	cls,
		char const	args,
		const char *	cfgfile,
		const struct GNUNET_CONFIGURATION_Handle *	cfg
	)

static

Definition at line 422 of file gnunet-seti-profiler.c.

 {
   if (0 != GNUNET_TESTING_peer_run ("set-profiler",
                                     cfgfile,
                                     &run, NULL))
     ret = 2;
 }

References GNUNET_TESTING_peer_run(), ret, and run().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 435 of file gnunet-seti-profiler.c.

 {
   struct GNUNET_GETOPT_CommandLineOption options[] = {
     GNUNET_GETOPT_option_uint ('A',
                                "num-first",
                                NULL,
                                gettext_noop ("number of values"),
                                &num_a),
     GNUNET_GETOPT_option_uint ('B',
                                "num-second",
                                NULL,
                                gettext_noop ("number of values"),
                                &num_b),
     GNUNET_GETOPT_option_uint ('C',
                                "num-common",
                                NULL,
                                gettext_noop ("number of values"),
                                &num_c),
     GNUNET_GETOPT_option_uint ('i',
                                "use-intersection",
                                NULL,
                                gettext_noop (
                                  "return intersection instead of delta"),
                                &use_intersection),
     GNUNET_GETOPT_option_uint ('w',
                                "element-size",
                                NULL,
                                gettext_noop ("element size"),
                                &element_size),
     GNUNET_GETOPT_option_filename ('s',
                                    "statistics",
                                    "FILENAME",
                                    gettext_noop ("write statistics to file"),
                                    &statistics_filename),
     GNUNET_GETOPT_OPTION_END
   };
  
   GNUNET_PROGRAM_run2 (argc, argv,
                        "gnunet-seti-profiler",
                        "help",
                        options,
                        &pre_run,
                        NULL,
                        GNUNET_YES);
   return ret;
 }

References element_size, gettext_noop, GNUNET_GETOPT_OPTION_END, GNUNET_GETOPT_option_filename(), GNUNET_GETOPT_option_uint(), GNUNET_PROGRAM_run2(), GNUNET_YES, num_a, num_b, num_c, options, pre_run(), ret, statistics_filename, and use_intersection.

Here is the call graph for this function:

Variable Documentation

◆ ret

int ret

static

Definition at line 33 of file gnunet-seti-profiler.c.

Referenced by main(), map_remove_iterator(), pre_run(), and run().

◆ num_a

unsigned int num_a = 5

static

Definition at line 35 of file gnunet-seti-profiler.c.

Referenced by main(), and run().

◆ num_b

unsigned int num_b = 5

static

Definition at line 36 of file gnunet-seti-profiler.c.

Referenced by main(), and run().

◆ num_c

unsigned int num_c = 20

static

Definition at line 37 of file gnunet-seti-profiler.c.

Referenced by main(), and run().

◆ config

const struct GNUNET_CONFIGURATION_Handle* config

static

Definition at line 39 of file gnunet-seti-profiler.c.

Referenced by run().

◆ info1

struct SetInfo info1

Referenced by check_all_done(), handle_shutdown(), and run().

◆ info2

struct SetInfo info2

Referenced by check_all_done(), handle_shutdown(), run(), and set_listen_cb().

◆ common_sent

struct GNUNET_CONTAINER_MultiHashMap* common_sent

static

Definition at line 51 of file gnunet-seti-profiler.c.

Referenced by run().

◆ app_id

struct GNUNET_HashCode app_id

static

Definition at line 51 of file gnunet-seti-profiler.c.

Referenced by run().

◆ local_peer

struct GNUNET_PeerIdentity local_peer

static

Definition at line 51 of file gnunet-seti-profiler.c.

Referenced by run().

◆ set_listener

struct GNUNET_SETI_ListenHandle* set_listener

static

Definition at line 57 of file gnunet-seti-profiler.c.

Referenced by handle_shutdown(), and run().

◆ use_intersection

unsigned int use_intersection

static

Definition at line 59 of file gnunet-seti-profiler.c.

Referenced by main(), run(), and set_listen_cb().

◆ element_size

unsigned int element_size = 32

static

Definition at line 61 of file gnunet-seti-profiler.c.

Referenced by main(), run(), set_insert_iterator(), and set_result_cb().

◆ statistics

struct GNUNET_STATISTICS_Handle* statistics

static

Handle to the statistics service.

Definition at line 66 of file gnunet-seti-profiler.c.

Referenced by check_all_done(), handle_shutdown(), and run().

◆ statistics_filename

char* statistics_filename

static

The profiler will write statistics for all peers to the file with this name.

Definition at line 72 of file gnunet-seti-profiler.c.

Referenced by check_all_done(), and main().

◆ statistics_file

FILE* statistics_file

static

The profiler will write statistics for all peers to this file.

Definition at line 78 of file gnunet-seti-profiler.c.

Referenced by check_all_done(), statistics_done(), and statistics_result().

Data Structures

Functions

Variables

Function Documentation

◆ map_remove_iterator()

◆ statistics_result()

◆ statistics_done()

◆ check_all_done()

◆ set_result_cb()

◆ set_listen_cb()

◆ set_insert_iterator()

◆ handle_shutdown()

◆ run()

◆ pre_run()

◆ main()

Variable Documentation

◆ ret

◆ num_a

◆ num_b

◆ num_c

◆ config

◆ info1

◆ info2

◆ common_sent

◆ app_id

◆ local_peer

◆ set_listener

◆ use_intersection

◆ element_size

◆ statistics

◆ statistics_filename

◆ statistics_file