aa

2021-08-02 17:31:20 +08:00
parent b87b12f548
commit bc2ac8bed1
1 changed files with 8 additions and 1 deletions
--- a/business/jxstore/event/event_tcp.go
+++ b/business/jxstore/event/event_tcp.go
@@ -239,7 +239,14 @@ func (t *TcpClient) doPrint(key string) (err error) {
 						if c != nil {
 							if _, err = c.Write(data); err != nil {
 								globals.SugarLogger.Debugf("handleTcpMessages err [%v]", err)
-								t.delConn(printMsg.PrintNo)
+								//t.delConn(printMsg.PrintNo)
+								if t.isExist(key) {
+									timeoutChan <- 1
+									timeoutChan <- 1
+									timeoutChan <- 1
+									t.clear(key)
+								}
+								return
 							} else {
 								globals.SugarLogger.Debugf("handleTcpMessages success, data: %v", hex.EncodeToString(data))
 								//等待回调