[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r35871 - gnunet/src/rps
From: |
gnunet |
Subject: |
[GNUnet-SVN] r35871 - gnunet/src/rps |
Date: |
Sat, 6 Jun 2015 01:03:08 +0200 |
Author: ch3
Date: 2015-06-06 01:03:08 +0200 (Sat, 06 Jun 2015)
New Revision: 35871
Modified:
gnunet/src/rps/gnunet-service-rps.c
Log:
-writing the gossip list (view) to file
Modified: gnunet/src/rps/gnunet-service-rps.c
===================================================================
--- gnunet/src/rps/gnunet-service-rps.c 2015-06-05 23:03:06 UTC (rev 35870)
+++ gnunet/src/rps/gnunet-service-rps.c 2015-06-05 23:03:08 UTC (rev 35871)
@@ -28,6 +28,7 @@
#include "gnunet_cadet_service.h"
#include "gnunet_nse_service.h"
#include "rps.h"
+#include "rps-test_util.h"
#include "gnunet-service-rps_sampler.h"
@@ -218,7 +219,12 @@
//static unsigned int gossip_list_size;
static uint32_t gossip_list_size;
+/**
+ * Name to log view (gossip_list) to
+ */
+static char *file_name_view_log;
+
/**
* The size of sampler we need to be able to satisfy the client's need of
* random peers.
@@ -673,7 +679,12 @@
GNUNET_assert (1 == num_peers);
if (gossip_list_size < sampler_size_est_need)
+ {
GNUNET_array_append (gossip_list, gossip_list_size, *ids);
+ to_file (file_name_view_log,
+ "+%s\t(hist)",
+ GNUNET_i2s_full (ids));
+ }
if (0 < num_hist_update_tasks)
num_hist_update_tasks--;
@@ -913,7 +924,12 @@
insert_in_gossip_list (void *cls, const struct GNUNET_PeerIdentity *peer)
{
if (GNUNET_NO == in_arr (gossip_list, gossip_list_size, peer))
+ {
GNUNET_array_append (gossip_list, gossip_list_size, *peer);
+ to_file (file_name_view_log,
+ "+%s\t(ins in gossip list)",
+ GNUNET_i2s_full (peer));
+ }
(void) get_channel (peer_map, peer);
}
@@ -1968,8 +1984,13 @@
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Printing gossip list:\n");
for (i = 0 ; i < gossip_list_size ; i++)
+ {
LOG (GNUNET_ERROR_TYPE_DEBUG,
"\t%s\n", GNUNET_i2s (&gossip_list[i]));
+ to_file (file_name_view_log,
+ "=%s\t(do round)",
+ GNUNET_i2s_full (&gossip_list[i]));
+ }
// TODO log lists, ...
/* Would it make sense to have one shuffeled gossip list and then
@@ -2022,6 +2043,7 @@
/* Update gossip list */
+ /* TODO see how many peers are in push-/pull- list! */
if (push_list_size <= alpha * gossip_list_size
&& push_list_size > 0
@@ -2047,11 +2069,17 @@
GNUNET_array_grow (gossip_list, gossip_list_size, second_border);
+ to_file (file_name_view_log,
+ "--- emptied ---");
+
for (i = 0 ; i < first_border ; i++)
{/* Update gossip list with peers received through PUSHes */
r_index = GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_STRONG,
push_list_size);
gossip_list[i] = push_list[r_index];
+ to_file (file_name_view_log,
+ "+%s't(push list)",
+ GNUNET_i2s_full (&gossip_list[i]));
// TODO change the peer_flags accordingly
}
@@ -2060,6 +2088,9 @@
r_index = GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_STRONG,
pull_list_size);
gossip_list[i] = pull_list[r_index];
+ to_file (file_name_view_log,
+ "+%s\t(pull list)",
+ GNUNET_i2s_full (&gossip_list[i]));
// TODO change the peer_flags accordingly
}
@@ -2077,7 +2108,12 @@
rem_from_list (&peers_to_clean, &peers_to_clean_size, &gossip_list[i]);
for (i = 0 ; i < peers_to_clean_size ; i++)
+ {
peer_clean (&peers_to_clean[i]);
+ /* to_file (file_name_view_log,
+ "-%s",
+ GNUNET_i2s_full (&peers_to_clean[i])); */
+ }
GNUNET_free (peers_to_clean);
}
@@ -2470,6 +2506,9 @@
struct GNUNET_SERVER_Handle *server,
const struct GNUNET_CONFIGURATION_Handle *c)
{
+ int size;
+ int out_size;
+
// TODO check what this does -- copied from gnunet-boss
// - seems to work as expected
GNUNET_log_setup ("rps", GNUNET_error_type_to_string
(GNUNET_ERROR_TYPE_DEBUG), NULL);
@@ -2511,8 +2550,27 @@
gossip_list = NULL;
+ gossip_list_size = 0;
+ /* file_name_view_log */
+ GNUNET_DISK_directory_create ("/tmp/rps/");
+ size = (14 + strlen (GNUNET_i2s_full (&own_identity)) + 1) * sizeof (char);
+ file_name_view_log = GNUNET_malloc (size);
+ out_size = GNUNET_snprintf (file_name_view_log,
+ size,
+ "/tmp/rps/view-%s",
+ GNUNET_i2s_full (&own_identity));
+ if (size < out_size ||
+ 0 > out_size)
+ {
+ LOG (GNUNET_ERROR_TYPE_WARNING,
+ "Failed to write string to buffer (size: %i, out_size: %i)\n",
+ size,
+ out_size);
+ }
+
+
/* connect to NSE */
nse = GNUNET_NSE_connect (cfg, nse_callback, NULL);
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r35871 - gnunet/src/rps,
gnunet <=