diff options
Diffstat (limited to 'toxcore/TCP_server.c')
-rw-r--r-- | toxcore/TCP_server.c | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/toxcore/TCP_server.c b/toxcore/TCP_server.c index 7a7a4fa7..47ad9933 100644 --- a/toxcore/TCP_server.c +++ b/toxcore/TCP_server.c | |||
@@ -40,7 +40,7 @@ struct TCP_Server { | |||
40 | int efd; | 40 | int efd; |
41 | uint64_t last_run_pinged; | 41 | uint64_t last_run_pinged; |
42 | #endif | 42 | #endif |
43 | sock_t *socks_listening; | 43 | Socket *socks_listening; |
44 | unsigned int num_listening_socks; | 44 | unsigned int num_listening_socks; |
45 | 45 | ||
46 | uint8_t public_key[CRYPTO_PUBLIC_KEY_SIZE]; | 46 | uint8_t public_key[CRYPTO_PUBLIC_KEY_SIZE]; |
@@ -78,7 +78,7 @@ size_t tcp_server_listen_count(const TCP_Server *tcp_server) | |||
78 | /* return 1 on success | 78 | /* return 1 on success |
79 | * return 0 on failure | 79 | * return 0 on failure |
80 | */ | 80 | */ |
81 | static int bind_to_port(sock_t sock, int family, uint16_t port) | 81 | static int bind_to_port(Socket sock, int family, uint16_t port) |
82 | { | 82 | { |
83 | struct sockaddr_storage addr = {0}; | 83 | struct sockaddr_storage addr = {0}; |
84 | size_t addrsize; | 84 | size_t addrsize; |
@@ -232,7 +232,7 @@ static int del_accepted(TCP_Server *TCP_server, int index) | |||
232 | /* return the amount of data in the tcp recv buffer. | 232 | /* return the amount of data in the tcp recv buffer. |
233 | * return 0 on failure. | 233 | * return 0 on failure. |
234 | */ | 234 | */ |
235 | unsigned int TCP_socket_data_recv_buffer(sock_t sock) | 235 | unsigned int TCP_socket_data_recv_buffer(Socket sock) |
236 | { | 236 | { |
237 | #if defined(_WIN32) || defined(__WIN32__) || defined (WIN32) | 237 | #if defined(_WIN32) || defined(__WIN32__) || defined (WIN32) |
238 | unsigned long count = 0; | 238 | unsigned long count = 0; |
@@ -252,7 +252,7 @@ unsigned int TCP_socket_data_recv_buffer(sock_t sock) | |||
252 | * return 0 if nothing has been read from socket. | 252 | * return 0 if nothing has been read from socket. |
253 | * return ~0 on failure. | 253 | * return ~0 on failure. |
254 | */ | 254 | */ |
255 | uint16_t read_TCP_length(sock_t sock) | 255 | uint16_t read_TCP_length(Socket sock) |
256 | { | 256 | { |
257 | unsigned int count = TCP_socket_data_recv_buffer(sock); | 257 | unsigned int count = TCP_socket_data_recv_buffer(sock); |
258 | 258 | ||
@@ -282,7 +282,7 @@ uint16_t read_TCP_length(sock_t sock) | |||
282 | * return length on success | 282 | * return length on success |
283 | * return -1 on failure/no data in buffer. | 283 | * return -1 on failure/no data in buffer. |
284 | */ | 284 | */ |
285 | int read_TCP_packet(sock_t sock, uint8_t *data, uint16_t length) | 285 | int read_TCP_packet(Socket sock, uint8_t *data, uint16_t length) |
286 | { | 286 | { |
287 | unsigned int count = TCP_socket_data_recv_buffer(sock); | 287 | unsigned int count = TCP_socket_data_recv_buffer(sock); |
288 | 288 | ||
@@ -304,7 +304,7 @@ int read_TCP_packet(sock_t sock, uint8_t *data, uint16_t length) | |||
304 | * return 0 if could not read any packet. | 304 | * return 0 if could not read any packet. |
305 | * return -1 on failure (connection must be killed). | 305 | * return -1 on failure (connection must be killed). |
306 | */ | 306 | */ |
307 | int read_packet_TCP_secure_connection(sock_t sock, uint16_t *next_packet_length, const uint8_t *shared_key, | 307 | int read_packet_TCP_secure_connection(Socket sock, uint16_t *next_packet_length, const uint8_t *shared_key, |
308 | uint8_t *recv_nonce, uint8_t *data, uint16_t max_len) | 308 | uint8_t *recv_nonce, uint8_t *data, uint16_t max_len) |
309 | { | 309 | { |
310 | if (*next_packet_length == 0) { | 310 | if (*next_packet_length == 0) { |
@@ -529,7 +529,7 @@ static int kill_accepted(TCP_Server *TCP_server, int index) | |||
529 | rm_connection_index(TCP_server, &TCP_server->accepted_connection_array[index], i); | 529 | rm_connection_index(TCP_server, &TCP_server->accepted_connection_array[index], i); |
530 | } | 530 | } |
531 | 531 | ||
532 | sock_t sock = TCP_server->accepted_connection_array[index].sock; | 532 | Socket sock = TCP_server->accepted_connection_array[index].sock; |
533 | 533 | ||
534 | if (del_accepted(TCP_server, index) != 0) { | 534 | if (del_accepted(TCP_server, index) != 0) { |
535 | return -1; | 535 | return -1; |
@@ -971,7 +971,7 @@ static int confirm_TCP_connection(TCP_Server *TCP_server, TCP_Secure_Connection | |||
971 | /* return index on success | 971 | /* return index on success |
972 | * return -1 on failure | 972 | * return -1 on failure |
973 | */ | 973 | */ |
974 | static int accept_connection(TCP_Server *TCP_server, sock_t sock) | 974 | static int accept_connection(TCP_Server *TCP_server, Socket sock) |
975 | { | 975 | { |
976 | if (!sock_valid(sock)) { | 976 | if (!sock_valid(sock)) { |
977 | return -1; | 977 | return -1; |
@@ -1003,9 +1003,9 @@ static int accept_connection(TCP_Server *TCP_server, sock_t sock) | |||
1003 | return index; | 1003 | return index; |
1004 | } | 1004 | } |
1005 | 1005 | ||
1006 | static sock_t new_listening_TCP_socket(int family, uint16_t port) | 1006 | static Socket new_listening_TCP_socket(int family, uint16_t port) |
1007 | { | 1007 | { |
1008 | sock_t sock = socket(family, SOCK_STREAM, IPPROTO_TCP); | 1008 | Socket sock = socket(family, SOCK_STREAM, IPPROTO_TCP); |
1009 | 1009 | ||
1010 | if (!sock_valid(sock)) { | 1010 | if (!sock_valid(sock)) { |
1011 | return ~0; | 1011 | return ~0; |
@@ -1048,7 +1048,7 @@ TCP_Server *new_TCP_server(uint8_t ipv6_enabled, uint16_t num_sockets, const uin | |||
1048 | return NULL; | 1048 | return NULL; |
1049 | } | 1049 | } |
1050 | 1050 | ||
1051 | temp->socks_listening = (sock_t *)calloc(num_sockets, sizeof(sock_t)); | 1051 | temp->socks_listening = (Socket *)calloc(num_sockets, sizeof(Socket)); |
1052 | 1052 | ||
1053 | if (temp->socks_listening == NULL) { | 1053 | if (temp->socks_listening == NULL) { |
1054 | free(temp); | 1054 | free(temp); |
@@ -1080,7 +1080,7 @@ TCP_Server *new_TCP_server(uint8_t ipv6_enabled, uint16_t num_sockets, const uin | |||
1080 | #endif | 1080 | #endif |
1081 | 1081 | ||
1082 | for (i = 0; i < num_sockets; ++i) { | 1082 | for (i = 0; i < num_sockets; ++i) { |
1083 | sock_t sock = new_listening_TCP_socket(family, ports[i]); | 1083 | Socket sock = new_listening_TCP_socket(family, ports[i]); |
1084 | 1084 | ||
1085 | if (sock_valid(sock)) { | 1085 | if (sock_valid(sock)) { |
1086 | #ifdef TCP_SERVER_USE_EPOLL | 1086 | #ifdef TCP_SERVER_USE_EPOLL |
@@ -1124,7 +1124,7 @@ static void do_TCP_accept_new(TCP_Server *TCP_server) | |||
1124 | for (i = 0; i < TCP_server->num_listening_socks; ++i) { | 1124 | for (i = 0; i < TCP_server->num_listening_socks; ++i) { |
1125 | struct sockaddr_storage addr; | 1125 | struct sockaddr_storage addr; |
1126 | socklen_t addrlen = sizeof(addr); | 1126 | socklen_t addrlen = sizeof(addr); |
1127 | sock_t sock; | 1127 | Socket sock; |
1128 | 1128 | ||
1129 | do { | 1129 | do { |
1130 | sock = accept(TCP_server->socks_listening[i], (struct sockaddr *)&addr, &addrlen); | 1130 | sock = accept(TCP_server->socks_listening[i], (struct sockaddr *)&addr, &addrlen); |
@@ -1292,7 +1292,7 @@ static void do_TCP_epoll(TCP_Server *TCP_server) | |||
1292 | int n; | 1292 | int n; |
1293 | 1293 | ||
1294 | for (n = 0; n < nfds; ++n) { | 1294 | for (n = 0; n < nfds; ++n) { |
1295 | sock_t sock = events[n].data.u64 & 0xFFFFFFFF; | 1295 | Socket sock = events[n].data.u64 & 0xFFFFFFFF; |
1296 | int status = (events[n].data.u64 >> 32) & 0xFF, index = (events[n].data.u64 >> 40); | 1296 | int status = (events[n].data.u64 >> 32) & 0xFF, index = (events[n].data.u64 >> 40); |
1297 | 1297 | ||
1298 | if ((events[n].events & EPOLLERR) || (events[n].events & EPOLLHUP) || (events[n].events & EPOLLRDHUP)) { | 1298 | if ((events[n].events & EPOLLERR) || (events[n].events & EPOLLHUP) || (events[n].events & EPOLLRDHUP)) { |
@@ -1333,7 +1333,7 @@ static void do_TCP_epoll(TCP_Server *TCP_server) | |||
1333 | socklen_t addrlen = sizeof(addr); | 1333 | socklen_t addrlen = sizeof(addr); |
1334 | 1334 | ||
1335 | while (1) { | 1335 | while (1) { |
1336 | sock_t sock_new = accept(sock, (struct sockaddr *)&addr, &addrlen); | 1336 | Socket sock_new = accept(sock, (struct sockaddr *)&addr, &addrlen); |
1337 | 1337 | ||
1338 | if (!sock_valid(sock_new)) { | 1338 | if (!sock_valid(sock_new)) { |
1339 | break; | 1339 | break; |