diff options
| author | Jesper Jensen <jesper@jnsn.dev> | 2025-04-15 13:05:19 +0200 |
|---|---|---|
| committer | Jesper Jensen <jesper@jnsn.dev> | 2025-04-15 13:05:19 +0200 |
| commit | 6386a3eb9628315e23e16637ea5d29e72b053f0f (patch) | |
| tree | 00c6a62072037c2f7be74d379e6f6ef341d9d590 | |
| parent | a2f18ae0234bc6dbccaebd21bc7ea07ceac2ee7a (diff) | |
Expose the number of keepalive pings we send
| -rw-r--r-- | src/metrics.c | 10 | ||||
| -rw-r--r-- | src/metrics.h | 2 | ||||
| -rw-r--r-- | src/proto.c | 1 |
3 files changed, 12 insertions, 1 deletions
diff --git a/src/metrics.c b/src/metrics.c index 7bac410..115b782 100644 --- a/src/metrics.c +++ b/src/metrics.c @@ -17,6 +17,7 @@ prom_histogram_t *offered = NULL; prom_gauge_t *activeNodes = NULL; prom_gauge_t *requestsInFlight = NULL; prom_counter_t *retries = NULL; +prom_counter_t *keepalive_count = NULL; enum MHD_Result promhttp_handler( void *cls, @@ -192,6 +193,15 @@ void metric_init() { NULL ) ); + + keepalive_count = prom_collector_registry_must_register_metric( + prom_counter_new( + "dht_keepalive_count", + "Number of times a node has been pinged due to inactivity", + 0, + NULL + ) + ); } void metric_end() { diff --git a/src/metrics.h b/src/metrics.h index 3155ccb..f129ce7 100644 --- a/src/metrics.h +++ b/src/metrics.h @@ -19,7 +19,7 @@ extern prom_histogram_t *offered; extern prom_gauge_t *activeNodes; extern prom_gauge_t *requestsInFlight; extern prom_counter_t *retries; - +extern prom_counter_t *keepalive_count; extern prom_counter_t *requestsProcessed; diff --git a/src/proto.c b/src/proto.c index d4f8b59..c1cc392 100644 --- a/src/proto.c +++ b/src/proto.c @@ -693,6 +693,7 @@ int proto_run(struct dht* dht, char* buff, size_t recv_len, struct sockaddr_in* fatal("NOPE %d", rc); } + prom_counter_inc(keepalive_count, NULL); oldest->expire = 0; routing_oldest(&oldest); } |