From 10b7aa3bc7557214ee0a361dc716382ce15c0d1c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Wed, 10 Jul 2024 12:47:56 +0800 Subject: [PATCH] 1 --- business/jxstore/event/event_tcp.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 079c44203..c64c76457 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -73,8 +73,6 @@ func handleConn(c net.Conn) error { return err } - globals.SugarLogger.Debugf("=====buffer := %s", string(buffer)) - globals.SugarLogger.Debugf("=====buffer := %s", utils.Format4Output(c.LocalAddr(), false)) //看是心跳还是打印回调 data := hex.EncodeToString(buffer[:n]) var ( @@ -262,10 +260,10 @@ func doPrint(t *TcpClient, key string) (err error) { } if _, err = c.Write(data); err != nil { - globals.SugarLogger.Debugf("=====2 %v", err) globals.SugarLogger.Debugf("handleTcpMessages err [%v]", err) //close(t.TimeoutMap[key]) - delete(t.TimeoutMap, key) + //delete(t.TimeoutMap, key) + delete(PrintObject, key) } else { //等待回调 dataStr := <-t.CallBackMap[key]