mirrors/byedpi
1
0
Fork 0
mirror of https://github.com/hufrea/byedpi.git synced 2024-12-22 22:35:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

--repeats for UDP

Browse Source
This commit is contained in:
ruti 2024-10-18 12:30:48 +03:00
parent 2240039377
commit 225ccc8319
2 changed files with 18 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
extend.c
View File

@ -452,20 +452,23 @@ ssize_t tcp_recv_hook(struct poolhd *pool, struct eval *val,
ssize_t udp_hook(struct eval *val, ssize_t udp_hook(struct eval *val,
char *buffer, size_t bfsize, ssize_t n, struct sockaddr_ina *dst) char *buffer, size_t bfsize, ssize_t n, struct sockaddr_ina *dst)
{ {
if (val->recv_count) { if (val->round_count > params.repeats) {
return send(val->fd, buffer, n, 0); return send(val->fd, buffer, n, 0);
} }
int m = val->attempt; int m = val->attempt;
if (!m) for (; m < params.dp_count; m++) { if (!m) {
struct desync_params *dp = &params.dp[m]; for (; m < params.dp_count; m++) {
if (!dp->detect && struct desync_params *dp = &params.dp[m];
(!dp->proto || (dp->proto & IS_UDP)) && if (!dp->detect &&
(!dp->pf[0] || check_port(dp->pf, &dst->in6))) { (!dp->proto || (dp->proto & IS_UDP)) &&
break; (!dp->pf[0] || check_port(dp->pf, &dst->in6))) {
break;
}
} }
} if (m >= params.dp_count) {
if (m >= params.dp_count) { return -1;
return -1; }
val->attempt = m;
} }
return desync_udp(val->fd, buffer, bfsize, n, &dst->sa, m); return desync_udp(val->fd, buffer, bfsize, n, &dst->sa, m);
} }

5
proxy.c
View File

@ -746,6 +746,11 @@ int on_udp_tunnel(struct eval *val, char *buffer, size_t bfsize)
return -1; return -1;
} }
val->recv_count += n; val->recv_count += n;
if (val->round_sent == 0) {
val->round_count++;
val->round_sent += n;
val->pair->round_sent = 0;
}
ssize_t ns; ssize_t ns;
if (val->flag == FLAG_CONN) { if (val->flag == FLAG_CONN) {