1

business/jxstore/event/event_tcp.go

@@ -19,7 +19,7 @@ import (
 var Poll *Pool
 
 func init() {
-	Poll = NewPool(100)
+	Poll = NewPool(500)
 	Poll.Start()
 
 }
@@ -51,6 +51,7 @@ func ListenTcp() {
 			t := NewTcpClient()
 			if err := handleConn(c, t); err != nil {
 				t = nil
+				Poll.Stop()
 				return
 			}
 		}
@@ -228,6 +229,8 @@ func (t *TcpClient) HandleTcpMessages(printNo string) {
 				}
 			} else {
 				globals.SugarLogger.Debugf("HandleTcpMessages timeout")
+				t = nil
+				Poll.Stop()
 				return
 			}
 		}
@@ -356,10 +359,14 @@ func (t *TcpClient) doPrint(key string) (err error) {
 							}
 						}
 					} else {
+						t = nil
+						Poll.Stop()
 						globals.SugarLogger.Debugf("msgMap is nil")
 					}
 				}
 			} else {
+				t = nil
+				Poll.Stop()
 				globals.SugarLogger.Debugf("doPrint timeout")
 				return
 			}