From 6ee030ca7cff06395f832f54c74fdf6c4a7a573d Mon Sep 17 00:00:00 2001 From: Evgeny Date: Thu, 4 Jun 2026 23:07:34 +0300 Subject: [PATCH] 1 --- src/etcp_router.h | 2 +- src/proxy/tcp_proxy_server.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/etcp_router.h b/src/etcp_router.h index 027d22a1..de43e1e5 100644 --- a/src/etcp_router.h +++ b/src/etcp_router.h @@ -63,7 +63,7 @@ struct ETCP_ROUTER_CONN { #define ROUTER_ACK_INTERVAL_TB 100 // интервал ACK: 10ms в timebase (0.1ms) #define ROUTER_ACK_IDLE_TB 5000 // idle таймаут: 500ms #define ROUTER_SEND_RESUME_TB 500 // retry интервал send_q: 50ms -#define ROUTER_MAX_SEND_Q_PACKETS 256 // порог backpressure на send_q +#define ROUTER_MAX_SEND_Q_PACKETS 4 // порог backpressure на send_q // Флаги в старших битах seq (взаимоисключающие) #define ROUTER_SEQ_CLOSE_FLAG 0x80000000 // нормальное закрытие conn diff --git a/src/proxy/tcp_proxy_server.c b/src/proxy/tcp_proxy_server.c index c13d9004..4fc237eb 100644 --- a/src/proxy/tcp_proxy_server.c +++ b/src/proxy/tcp_proxy_server.c @@ -290,7 +290,7 @@ int tcp_proxy_server_handle_connect(struct UTUN_INSTANCE* inst, struct ll_entry* (int)sock, stream_id, dest_ip[0],dest_ip[1],dest_ip[2],dest_ip[3],ntohs(dest_port), ctx->conn_count); socket_set_nonblocking(sock); - rc->tc = tcp_conn_create(inst->ua, sock, 1500, 8192, 32, 8, on_fin_cb, on_error_cb, rc); + rc->tc = tcp_conn_create(inst->ua, sock, 1500, 8192, 4, 0, on_fin_cb, on_error_cb, rc); if (!rc->tc) { DEBUG_ERROR(DEBUG_CATEGORY_SOCKET, "TCP proxy server: tcp_conn_create failed"); socket_close_wrapper(sock); ctx->conn_count--; u_free(rc); queue_dgram_free(entry); queue_entry_free(entry); return -1; } rc->tc->on_closed = on_closed_cb; queue_set_callback(rc->tc->read_queue, read_queue_drain_cb, rc);