diff options
| author | Jesper Jensen <jesper@jnsn.dev> | 2025-05-11 17:04:28 +0200 |
|---|---|---|
| committer | Jesper Jensen <jesper@jnsn.dev> | 2025-05-11 17:04:28 +0200 |
| commit | 3ccb8ad85c8777e417d1212bc19dc14b348fef4d (patch) | |
| tree | deb594eccf0b780aeb4ae52099c49a987701afff /src/proto.c | |
| parent | abc0b1c73cfc8da2a0a0bca02c8689f73a1588f2 (diff) | |
Handle error from lookup
Diffstat (limited to 'src/proto.c')
| -rw-r--r-- | src/proto.c | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/proto.c b/src/proto.c index 314d846..cbf50d1 100644 --- a/src/proto.c +++ b/src/proto.c @@ -936,7 +936,14 @@ int proto_run(struct dht* dht, char* buff, size_t recv_len, struct sockaddr_in* }; int rc = send_lookup(dht, &dht->lookup.target, time(NULL), (struct sockaddr*)&dest, sizeof(struct sockaddr_in), &msgbuff); - assert(rc == 0); + if(rc == PROTO_ENOREQ) { + prom_counter_inc(outbox_overflow, NULL); + dht->pause = true; + recalulate_waketime(dht); + return 0; + } else if(rc != 0) { + fatal("NOPE %d", rc); + } } dht->lookup.timeout = now + 120; |
