[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r32779 - gnunet/src/mesh
From: |
gnunet |
Subject: |
[GNUnet-SVN] r32779 - gnunet/src/mesh |
Date: |
Sat, 22 Mar 2014 23:46:03 +0100 |
Author: bartpolot
Date: 2014-03-22 23:46:02 +0100 (Sat, 22 Mar 2014)
New Revision: 32779
Modified:
gnunet/src/mesh/gnunet-mesh-profiler.c
Log:
- start test if warmup "fails"
Modified: gnunet/src/mesh/gnunet-mesh-profiler.c
===================================================================
--- gnunet/src/mesh/gnunet-mesh-profiler.c 2014-03-22 22:37:13 UTC (rev
32778)
+++ gnunet/src/mesh/gnunet-mesh-profiler.c 2014-03-22 22:46:02 UTC (rev
32779)
@@ -797,8 +797,12 @@
peers_warmup++;
if (peers_warmup < peers_total)
return NULL;
- test_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
- &start_test, NULL);
+ if (GNUNET_SCHEDULER_NO_TASK != test_task)
+ {
+ GNUNET_SCHEDULER_cancel (test_task);
+ test_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
+ &start_test, NULL);
+ }
return NULL;
}
GNUNET_assert (peer == peers[n].incoming);
@@ -869,6 +873,7 @@
enum GNUNET_MESH_ChannelOption flags;
unsigned long i;
+ test_task = GNUNET_SCHEDULER_NO_TASK;
if ((GNUNET_SCHEDULER_REASON_SHUTDOWN & tc->reason) != 0)
return;
@@ -969,7 +974,12 @@
GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Got all IDs, starting profiler\n");
if (do_warmup)
{
+ struct GNUNET_TIME_Relative delay;
+
warmup();
+ delay = GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS,
+ 100 * peers_total);
+ test_task = GNUNET_SCHEDULER_add_delayed (delay, &start_test, NULL);
return; /* start_test from incoming_channel */
}
test_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r32779 - gnunet/src/mesh,
gnunet <=