diff options
| -rw-r--r-- | src/metrics.c | 10 | ||||
| -rw-r--r-- | src/metrics.h | 1 | ||||
| -rw-r--r-- | src/peers.c | 3 |
3 files changed, 14 insertions, 0 deletions
diff --git a/src/metrics.c b/src/metrics.c index fb81b77..d85f6d9 100644 --- a/src/metrics.c +++ b/src/metrics.c @@ -10,6 +10,7 @@ prom_counter_t *meta = NULL; prom_gauge_t *wakeup_time = NULL; prom_counter_t *peers = NULL; +prom_counter_t *peers_fetched = NULL; prom_gauge_t *current_hashes = NULL; prom_counter_t *hashes = NULL; prom_gauge_t *hashes_size = NULL; @@ -128,6 +129,15 @@ void metric_init() { ) ); + peers_fetched = prom_collector_registry_must_register_metric( + prom_counter_new( + "dht_peers_retrieved", + "Number of peers retrieved from the table", + 0, + NULL + ) + ); + current_hashes = prom_collector_registry_must_register_metric( prom_gauge_new( "dht_live_hashes_total", diff --git a/src/metrics.h b/src/metrics.h index 3c79129..a7ac9f2 100644 --- a/src/metrics.h +++ b/src/metrics.h @@ -12,6 +12,7 @@ extern prom_counter_t *meta; extern prom_gauge_t *wakeup_time; extern prom_counter_t *peers; +extern prom_counter_t *peers_fetched; extern prom_gauge_t *current_hashes; extern prom_counter_t *hashes; extern prom_gauge_t *hashes_size; diff --git a/src/peers.c b/src/peers.c index a27176e..4eeba53 100644 --- a/src/peers.c +++ b/src/peers.c @@ -157,8 +157,11 @@ void get_peers(struct infohash* infohash, struct addr **peers, size_t *peers_len return; } + assert(entry->value_len != 0); + *peers = entry->value; *peers_len = entry->value_len; + prom_counter_add(peers_fetched, entry->value_len, NULL); } void expire_hashes(time_t now) { |