diff options
author | Christian Grothoff <christian@grothoff.org> | 2019-01-10 16:30:45 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2019-01-10 16:30:45 +0100 |
commit | 87a05357dba158dd0ada1e37d5a53d390b2ce122 (patch) | |
tree | 554a87ef52d8ee44427ca95aaa26eea54088be49 /src/namecache | |
parent | 8ab07345e1227c815db1de6404b29e616bbf065b (diff) | |
download | gnunet-87a05357dba158dd0ada1e37d5a53d390b2ce122.tar.gz gnunet-87a05357dba158dd0ada1e37d5a53d390b2ce122.zip |
add stats to namecache
Diffstat (limited to 'src/namecache')
-rw-r--r-- | src/namecache/gnunet-service-namecache.c | 27 |
1 files changed, 26 insertions, 1 deletions
diff --git a/src/namecache/gnunet-service-namecache.c b/src/namecache/gnunet-service-namecache.c index c852aaacc..3b5119a8f 100644 --- a/src/namecache/gnunet-service-namecache.c +++ b/src/namecache/gnunet-service-namecache.c | |||
@@ -25,6 +25,7 @@ | |||
25 | #include "platform.h" | 25 | #include "platform.h" |
26 | #include "gnunet_util_lib.h" | 26 | #include "gnunet_util_lib.h" |
27 | #include "gnunet_dnsparser_lib.h" | 27 | #include "gnunet_dnsparser_lib.h" |
28 | #include "gnunet_statistics_service.h" | ||
28 | #include "gnunet_namecache_service.h" | 29 | #include "gnunet_namecache_service.h" |
29 | #include "gnunet_namecache_plugin.h" | 30 | #include "gnunet_namecache_plugin.h" |
30 | #include "gnunet_signatures.h" | 31 | #include "gnunet_signatures.h" |
@@ -58,6 +59,11 @@ struct NamecacheClient | |||
58 | static const struct GNUNET_CONFIGURATION_Handle *GSN_cfg; | 59 | static const struct GNUNET_CONFIGURATION_Handle *GSN_cfg; |
59 | 60 | ||
60 | /** | 61 | /** |
62 | * Handle to the statistics service | ||
63 | */ | ||
64 | static struct GNUNET_STATISTICS_Handle *statistics; | ||
65 | |||
66 | /** | ||
61 | * Database handle | 67 | * Database handle |
62 | */ | 68 | */ |
63 | static struct GNUNET_NAMECACHE_PluginFunctions *GSN_database; | 69 | static struct GNUNET_NAMECACHE_PluginFunctions *GSN_database; |
@@ -83,6 +89,12 @@ cleanup_task (void *cls) | |||
83 | GSN_database)); | 89 | GSN_database)); |
84 | GNUNET_free (db_lib_name); | 90 | GNUNET_free (db_lib_name); |
85 | db_lib_name = NULL; | 91 | db_lib_name = NULL; |
92 | if (NULL != statistics) | ||
93 | { | ||
94 | GNUNET_STATISTICS_destroy (statistics, | ||
95 | GNUNET_NO); | ||
96 | statistics = NULL; | ||
97 | } | ||
86 | } | 98 | } |
87 | 99 | ||
88 | 100 | ||
@@ -194,6 +206,10 @@ handle_lookup_block_it (void *cls, | |||
194 | GNUNET_memcpy (&r[1], | 206 | GNUNET_memcpy (&r[1], |
195 | &block[1], | 207 | &block[1], |
196 | esize); | 208 | esize); |
209 | GNUNET_STATISTICS_update (statistics, | ||
210 | "blocks found in cache", | ||
211 | 1, | ||
212 | GNUNET_NO); | ||
197 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 213 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
198 | "Sending NAMECACHE_LOOKUP_BLOCK_RESPONSE message with expiration time %s\n", | 214 | "Sending NAMECACHE_LOOKUP_BLOCK_RESPONSE message with expiration time %s\n", |
199 | GNUNET_STRINGS_absolute_time_to_string (GNUNET_TIME_absolute_ntoh (r->expire))); | 215 | GNUNET_STRINGS_absolute_time_to_string (GNUNET_TIME_absolute_ntoh (r->expire))); |
@@ -220,7 +236,10 @@ handle_lookup_block (void *cls, | |||
220 | 236 | ||
221 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 237 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
222 | "Received NAMECACHE_LOOKUP_BLOCK message\n"); | 238 | "Received NAMECACHE_LOOKUP_BLOCK message\n"); |
223 | 239 | GNUNET_STATISTICS_update (statistics, | |
240 | "blocks looked up", | ||
241 | 1, | ||
242 | GNUNET_NO); | ||
224 | lnc.request_id = ntohl (ln_msg->gns_header.r_id); | 243 | lnc.request_id = ntohl (ln_msg->gns_header.r_id); |
225 | lnc.nc = nc; | 244 | lnc.nc = nc; |
226 | lnc.status = GNUNET_OK; | 245 | lnc.status = GNUNET_OK; |
@@ -284,6 +303,10 @@ handle_block_cache (void *cls, | |||
284 | size_t esize; | 303 | size_t esize; |
285 | int res; | 304 | int res; |
286 | 305 | ||
306 | GNUNET_STATISTICS_update (statistics, | ||
307 | "blocks cached", | ||
308 | 1, | ||
309 | GNUNET_NO); | ||
287 | esize = ntohs (rp_msg->gns_header.header.size) - sizeof (struct BlockCacheMessage); | 310 | esize = ntohs (rp_msg->gns_header.header.size) - sizeof (struct BlockCacheMessage); |
288 | block = GNUNET_malloc (sizeof (struct GNUNET_GNSRECORD_Block) + esize); | 311 | block = GNUNET_malloc (sizeof (struct GNUNET_GNSRECORD_Block) + esize); |
289 | block->signature = rp_msg->signature; | 312 | block->signature = rp_msg->signature; |
@@ -353,6 +376,8 @@ run (void *cls, | |||
353 | NULL); | 376 | NULL); |
354 | return; | 377 | return; |
355 | } | 378 | } |
379 | statistics = GNUNET_STATISTICS_create ("namecache", | ||
380 | cfg); | ||
356 | 381 | ||
357 | /* Configuring server handles */ | 382 | /* Configuring server handles */ |
358 | GNUNET_SCHEDULER_add_shutdown (&cleanup_task, | 383 | GNUNET_SCHEDULER_add_shutdown (&cleanup_task, |