arg
[oweals/gnunet.git] / src / fs / gnunet-service-fs.c
index 20a98e6f24721285a357c1ac51882c5d6b1e2264..d95aec6bf04f8f8d7329844e08be48b0afda1181 100644 (file)
@@ -128,6 +128,10 @@ struct GNUNET_BLOCK_Context *GSF_block_ctx;
  */
 struct GNUNET_CORE_Handle *GSF_core;
 
+/**
+ * Are we introducing randomized delays for better anonymity?
+ */
+int GSF_enable_randomized_delays;
 
 /* ***************************** locals ******************************* */
 
@@ -235,6 +239,7 @@ handle_p2p_put (void *cls,
       GNUNET_break (0);
       return GNUNET_OK;
     }
+  GSF_cover_content_count++;
   return GSF_handle_p2p_content_ (cp, message);
 }
 
@@ -330,7 +335,7 @@ start_p2p_processing (void *cls,
   struct GSF_PendingRequestData *prd;
 
   prd = GSF_pending_request_get_data_ (pr);
-#if DEBUG_FS
+#if DEBUG_FS_CLIENT
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Finished database lookup for local request `%s' with result %d\n",
              GNUNET_h2s (&prd->query),
@@ -405,6 +410,7 @@ shutdown_task (void *cls,
   GNUNET_CONFIGURATION_destroy (block_cfg);
   block_cfg = NULL;
   GNUNET_STATISTICS_destroy (GSF_stats, GNUNET_NO);
+  GSF_stats = NULL;
   if (GNUNET_SCHEDULER_NO_TASK != cover_age_task)
     {
       GNUNET_SCHEDULER_cancel (cover_age_task);
@@ -567,6 +573,7 @@ run (void *cls,
      const struct GNUNET_CONFIGURATION_Handle *cfg)
 {
   GSF_cfg = cfg;
+  GSF_enable_randomized_delays = GNUNET_CONFIGURATION_get_value_yesno (cfg, "fs", "DELAY");
   GSF_dsh = GNUNET_DATASTORE_connect (cfg);
   if (NULL == GSF_dsh)
     {