third-party-mirrors/sslh
1
0
Fork 0
mirror of https://github.com/yrutschle/sslh.git synced 2025-06-19 16:33:52 +03:00
Code Issues Packages Projects Releases Wiki Activity

abstract connection activation

Browse Source
This commit is contained in:
yrutschle 2022-04-18 21:25:07 +02:00
parent 35036c94c7
commit 8ac93c3e9d
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
udp-listener.c
View File

@ -164,6 +164,12 @@ void udp_timeouts(struct loop_info* fd_info)
fd_info->next_timeout = next_timeout; fd_info->next_timeout = next_timeout;
} }
/* Mark the connection was active */
static void mark_active(struct connection* cnx)
{
cnx->last_active = time(NULL);
}
/* Process UDP coming from outside (client towards server) /* Process UDP coming from outside (client towards server)
* If it's a new source, probe; otherwise, forward to previous target * If it's a new source, probe; otherwise, forward to previous target
@ -235,14 +241,13 @@ int udp_c2s_forward(int sockfd, struct loop_info* fd_info)
/* at this point src is the UDP connection */ /* at this point src is the UDP connection */
res = sendto(cnx->target_sock, data, len, 0, res = sendto(cnx->target_sock, data, len, 0,
cnx->proto->saddr->ai_addr, cnx->proto->saddr->ai_addrlen); cnx->proto->saddr->ai_addr, cnx->proto->saddr->ai_addrlen);
cnx->last_active = time(NULL); mark_active(cnx);
print_message(msg_fd, "sending %d to %s\n", print_message(msg_fd, "sending %d to %s\n",
res, sprintaddr(data, sizeof(data), cnx->proto->saddr)); res, sprintaddr(data, sizeof(data), cnx->proto->saddr));
return out; return out;
} }
void udp_s2c_forward(struct connection* cnx) void udp_s2c_forward(struct connection* cnx)
{ {
int sockfd = cnx->target_sock; int sockfd = cnx->target_sock;
@ -254,6 +259,6 @@ void udp_s2c_forward(struct connection* cnx)
CHECK_RES_DIE(res, "udp_listener/recvfrom"); CHECK_RES_DIE(res, "udp_listener/recvfrom");
res = sendto(cnx->local_endpoint, data, res, 0, res = sendto(cnx->local_endpoint, data, res, 0,
&cnx->client_addr, cnx->addrlen); &cnx->client_addr, cnx->addrlen);
cnx->last_active = time(NULL); mark_active(cnx);
} }