aa
This commit is contained in:
@@ -275,7 +275,8 @@ func (t *TcpClient) HandleCheckTcpHeart(key string) {
|
|||||||
changePrinterStatus(key, printerStatusOffline)
|
changePrinterStatus(key, printerStatusOffline)
|
||||||
if t.isExist(key) {
|
if t.isExist(key) {
|
||||||
globals.SugarLogger.Debugf("HandleCheckTcpHeart clear...")
|
globals.SugarLogger.Debugf("HandleCheckTcpHeart clear...")
|
||||||
t.clear(key)
|
//t.clear(key)
|
||||||
|
close(t.TimeoutMap[key])
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -288,7 +288,6 @@ func (t *TcpClient) clear(key string) {
|
|||||||
//delete(t.MsgMap, key)
|
//delete(t.MsgMap, key)
|
||||||
//close(t.CallBackMap[key])
|
//close(t.CallBackMap[key])
|
||||||
//delete(t.CallBackMap, key)
|
//delete(t.CallBackMap, key)
|
||||||
close(t.TimeoutMap[key])
|
|
||||||
delete(t.TimeoutMap, key)
|
delete(t.TimeoutMap, key)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user