diff options
| author | Jesper Jensen <jesper@jnsn.dev> | 2025-05-11 00:25:12 +0200 |
|---|---|---|
| committer | Jesper Jensen <jesper@jnsn.dev> | 2025-05-11 00:25:39 +0200 |
| commit | abc0b1c73cfc8da2a0a0bca02c8689f73a1588f2 (patch) | |
| tree | 97a2fb373b37ce8bbeb670d1a3d30812fbde7b98 /src/proto.c | |
| parent | e3ff3bb996a0947a1539623902cbc5701beccef3 (diff) | |
Add metric for discarded packets
Diffstat (limited to 'src/proto.c')
| -rw-r--r-- | src/proto.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/proto.c b/src/proto.c index 5d28ceb..314d846 100644 --- a/src/proto.c +++ b/src/proto.c @@ -734,6 +734,7 @@ int handle_packet(struct dht* dht, time_t now, enum commandType type, char* tran dht->pause = false; int rc = dht->requestdata[reqId].fun(dht, now, &dht->requestdata[reqId].cont, packet, packet_len, dht->sfd, (struct sockaddr*)remote, remote_len, msgbuff); if(rc == PROTO_ENOREQ) { + prom_counter_inc(outbox_overflow, NULL); dht->pause = true; } else if(rc == PROTO_EDISC) { return 0; @@ -880,6 +881,7 @@ int proto_run(struct dht* dht, char* buff, size_t recv_len, struct sockaddr_in* int rc = dht->requestdata[i].timeout_fun(dht, &dht->self, now, &dht->requestdata[i].cont, &msgbuff); if(rc == PROTO_ENOREQ) { + prom_counter_inc(outbox_overflow, NULL); dht->pause = true; recalulate_waketime(dht); return 0; @@ -905,6 +907,7 @@ int proto_run(struct dht* dht, char* buff, size_t recv_len, struct sockaddr_in* dest.sin_port = oldest->addr.port; int rc = send_ping(dht, &oldest->id, now, false, (const struct sockaddr*)&dest, sizeof(dest), &msgbuff); if(rc == PROTO_ENOREQ) { + prom_counter_inc(outbox_overflow, NULL); dht->pause = true; recalulate_waketime(dht); return 0; |