From b5127f1c7624f40437159f164ac8eabc50b65f74 Mon Sep 17 00:00:00 2001 From: Jesper Jensen Date: Sun, 19 Sep 2021 11:46:27 +0200 Subject: Add general tests --- src/proto.h | 44 ++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 44 insertions(+) create mode 100644 src/proto.h (limited to 'src/proto.h') diff --git a/src/proto.h b/src/proto.h new file mode 100644 index 0000000..85dd310 --- /dev/null +++ b/src/proto.h @@ -0,0 +1,44 @@ +#pragma once + +#include "routing.h" +#include +#include + +// 192.0.2.0 +#define UNDEF_ADDR (struct in_addr){0xC0000200} +#define MAX_DISC 32 +#define MAX_INFLIGHT 32 + +struct dht; +struct msgbuff; +typedef void (*cont)(struct dht* dht, struct nodeid* self, char* packet, size_t packet_len, int socket, struct sockaddr* remote, socklen_t remote_len, struct msgbuff* msgbuff); + +struct discovery { + uint16_t port; + struct nodeid expected_id; +}; + +struct dht { + struct nodeid self; + int sfd; + + struct in_addr addrs[MAX_DISC]; + struct discovery pending_discover[MAX_DISC]; + + bool reqalloc[MAX_INFLIGHT]; + struct { + struct sockaddr_storage addr; + cont fun; + } requestdata[MAX_INFLIGHT]; +}; + +struct message { + char payload[128]; + size_t payload_len; + struct sockaddr_storage dest; + socklen_t dest_len; +}; + +void proto_begin(struct dht* dht, struct message** output, const struct message* const output_end); +int proto_run(struct dht* dht, char* buffer, size_t buffer_len, struct sockaddr_in* remote, socklen_t remote_len, struct message** output, const struct message* const output_end); +void proto_end(struct dht* dht); -- cgit v1.2.3