summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorJesper Jensen <jesper@slashwin.dk>2021-10-16 23:43:07 +0200
committerJesper Jensen <jesper@slashwin.dk>2021-10-16 23:47:16 +0200
commit38f176ca9c1f21fc11b3ccc6aa45bd2f47e2eab7 (patch)
treeb35962de0142a9635b0409a1228eee529bf470fe /src
parentef39868b6bffa3030c7cbc083df1301849fba0f7 (diff)
Flush in main
Diffstat (limited to 'src')
-rw-r--r--src/main.c3
-rw-r--r--src/proto.c8
2 files changed, 5 insertions, 6 deletions
diff --git a/src/main.c b/src/main.c
index 3cffa29..20cd376 100644
--- a/src/main.c
+++ b/src/main.c
@@ -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;