From 2af4dc7327c1be3b5aa2c598becd8101166d8662 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Tue, 3 Aug 2021 14:59:21 +0800 Subject: [PATCH] aa --- business/jxstore/event/event_tcp.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 25d4a4cab..289474f43 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -191,8 +191,6 @@ func (t *TcpClient) doPrint(key string) (err error) { if !t.isExistMsg(key) { return err } - defer close(t.MsgMap[key]) - defer close(t.CallBackMap[key]) globals.SugarLogger.Debugf("doPrint printNo: %s", key) go func() { for { @@ -256,13 +254,14 @@ func (t *TcpClient) doPrint(key string) (err error) { } } }() + close(t.MsgMap[key]) + close(t.CallBackMap[key]) return err } //检测心跳 func (t *TcpClient) HandleCheckTcpHeart(key string) { globals.SugarLogger.Debugf("HandleCheckTcpHeart begin key: %s", key) - defer t.Clients[key].C.Close() go func() { for { select { @@ -298,4 +297,5 @@ func (t *TcpClient) HandleCheckTcpHeart(key string) { //} } }() + t.Clients[key].C.Close() }