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

Handle empty response

Browse Source
This commit is contained in:
ruti 2024-08-20 02:56:10 +03:00
parent efee93cfd9
commit bd2eb4e4e1
1 changed files with 26 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
extend.c
View File

@ -206,6 +206,30 @@ int on_torst(struct poolhd *pool, struct eval *val)
} }
int on_fin(struct poolhd *pool, struct eval *val)
{
int m = val->pair->attempt + 1;
for (; m < params.dp_count; m++) {
struct desync_params *dp = &params.dp[m];
if (!dp->detect) {
return -1;
}
if (!(dp->detect & DETECT_TLS_ERR)) {
continue;
}
char *req = val->pair->buff.data;
ssize_t qn = val->pair->buff.size;
if (!is_tls_chello(req, qn)) {
continue;
}
return reconnect(pool, val, m);
}
return -1;
}
int on_response(struct poolhd *pool, struct eval *val, int on_response(struct poolhd *pool, struct eval *val,
char *resp, ssize_t sn) char *resp, ssize_t sn)
{ {
@ -260,10 +284,9 @@ int on_tunnel_check(struct poolhd *pool, struct eval *val,
case ECONNRESET: case ECONNRESET:
case ECONNREFUSED: case ECONNREFUSED:
case ETIMEDOUT: case ETIMEDOUT:
break; return on_torst(pool, val);
default: return -1;
} }
return on_torst(pool, val); return on_fin(pool, val);
} }
// //
if (on_response(pool, val, buffer, n) == 0) { if (on_response(pool, val, buffer, n) == 0) {