liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-08-03 14:59:21 +08:00
parent 9b8bc1c240
commit 2af4dc7327
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/jxstore/event/event_tcp.go
View File

@@ -191,8 +191,6 @@ func (t *TcpClient) doPrint(key string) (err error) {
if !t.isExistMsg(key) { if !t.isExistMsg(key) {
return err return err
} }
defer close(t.MsgMap[key])
defer close(t.CallBackMap[key])
globals.SugarLogger.Debugf("doPrint printNo: %s", key) globals.SugarLogger.Debugf("doPrint printNo: %s", key)
go func() { go func() {
for { for {
@@ -256,13 +254,14 @@ func (t *TcpClient) doPrint(key string) (err error) {
} }
} }
}() }()
close(t.MsgMap[key])
close(t.CallBackMap[key])
return err return err
} }
//检测心跳 //检测心跳
func (t *TcpClient) HandleCheckTcpHeart(key string) { func (t *TcpClient) HandleCheckTcpHeart(key string) {
globals.SugarLogger.Debugf("HandleCheckTcpHeart begin key: %s", key) globals.SugarLogger.Debugf("HandleCheckTcpHeart begin key: %s", key)
defer t.Clients[key].C.Close()
go func() { go func() {
for { for {
select { select {
@@ -298,4 +297,5 @@ func (t *TcpClient) HandleCheckTcpHeart(key string) {
//} //}
} }
}() }()
t.Clients[key].C.Close()
} }