| 56 |
} |
} |
| 57 |
|
|
| 58 |
sin.sin_family = AF_INET; |
sin.sin_family = AF_INET; |
| 59 |
sin.sin_addr.s_addr = |
sin.sin_addr.s_addr = (hostaddr[0] != '\0' ? inet_addr(hostaddr) : INADDR_ANY); |
|
(strnlen(hostaddr, sizeof(hostaddr)) > 0 ? inet_addr(hostaddr) : INADDR_ANY); |
|
| 60 |
sin.sin_port = htons(port); |
sin.sin_port = htons(port); |
| 61 |
|
|
| 62 |
|
// Reuse address and port |
| 63 |
|
flags = 1; |
| 64 |
|
if (setsockopt(socket_server, SOL_SOCKET, SO_REUSEADDR, &flags, sizeof(flags)) < 0) |
| 65 |
|
{ |
| 66 |
|
log_error("setsockopt SO_REUSEADDR error (%d)\n", errno); |
| 67 |
|
} |
| 68 |
|
if (setsockopt(socket_server, SOL_SOCKET, SO_REUSEPORT, &flags, sizeof(flags)) < 0) |
| 69 |
|
{ |
| 70 |
|
log_error("setsockopt SO_REUSEPORT error (%d)\n", errno); |
| 71 |
|
} |
| 72 |
|
|
| 73 |
if (bind(socket_server, (struct sockaddr *)&sin, sizeof(sin)) < 0) |
if (bind(socket_server, (struct sockaddr *)&sin, sizeof(sin)) < 0) |
| 74 |
{ |
{ |
| 75 |
log_error("Bind address %s:%u failed\n", |
log_error("Bind address %s:%u failed (%d)\n", |
| 76 |
inet_ntoa(sin.sin_addr), ntohs(sin.sin_port)); |
inet_ntoa(sin.sin_addr), ntohs(sin.sin_port), errno); |
| 77 |
exit(2); |
exit(2); |
| 78 |
} |
} |
| 79 |
|
|
| 80 |
if (listen(socket_server, 10) < 0) |
if (listen(socket_server, 10) < 0) |
| 81 |
{ |
{ |
| 82 |
log_error("Socket listen failed\n"); |
log_error("Socket listen failed (%d)\n", errno); |
| 83 |
exit(3); |
exit(3); |
| 84 |
} |
} |
| 85 |
|
|
| 151 |
timeout.tv_sec = 0; |
timeout.tv_sec = 0; |
| 152 |
timeout.tv_usec = 100 * 1000; // 0.1 second |
timeout.tv_usec = 100 * 1000; // 0.1 second |
| 153 |
|
|
| 154 |
ret = select(FD_SETSIZE, &testfds, NULL, NULL, &timeout); |
ret = select(socket_server + 1, &testfds, NULL, NULL, &timeout); |
| 155 |
|
|
| 156 |
if (ret < 0) |
if (ret < 0) |
| 157 |
{ |
{ |
| 176 |
{ |
{ |
| 177 |
flags = fcntl(socket_server, F_GETFL, 0); |
flags = fcntl(socket_server, F_GETFL, 0); |
| 178 |
fcntl(socket_server, F_SETFL, flags | O_NONBLOCK); |
fcntl(socket_server, F_SETFL, flags | O_NONBLOCK); |
| 179 |
|
|
| 180 |
while ((socket_client = |
while ((socket_client = |
| 181 |
accept(socket_server, (struct sockaddr *)&sin, &namelen)) < 0) |
accept(socket_server, (struct sockaddr *)&sin, &namelen)) < 0) |
| 182 |
{ |
{ |
| 186 |
break; |
break; |
| 187 |
} |
} |
| 188 |
} |
} |
| 189 |
|
|
| 190 |
fcntl(socket_server, F_SETFL, flags); |
fcntl(socket_server, F_SETFL, flags); |
| 191 |
} |
} |
| 192 |
|
|