From ca27491d146961c840496a0f504c441510119be6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= <zouzongnan1995@icloud.com>
Date: Wed, 31 May 2023 15:43:18 +0800
Subject: [PATCH] 1

---
 business/jxstore/event/event_tcp.go | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go
index d7d2fa55f..60d2a41ff 100644
--- a/business/jxstore/event/event_tcp.go
+++ b/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
 			}