From ff7ae26ce5a79d1d9e2c099d64861eff548f3e7e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Wed, 31 May 2023 19:45:27 +0800 Subject: [PATCH] 1 --- business/jxstore/event/event_tcp.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index e05a43ef0..c64d4124c 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -51,7 +51,7 @@ func ListenTcp() { t := NewTcpClient() if err := handleConn(c, t); err != nil { t = nil - Poll.Stop() + //Poll.Stop() return } } @@ -230,7 +230,7 @@ func (t *TcpClient) HandleTcpMessages(printNo string) { } else { globals.SugarLogger.Debugf("HandleTcpMessages timeout") t = nil - Poll.Stop() + //Poll.Stop() return } } @@ -284,7 +284,7 @@ func (t *TcpClient) doPrint(key string) (err error) { if !ok { globals.SugarLogger.Debugf("doPrint err !ok ...") t = nil - Poll.Stop() + //Poll.Stop() return } var ( @@ -362,13 +362,13 @@ func (t *TcpClient) doPrint(key string) (err error) { } } else { t = nil - Poll.Stop() + //Poll.Stop() globals.SugarLogger.Debugf("msgMap is nil") } } } else { t = nil - Poll.Stop() + //Poll.Stop() globals.SugarLogger.Debugf("doPrint timeout") return }