fix starting stddevs/avgs

diff --git a/src/nse/gnunet-service-nse.c b/src/nse/gnunet-service-nse.c
index cb0216dc6ff9a56b4b4ee1dff0eadcb4da6c46fe..1d5421acb0d37268e1506b06786d10b05e4eee12 100644 (file)
--- a/src/nse/gnunet-service-nse.c
+++ b/src/nse/gnunet-service-nse.c
@@ -72,7 +72,7 @@
 /**
  * Interval for sending network size estimation flood requests.
  */
-#define GNUNET_NSE_INTERVAL GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 60)
+#define GNUNET_NSE_INTERVAL GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 15)
 
 
 /**
@@ -208,6 +208,11 @@ static struct GNUNET_NSE_FloodMessage size_estimate_messages[HISTORY_SIZE];
  */
 static unsigned int estimate_index;
 
+/**
+ * Number of valid entries in the history.
+ */
+static unsigned int estimate_count;
+
 /**
  * Task scheduled to update our flood message for the next round.
  */
@@ -274,10 +279,10 @@ setup_estimate_message (struct GNUNET_NSE_ClientMessage *em)
   mean = 0.0;
   sum = 0.0;
   sumweight = 0.0;
-  for (i=0; i<HISTORY_SIZE; i++)
+  for (i=0;i<estimate_count; i++)
     {
-      val = htonl (size_estimate_messages[i].matching_bits);
-      weight = HISTORY_SIZE - ((estimate_index + HISTORY_SIZE - i) % HISTORY_SIZE);
+      val = htonl (size_estimate_messages[(estimate_index - i + HISTORY_SIZE) % HISTORY_SIZE].matching_bits);
+      weight = estimate_count + 1 - i;
 
       temp = weight + sumweight;
       q = val - mean;
@@ -300,7 +305,7 @@ setup_estimate_message (struct GNUNET_NSE_ClientMessage *em)
   em->size_estimate = mean - 0.5;
   em->std_deviation = std_dev;
   GNUNET_STATISTICS_set (stats, 
-                        "Current network size estimate",
+                        "# nodes in the network (estimate)",
                         (uint64_t) pow (2, mean - 0.5), GNUNET_NO);
 }
 
@@ -625,6 +630,8 @@ update_flood_message(void *cls,
   next_timestamp = GNUNET_TIME_absolute_add (current_timestamp,
                                             GNUNET_NSE_INTERVAL);
   estimate_index = (estimate_index + 1) % HISTORY_SIZE;
+  if (estimate_count < HISTORY_SIZE)
+    estimate_count++;
   setup_flood_message (estimate_index, current_timestamp);
   hop_count_max = 0;
   for (i=0;i<HISTORY_SIZE;i++)
@@ -1051,6 +1058,7 @@ core_init (void *cls, struct GNUNET_CORE_Handle *server,
       setup_flood_message (i, prev_time);
     }
   estimate_index = HISTORY_SIZE - 1;
+  estimate_count = 2;
   flood_task
     = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_absolute_get_remaining (next_timestamp),
                                    &update_flood_message, NULL);
@@ -1124,7 +1132,7 @@ run(void *cls, struct GNUNET_SERVER_Handle *server,
       GNUNET_SCHEDULER_shutdown ();
       return;
     }
-  stats = GNUNET_STATISTICS_create ("NSE", cfg);
+  stats = GNUNET_STATISTICS_create ("nse", cfg);
 }
 
 

diff --git a/src/nse/test_nse.conf b/src/nse/test_nse.conf
index 17574a74821bae98d115b4f702a659fbe1a6e801..abd623687e2b95d7658feec808387bd22c3e3d18 100644 (file)
--- a/src/nse/test_nse.conf
+++ b/src/nse/test_nse.conf
@@ -40,7 +40,7 @@ AUTOSTART = YES
 AUTOSTART = NO
 
 [testing]
-NUM_PEERS = 20
+NUM_PEERS = 1000
 WEAKRANDOM = YES
 TOPOLOGY = NONE
 CONNECT_TOPOLOGY = SMALL_WORLD_RING

diff --git a/src/nse/test_nse_multipeer.c b/src/nse/test_nse_multipeer.c
index bfd7741b1469ae6cf794ce0cfe3b640ece400525..c277fdf7b135167cb7b26f72845aa4af68b55351 100644 (file)
--- a/src/nse/test_nse_multipeer.c
+++ b/src/nse/test_nse_multipeer.c
@@ -49,9 +49,9 @@ struct NSEPeer *peer_head;
 struct NSEPeer *peer_tail;
 
 /**
- * How long until we give up on connecting the peers?
+ * How long do we run the test?
  */
-#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 1500)
+#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 5)
 
 static int ok;