[GNUnet-SVN] r22485 - gnunet/src/gns

[gnunet]

Author: schanzen
Date: 2012-07-04 20:30:21 +0200 (Wed, 04 Jul 2012)
New Revision: 22485

Modified:
   gnunet/src/gns/gnunet-service-gns.c
Log:
-improve change in record number on zone iteration

Modified: gnunet/src/gns/gnunet-service-gns.c
===================================================================
--- gnunet/src/gns/gnunet-service-gns.c 2012-07-04 18:14:01 UTC (rev 22484)
+++ gnunet/src/gns/gnunet-service-gns.c 2012-07-04 18:30:21 UTC (rev 22485)
@@ -51,6 +51,7 @@
 #define INITIAL_ZONE_ITERATION_INTERVAL GNUNET_TIME_UNIT_MILLISECONDS
 #define MINIMUM_ZONE_ITERATION_INTERVAL GNUNET_TIME_UNIT_SECONDS
 #define DEFAULT_RECORD_PUT_INTERVAL GNUNET_TIME_relative_multiply 
(GNUNET_TIME_UNIT_HOURS, 4)
+#define LATE_ITERATION_SPEEDUP_FACTOR 2
 
 /**
  * Handle to a shorten operation from api
@@ -199,6 +200,9 @@
 /* automatic pkey import for name shortening */
 static int auto_import_pkey;
 
+/* first zone iteration is specia */
+static int first_zone_iteration;
+
 /* lookup timeout */
 static struct GNUNET_TIME_Relative default_lookup_timeout;
 
@@ -336,7 +340,6 @@
   uint32_t rd_payload_length;
   char* nrb_data = NULL;
   size_t namelen;
-  int interval_adjustment = 1;
   struct GNUNET_TIME_Relative next_put_interval;
 
   
@@ -344,6 +347,7 @@
   /* we're done */
   if (NULL == name)
   {
+    first_zone_iteration = GNUNET_NO;
     if (0 == num_public_records)
     {
       /**
@@ -486,13 +490,15 @@
   
   num_public_records++;
   
-  if (num_public_records > last_num_public_records)
+  if ((num_public_records > last_num_public_records)
+      && (first_zone_iteration == GNUNET_NO))
   {
-    interval_adjustment = ceil ((double)num_public_records / 
(double)last_num_public_records);
+    zone_iteration_interval = GNUNET_TIME_relative_divide (record_put_interval,
+                                                           num_public_records);
     GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
                "Last record count was lower than current record count... 
increasing.\n");
     next_put_interval = GNUNET_TIME_relative_divide (zone_iteration_interval,
-                                                     interval_adjustment);
+                                                 
LATE_ITERATION_SPEEDUP_FACTOR);
 
   }
   else
@@ -1394,6 +1400,7 @@
    * for our records
    * We have roughly an hour for all records;
    */
+  first_zone_iteration = GNUNET_YES;
   zone_update_taskid = GNUNET_SCHEDULER_add_now (&update_zone_dht_start, NULL);
 
   GNUNET_SERVER_add_handlers (server, handlers);