| 17 |
|
|
| 18 |
#include "common.h" |
#include "common.h" |
| 19 |
#include "io.h" |
#include "io.h" |
| 20 |
|
#include "tcplib.h" |
| 21 |
#include <sys/socket.h> |
#include <sys/socket.h> |
| 22 |
#include <netinet/in.h> |
#include <netinet/in.h> |
| 23 |
#include <arpa/inet.h> |
#include <arpa/inet.h> |
| 25 |
int |
int |
| 26 |
net_server (const char *hostaddr, unsigned int port) |
net_server (const char *hostaddr, unsigned int port) |
| 27 |
{ |
{ |
| 28 |
int namelen, seq, netint; |
int namelen, seq, netint, result, flags; |
| 29 |
struct sockaddr_in sin; |
struct sockaddr_in sin; |
| 30 |
char temp[256]; |
char temp[256]; |
| 31 |
|
fd_set testfds; |
| 32 |
|
struct timeval timeout; |
| 33 |
|
|
| 34 |
socket_server = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP); |
socket_server = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP); |
| 35 |
|
|
| 63 |
log_std ("Listening at %s:%d\n", hostaddr_server, port_server); |
log_std ("Listening at %s:%d\n", hostaddr_server, port_server); |
| 64 |
|
|
| 65 |
namelen = sizeof (sin); |
namelen = sizeof (sin); |
| 66 |
while (1) |
while (!SYS_exit) |
| 67 |
{ |
{ |
| 68 |
if ((socket_client = |
FD_ZERO (&testfds); |
| 69 |
accept (socket_server, (struct sockaddr *) &sin, &namelen)) < 0) |
FD_SET (socket_server, &testfds); |
| 70 |
{ |
|
| 71 |
log_error ("Accept connection error\n"); |
timeout.tv_sec = 1; |
| 72 |
continue; |
timeout.tv_usec = 0; |
| 73 |
} |
|
| 74 |
|
result = SignalSafeSelect (FD_SETSIZE, &testfds, NULL, NULL, &timeout); |
| 75 |
|
if (result < 0) |
| 76 |
|
{ |
| 77 |
|
log_error ("Accept connection error\n"); |
| 78 |
|
continue; |
| 79 |
|
} |
| 80 |
|
|
| 81 |
|
if (result == 0) |
| 82 |
|
{ |
| 83 |
|
continue; |
| 84 |
|
} |
| 85 |
|
|
| 86 |
|
if (FD_ISSET (socket_server, &testfds)) |
| 87 |
|
{ |
| 88 |
|
flags = fcntl (socket_server, F_GETFL, 0); |
| 89 |
|
fcntl (socket_server, F_SETFL, flags | O_NONBLOCK); |
| 90 |
|
while ((socket_client = |
| 91 |
|
accept (socket_server, (struct sockaddr *) &sin, &namelen)) < 0) |
| 92 |
|
{ |
| 93 |
|
if (errno != EWOULDBLOCK && errno != ECONNABORTED && errno != EINTR) |
| 94 |
|
{ |
| 95 |
|
log_error ("Accept connection error\n"); |
| 96 |
|
break; |
| 97 |
|
} |
| 98 |
|
} |
| 99 |
|
fcntl (socket_server, F_SETFL, flags); |
| 100 |
|
} |
| 101 |
|
|
| 102 |
|
if (socket_client < 0) |
| 103 |
|
{ |
| 104 |
|
log_error ("Accept connection error\n"); |
| 105 |
|
continue; |
| 106 |
|
} |
| 107 |
|
|
| 108 |
strcpy (hostaddr_client, (const char *) inet_ntoa (sin.sin_addr)); |
strcpy (hostaddr_client, (const char *) inet_ntoa (sin.sin_addr)); |
| 109 |
port_client = ntohs (sin.sin_port); |
port_client = ntohs (sin.sin_port); |