aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pe.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2012-10-19 10:02:18 +0000
committerChristian Grothoff <christian@grothoff.org>2012-10-19 10:02:18 +0000
commit44bab2e9f9f2d9117ed0c3bd542804472c2d70b8 (patch)
tree18def3a6598d00819f7d4c1e911ed2a6cd51b4bd /src/fs/gnunet-service-fs_pe.c
parent7e82f8cf8a75bb2310aef008118a968c9a5b774f (diff)
downloadgnunet-44bab2e9f9f2d9117ed0c3bd542804472c2d70b8.tar.gz
gnunet-44bab2e9f9f2d9117ed0c3bd542804472c2d70b8.zip
-reduce stats collection by default
Diffstat (limited to 'src/fs/gnunet-service-fs_pe.c')
-rw-r--r--src/fs/gnunet-service-fs_pe.c12
1 files changed, 10 insertions, 2 deletions
diff --git a/src/fs/gnunet-service-fs_pe.c b/src/fs/gnunet-service-fs_pe.c
index 12108d23f..d4080e950 100644
--- a/src/fs/gnunet-service-fs_pe.c
+++ b/src/fs/gnunet-service-fs_pe.c
@@ -29,6 +29,10 @@
29#include "gnunet-service-fs_pe.h" 29#include "gnunet-service-fs_pe.h"
30#include "gnunet-service-fs_pr.h" 30#include "gnunet-service-fs_pr.h"
31 31
32/**
33 * Collect an instane number of statistics? May cause excessive IPC.
34 */
35#define INSANE_STATISTICS GNUNET_NO
32 36
33/** 37/**
34 * List of GSF_PendingRequests this request plan 38 * List of GSF_PendingRequests this request plan
@@ -541,14 +545,18 @@ merge_pr (void *cls, const struct GNUNET_HashCode * query, void *element)
541 GNUNET_CONTAINER_DLL_insert (prd->rpr_head, prd->rpr_tail, rpr); 545 GNUNET_CONTAINER_DLL_insert (prd->rpr_head, prd->rpr_tail, rpr);
542 GNUNET_CONTAINER_DLL_insert (rp->prl_head, rp->prl_tail, prl); 546 GNUNET_CONTAINER_DLL_insert (rp->prl_head, rp->prl_tail, prl);
543 mpr->merged = GNUNET_YES; 547 mpr->merged = GNUNET_YES;
548#if INSANE_STATISTICS
544 GNUNET_STATISTICS_update (GSF_stats, gettext_noop ("# requests merged"), 1, 549 GNUNET_STATISTICS_update (GSF_stats, gettext_noop ("# requests merged"), 1,
545 GNUNET_NO); 550 GNUNET_NO);
551#endif
546 latest = get_latest (rp); 552 latest = get_latest (rp);
547 if (GSF_pending_request_get_data_ (latest)->ttl.abs_value < 553 if (GSF_pending_request_get_data_ (latest)->ttl.abs_value <
548 prd->ttl.abs_value) 554 prd->ttl.abs_value)
549 { 555 {
556#if INSANE_STATISTICS
550 GNUNET_STATISTICS_update (GSF_stats, gettext_noop ("# requests refreshed"), 557 GNUNET_STATISTICS_update (GSF_stats, gettext_noop ("# requests refreshed"),
551 1, GNUNET_NO); 558 1, GNUNET_NO);
559#endif
552 rp->transmission_counter = 0; /* reset */ 560 rp->transmission_counter = 0; /* reset */
553 } 561 }
554 return GNUNET_NO; 562 return GNUNET_NO;
@@ -593,12 +601,12 @@ GSF_plan_add_ (struct GSF_ConnectedPeer *cp, struct GSF_PendingRequest *pr)
593 GNUNET_CONTAINER_multihashmap_get_multiple (pp->plan_map, 601 GNUNET_CONTAINER_multihashmap_get_multiple (pp->plan_map,
594 &GSF_pending_request_get_data_ 602 &GSF_pending_request_get_data_
595 (pr)->query, &merge_pr, &mpc); // 8 MB in 'merge_pr' 603 (pr)->query, &merge_pr, &mpc); // 8 MB in 'merge_pr'
596 if (mpc.merged != GNUNET_NO) 604 if (GNUNET_NO != mpc.merged)
597 return; 605 return;
598 GNUNET_CONTAINER_multihashmap_get_multiple (pp->plan_map, 606 GNUNET_CONTAINER_multihashmap_get_multiple (pp->plan_map,
599 &GSF_pending_request_get_data_ 607 &GSF_pending_request_get_data_
600 (pr)->query, &merge_pr, &mpc); 608 (pr)->query, &merge_pr, &mpc);
601 if (mpc.merged != GNUNET_NO) 609 if (GNUNET_NO != mpc.merged)
602 return; 610 return;
603 plan_count++; 611 plan_count++;
604 GNUNET_STATISTICS_update (GSF_stats, gettext_noop ("# query plan entries"), 1, 612 GNUNET_STATISTICS_update (GSF_stats, gettext_noop ("# query plan entries"), 1,