[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r18111 - gnunet/src/fs
From: |
gnunet |
Subject: |
[GNUnet-SVN] r18111 - gnunet/src/fs |
Date: |
Fri, 11 Nov 2011 20:56:55 +0100 |
Author: grothoff
Date: 2011-11-11 20:56:55 +0100 (Fri, 11 Nov 2011)
New Revision: 18111
Modified:
gnunet/src/fs/Makefile.am
gnunet/src/fs/gnunet-service-fs_pe.c
Log:
fixing 1787
Modified: gnunet/src/fs/Makefile.am
===================================================================
--- gnunet/src/fs/Makefile.am 2011-11-11 17:15:42 UTC (rev 18110)
+++ gnunet/src/fs/Makefile.am 2011-11-11 19:56:55 UTC (rev 18111)
@@ -138,7 +138,7 @@
$(top_builddir)/src/ats/libgnunetats.la \
$(top_builddir)/src/core/libgnunetcore.la \
$(top_builddir)/src/util/libgnunetutil.la \
- $(GN_LIBINTL)
+ $(GN_LIBINTL) -lm
gnunet_service_fs_DEPENDENCIES = \
libgnunetfs.la
Modified: gnunet/src/fs/gnunet-service-fs_pe.c
===================================================================
--- gnunet/src/fs/gnunet-service-fs_pe.c 2011-11-11 17:15:42 UTC (rev
18110)
+++ gnunet/src/fs/gnunet-service-fs_pe.c 2011-11-11 19:56:55 UTC (rev
18111)
@@ -251,6 +251,12 @@
static void
plan (struct PeerPlan *pp, struct GSF_RequestPlan *rp)
{
+#define N ((double)128.0)
+ /**
+ * Running average delay we currently impose.
+ */
+ static double avg_delay;
+
struct GSF_PendingRequestData *prd;
struct GNUNET_TIME_Relative delay;
@@ -259,7 +265,7 @@
gettext_noop ("# average retransmission delay (ms)"),
total_delay * 1000LL / plan_count, GNUNET_NO);
prd = GSF_pending_request_get_data_ (rp->prl_head->pr);
- // FIXME: calculate 'rp->priority'!
+
if (rp->transmission_counter < 8)
delay =
GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS,
@@ -276,6 +282,33 @@
delay.rel_value =
GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
delay.rel_value + 1);
+ /* Add 0.01 to avg_delay to avoid division-by-zero later */
+ avg_delay = (((avg_delay * (N-1.0)) + delay.rel_value) / N) + 0.01;
+
+ /*
+ For the priority, we need to consider a few basic rules:
+ 1) if we just started requesting (delay is small), we should
+ virtually always have a priority of zero.
+ 2) for requests with average latency, our priority should match
+ the average priority observed on the network
+ 3) even the longest-running requests should not be WAY out of
+ the observed average (thus we bound by a factor of 2)
+ 4) we add +1 to the observed average priority to avoid everyone
+ staying put at zero (2 * 0 = 0...).
+
+ Using the specific calculation below, we get:
+
+ delay = 0 => priority = 0;
+ delay = avg delay => priority = running-average-observed-priority;
+ delay >> avg_delay => priority = 2 * running-average-observed-priority;
+
+ which satisfies all of the rules above.
+
+ Note: M_PI_4 = PI/4 = arctan(1)
+ */
+ rp->priority = round ((GSF_current_priorities + 1.0) * atan (delay.rel_value
/ avg_delay)) / M_PI_4;
+ /* Note: usage of 'round' and 'atan' requires -lm */
+
if (rp->transmission_counter != 0)
delay.rel_value += TTL_DECREMENT;
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -304,6 +337,7 @@
if (GNUNET_SCHEDULER_NO_TASK != pp->task)
GNUNET_SCHEDULER_cancel (pp->task);
pp->task = GNUNET_SCHEDULER_add_now (&schedule_peer_transmission, pp);
+#undef N
}
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r18111 - gnunet/src/fs,
gnunet <=