1

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
 			}