third-party-mirrors/sslh
1
0
Fork 0
mirror of https://github.com/yrutschle/sslh.git synced 2025-04-13 07:37:15 +03:00
Code Issues Packages Projects Releases Wiki Activity

remove dependancy to watcher type in UDP timeout

Browse Source
This commit is contained in:
yrutschle 2021-11-09 18:12:02 +01:00
parent 8ddff5e388
commit d4d9dbb8e7
1 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
sslh-select.c
View File

@ -126,23 +126,21 @@ static void udp_timeouts(struct loop_info* fd_info)
time_t next_timeout = INT_MAX; time_t next_timeout = INT_MAX;
for (int i = 0; i < fd_info->watchers->max_fd; i++) { for (int i = 0; i < watchers_maxfd(fd_info->watchers); i++) {
/* if it's either in read or write set, there is a connection /* if it's either in read or write set, there is a connection
* behind that file descriptor */ * behind that file descriptor */
if (FD_ISSET(i, &fd_info->watchers->fds_r) || FD_ISSET(i, &fd_info->watchers->fds_w)) { struct connection* cnx = collection_get_cnx_from_fd(fd_info->collection, i);
struct connection* cnx = collection_get_cnx_from_fd(fd_info->collection, i); if (cnx) {
if (cnx) { time_t timeout = udp_timeout(cnx);
time_t timeout = udp_timeout(cnx); if (!timeout) continue; /* Not a UDP connection */
if (!timeout) continue; /* Not a UDP connection */ if (cnx && (timeout <= now)) {
if (cnx && (timeout <= now)) { print_message(msg_fd, "timed out UDP %d\n", cnx->target_sock);
print_message(msg_fd, "timed out UDP %d\n", cnx->target_sock); close(cnx->target_sock);
close(cnx->target_sock); watchers_del_read(fd_info->watchers, i);
watchers_del_read(fd_info->watchers, i); watchers_del_write(fd_info->watchers, i);
watchers_del_write(fd_info->watchers, i); collection_remove_cnx(fd_info->collection, cnx);
collection_remove_cnx(fd_info->collection, cnx); } else {
} else { if (timeout < next_timeout) next_timeout = timeout;
if (timeout < next_timeout) next_timeout = timeout;
}
} }
} }
} }