blob: 2e6dde6fc05ba19d4a316a86a24c0ef2c8bc3322 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
#include <stdlib.h>
#include <stdio.h>
#include <stdint.h>
#include <string.h>
#include <time.h>
#ifdef WIN32 //Put win32 includes here
#include <winsock2.h>
#include <windows.h>
#else //Linux includes
#include <fcntl.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#endif
typedef union
{
uint8_t c[4];
uint16_t s[2];
uint32_t i;
}IP;
typedef struct
{
IP ip;
uint16_t port;
}IP_Port;
typedef struct
{
char client_id[32];
IP_Port ip_port;
uint32_t timestamp;
}Client_data;
typedef struct
{
char client_id[32];
Client_data client_list[8];
}Friend;
typedef struct
{
IP_Port ip_port;
uint32_t ping_id;
uint32_t timestamp;
}Pinged;
typedef struct
{
int16_t family;
uint16_t port;
IP ip;
uint8_t zeroes[8];
#ifdef ENABLE_IPV6
uint8_t zeroes2[12];
#endif
}ADDR;
//Add a new friend to the friends list
//client_id must be 32 bytes long.
void addfriend(char * client_id);
//Delete a friend from the friends list
//client_id must be 32 bytes long.
//returns 0 if success
//returns 1 if failure (client_id not in friends list)
char delfriend(char * client_id);
//Get ip of friend
//client_id must be 32 bytes long.
//ip must be 4 bytes long.
//port must be 2 bytes long.
//returns ip if success
//returns ip of 0 if failure (This means the friend is either offline of we have not found him yet.)
IP_Port getfriendip(char * client_id);
//Run this function at least a couple times per second (It's the main loop)
void doDHT();
//if we recieve a DHT packet we call this function so it can be handled.
void DHT_recvpacket(char * packet, uint32_t length, IP_Port source);
//Use this function to bootstrap the client
//Sends a get nodes request to the given ip port
void bootstrap(IP_Port ip_port);
//TODO:
//Add functions to save and load the state(client list, friends list)
//Global variables
//Our client id
char self_client_id[32];
//Our UDP socket.
//We only use one so it's much easier to have it as a global variable
int sock;
#define LCLIENT_LIST 32
Client_data client_list[LCLIENT_LIST];
//Let's start with a static array for testing.
Friend friends_list[256];
uint16_t num_friends;
//The list of ip ports along with the ping_id of what we sent them and a timestamp
//TODO: make this more efficient looping up to 128 times is a bit...
#define LPING_ARRAY 128
Pinged pings[LPING_ARRAY];
#define LSEND_NODES_ARRAY LPING_ARRAY/2
Pinged send_nodes[LSEND_NODES_ARRAY];
|
