diff options
author | Christian Grothoff <christian@grothoff.org> | 2012-10-19 10:02:18 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2012-10-19 10:02:18 +0000 |
commit | 44bab2e9f9f2d9117ed0c3bd542804472c2d70b8 (patch) | |
tree | 18def3a6598d00819f7d4c1e911ed2a6cd51b4bd /src/fs/gnunet-service-fs_pe.c | |
parent | 7e82f8cf8a75bb2310aef008118a968c9a5b774f (diff) | |
download | gnunet-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.c | 12 |
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, |