diff --git a/inbound/default_tcp.go b/inbound/default_tcp.go index 0d32a1c0..b0d9d9e5 100644 --- a/inbound/default_tcp.go +++ b/inbound/default_tcp.go @@ -40,7 +40,11 @@ func (a *myInboundAdapter) loopTCPIn() { for { conn, err := tcpListener.Accept() if err != nil { - return + if E.IsClosed(err) { + return + } + a.logger.Error("accept: ", err) + continue } go a.injectTCP(conn, adapter.InboundContext{}) }