mirrors/byedpi
0
0
Fork 0
mirror of https://github.com/hufrea/byedpi.git synced 2025-06-30 18:43:04 +00:00
Code

-j after reconnect

Browse Source
This commit is contained in:
ruti 2025-05-20 20:12:09 +03:00
parent 31abd95aed
commit 13abef7c01
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
extend.c
View File

@ -127,20 +127,25 @@ static int cache_add(const union sockaddr_u *dst, int m)
int connect_hook(struct poolhd *pool, struct eval *val, int connect_hook(struct poolhd *pool, struct eval *val,
const union sockaddr_u *dst, evcb_t next) const union sockaddr_u *dst, evcb_t next)
{ {
int m = cache_get(dst), init_m = m; int m = val->attempt;
val->cache = (m == 0); if (!m) {
m = cache_get(dst);
val->cache = (m == 0);
}
int init_m = m;
m = m < 0 ? 0 : m; m = m < 0 ? 0 : m;
struct desync_params *dp; struct desync_params *dp;
for (; ; m++) { for (; ; m++) {
if (m == params.dp_count) {
return -1;
}
dp = &params.dp[m]; dp = &params.dp[m];
if ((!dp->detect || m == init_m) if ((!dp->detect || m == init_m)
&& check_l34(dp, SOCK_STREAM, dst)) { && check_l34(dp, SOCK_STREAM, dst)) {
break; break;
} }
if (m == params.dp_count) {
return -1;
}
} }
val->attempt = m; val->attempt = m;
@ -173,15 +178,15 @@ static int reconnect(struct poolhd *pool, struct eval *val, int m)
assert(val->flag == FLAG_CONN); assert(val->flag == FLAG_CONN);
struct eval *client = val->pair; struct eval *client = val->pair;
client->attempt = m;
if (create_conn(pool, client, &val->addr, &on_tunnel)) { if (connect_hook(pool, client, &val->addr, &on_tunnel)) {
return -1; return -1;
} }
val->pair = 0; val->pair = 0;
del_event(pool, val); del_event(pool, val);
client->cb = &on_tunnel; client->cb = &on_tunnel;
client->attempt = m;
client->cache = 1; client->cache = 1;
if (!client->buff) { if (!client->buff) {