From c4bac7f43c9bb851be3a8f68cdc8c05daae75186 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Tue, 27 Dec 2022 18:58:29 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/client_conn.go | 6 ++++++ internal/utils/agents/manager.go | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/internal/nodes/client_conn.go b/internal/nodes/client_conn.go index 288aaea..a8c802a 100644 --- a/internal/nodes/client_conn.go +++ b/internal/nodes/client_conn.go @@ -15,6 +15,7 @@ import ( "github.com/TeaOSLab/EdgeNode/internal/waf" "github.com/iwind/TeaGo/Tea" "github.com/iwind/TeaGo/types" + "io" "net" "os" "strings" @@ -112,6 +113,11 @@ func (this *ClientConn) Read(b []byte) (n int, err error) { } } + // 关闭连接 + if err == io.EOF { + _ = this.rawConn.Close() + } + return } diff --git a/internal/utils/agents/manager.go b/internal/utils/agents/manager.go index ffcc762..d8b46f5 100644 --- a/internal/utils/agents/manager.go +++ b/internal/utils/agents/manager.go @@ -69,7 +69,7 @@ func (this *Manager) Start() { } // 定时获取 - var duration = 30 * time.Second + var duration = 30 * time.Minute if Tea.IsTesting() { duration = 30 * time.Second }