summaryrefslogtreecommitdiff
path: root/toxcore/TCP_server.c
diff options
context:
space:
mode:
Diffstat (limited to 'toxcore/TCP_server.c')
-rw-r--r--toxcore/TCP_server.c30
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 */
81static int bind_to_port(sock_t sock, int family, uint16_t port) 81static 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 */
235unsigned int TCP_socket_data_recv_buffer(sock_t sock) 235unsigned 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 */
255uint16_t read_TCP_length(sock_t sock) 255uint16_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 */
285int read_TCP_packet(sock_t sock, uint8_t *data, uint16_t length) 285int 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 */
307int read_packet_TCP_secure_connection(sock_t sock, uint16_t *next_packet_length, const uint8_t *shared_key, 307int 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 */
974static int accept_connection(TCP_Server *TCP_server, sock_t sock) 974static 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
1006static sock_t new_listening_TCP_socket(int family, uint16_t port) 1006static 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;