[GNUnet-SVN] r18111 - gnunet/src/fs

[gnunet]

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
 }