ForkMaster/zapret
1
0
Fork 0
mirror of https://github.com/bol-van/zapret.git synced 2024-12-28 20:30:33 +05:00
Code Issues Actions Packages Projects Releases Wiki Activity

tpws: rate limit fix-seg errors without --debug

Browse Source
This commit is contained in:
bol-van 2024-11-19 10:12:39 +03:00
parent a93b142dcd
commit a0e1742861
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
tpws/tpws_conn.c
View File

@ -1118,8 +1118,24 @@ static ssize_t send_oob(int fd, uint8_t *buf, size_t len, int ttl, bool oob, uin
} }
static unsigned int segfail_count=0;
static time_t segfail_report_time=0;
static void report_segfail(void)
{
time_t now = time(NULL);
segfail_count++;
if (now==segfail_report_time)
VPRINT("WARNING ! segmentation failed. total fails : %u\n", segfail_count);
else
{
DLOG_ERR("WARNING ! segmentation failed. total fails : %u\n", segfail_count);
segfail_report_time = now;
}
}
#define RD_BLOCK_SIZE 65536 #define RD_BLOCK_SIZE 65536
#define MAX_WASTE (1024*1024) #define MAX_WASTE (1024*1024)
static bool handle_epoll(tproxy_conn_t *conn, struct tailhead *conn_list, uint32_t evt) static bool handle_epoll(tproxy_conn_t *conn, struct tailhead *conn_list, uint32_t evt)
{ {
int numbytes; int numbytes;
@ -1239,12 +1255,12 @@ static bool handle_epoll(tproxy_conn_t *conn, struct tailhead *conn_list, uint32
if (wasted) if (wasted)
VPRINT("WARNING ! wasted %u ms to fix segmenation\n", wasted); VPRINT("WARNING ! wasted %u ms to fix segmenation\n", wasted);
if (!bWaitOK) if (!bWaitOK)
DLOG_ERR("WARNING ! segmentation failed\n"); report_segfail();
} }
else else
{ {
if (socket_has_notsent(conn->partner->fd)) if (socket_has_notsent(conn->partner->fd))
DLOG_ERR("WARNING ! segmentation failed\n"); report_segfail();
} }
#endif #endif
VPRINT("Sending multisplit part %d %zd-%zd (len %zd)%s%s : ", i+1, from, to, len, bApplyDisorder ? " with disorder" : "", bApplyOOB ? " with OOB" : ""); VPRINT("Sending multisplit part %d %zd-%zd (len %zd)%s%s : ", i+1, from, to, len, bApplyDisorder ? " with disorder" : "", bApplyOOB ? " with OOB" : "");