diff options
| author | Jesper Jensen <jesper@slashwin.dk> | 2021-10-16 23:43:07 +0200 |
|---|---|---|
| committer | Jesper Jensen <jesper@slashwin.dk> | 2021-10-16 23:47:16 +0200 |
| commit | 38f176ca9c1f21fc11b3ccc6aa45bd2f47e2eab7 (patch) | |
| tree | b35962de0142a9635b0409a1228eee529bf470fe /src | |
| parent | ef39868b6bffa3030c7cbc083df1301849fba0f7 (diff) | |
Flush in main
Diffstat (limited to 'src')
| -rw-r--r-- | src/main.c | 3 | ||||
| -rw-r--r-- | src/proto.c | 8 |
2 files changed, 5 insertions, 6 deletions
@@ -21,11 +21,12 @@ int main(int argc, char** argv) { struct dht dht; dht.self = (struct nodeid){.inner={0xebe9bbf1, 0x3cdba6b3, 0x993e0c87, 0x900d5e25}}; + routing_init(&dht.self); + struct message* message_cursor = outbuff; proto_begin(&dht, time(NULL), &message_cursor, outbuff+32); flush_messages(dht.sfd, outbuff, message_cursor); - char buff_storage[2049]; int rc = 0; while(rc == 0) { diff --git a/src/proto.c b/src/proto.c index 8f4f737..196b912 100644 --- a/src/proto.c +++ b/src/proto.c @@ -180,7 +180,7 @@ PROCESS_TIMEOUT(getclient_timeout) { size_t reqId = (typeof(dht->requestdata[0])*)((void*)cont - offsetof(typeof(dht->requestdata[0]), cont)) - dht->requestdata; if(cont->ping.attempt >= 2) { - dbg("Timing out request %d after %d attempts", reqId, cont->ping.attempt); + dbg("Timing out request %ld after %d attempts", reqId, cont->ping.attempt); if(cont->ping.is_new) return 0; @@ -190,7 +190,7 @@ PROCESS_TIMEOUT(getclient_timeout) { return 0; } - dbg("Retrying request %d", reqId); + dbg("Retrying request %ld", reqId); if(*msgbuff->messages >= msgbuff->messages_end) return PROTO_ENOREQ; @@ -356,7 +356,6 @@ enum commandType { }; void proto_begin(struct dht* dht, time_t now, struct message** output, const struct message* const output_end) { - routing_flush(); struct msgbuff msgbuff = { output, output_end, @@ -367,7 +366,6 @@ void proto_begin(struct dht* dht, time_t now, struct message** output, const str dht->reqalloc[i] = false; } - routing_init(&dht->self); dbgl_id(&dht->self); dht->sfd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); @@ -646,7 +644,7 @@ int proto_run(struct dht* dht, char* buff, size_t recv_len, struct sockaddr_in* } } - dbg("%d/%d requests pending", allocated, MAX_INFLIGHT); + dbg("%ld/%ld requests pending", allocated, MAX_INFLIGHT); } { int filled; |
