mirror of
https://github.com/hufrea/byedpi.git
synced 2024-12-18 11:52:13 +03:00
rst if exist only one group
This commit is contained in:
parent
dca3b5693a
commit
e406476610
1 changed files with 9 additions and 6 deletions
15
extend.c
15
extend.c
|
@ -223,21 +223,24 @@ int on_torst(struct poolhd *pool, struct eval *val)
|
||||||
for (; m < params.dp_count; m++) {
|
for (; m < params.dp_count; m++) {
|
||||||
struct desync_params *dp = ¶ms.dp[m];
|
struct desync_params *dp = ¶ms.dp[m];
|
||||||
if (!dp->detect) {
|
if (!dp->detect) {
|
||||||
return -1;
|
m = 0;
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
if (dp->detect & DETECT_TORST) {
|
if (dp->detect & DETECT_TORST) {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (m >= params.dp_count) {
|
if (m == 0) {
|
||||||
|
}
|
||||||
|
else if (m >= params.dp_count) {
|
||||||
if (m > 1) mode_add_get(
|
if (m > 1) mode_add_get(
|
||||||
(struct sockaddr_ina *)&val->in6, 0);
|
(struct sockaddr_ina *)&val->in6, 0);
|
||||||
}
|
}
|
||||||
else if (can_reconn)
|
else if (can_reconn) {
|
||||||
return reconnect(pool, val, m);
|
return reconnect(pool, val, m);
|
||||||
else
|
}
|
||||||
mode_add_get(
|
else mode_add_get(
|
||||||
(struct sockaddr_ina *)&val->in6, m);
|
(struct sockaddr_ina *)&val->in6, m);
|
||||||
}
|
}
|
||||||
struct linger l = { .l_onoff = 1 };
|
struct linger l = { .l_onoff = 1 };
|
||||||
if (setsockopt(val->pair->fd, SOL_SOCKET,
|
if (setsockopt(val->pair->fd, SOL_SOCKET,
|
||||||
|
|
Loading…
Reference in a new issue