From 7652dc7b27fcad5f95eb4c60f054d60f206fcc69 Mon Sep 17 00:00:00 2001 From: zak Date: Tue, 6 Sep 2022 21:18:05 +0800 Subject: [PATCH] loopTCPIn should not return when one conn error --- inbound/default_tcp.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/inbound/default_tcp.go b/inbound/default_tcp.go index 0d32a1c0..be665c3c 100644 --- a/inbound/default_tcp.go +++ b/inbound/default_tcp.go @@ -40,9 +40,10 @@ func (a *myInboundAdapter) loopTCPIn() { for { conn, err := tcpListener.Accept() if err != nil { - return + a.logger.ErrorContext(a.ctx, err) + } else { + go a.injectTCP(conn, adapter.InboundContext{}) } - go a.injectTCP(conn, adapter.InboundContext{}) } }