1
This commit is contained in:
@@ -105,10 +105,6 @@ func handleConn(c net.Conn) error {
|
|||||||
c.Write([]byte("ok"))
|
c.Write([]byte("ok"))
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if printNo == "120220915001467" {
|
|
||||||
globals.SugarLogger.Debugf("=========heartbeat : %s", utils.Format4Output(heartbeat, false))
|
|
||||||
globals.SugarLogger.Debugf("=========callback : %s", utils.Format4Output(callback, false))
|
|
||||||
}
|
|
||||||
if heartbeat {
|
if heartbeat {
|
||||||
// 证明是心跳
|
// 证明是心跳
|
||||||
Heartbeat(c, t, data, printNo)
|
Heartbeat(c, t, data, printNo)
|
||||||
|
|||||||
@@ -642,11 +642,6 @@ func Heartbeat(c net.Conn, t *TcpClient, data string, printNo string) {
|
|||||||
//4、读打印channel并打印,并切等待回调channel中的消息
|
//4、读打印channel并打印,并切等待回调channel中的消息
|
||||||
//5、修改数据库中打印机状态(没在连接池中说明是重新连接的)
|
//5、修改数据库中打印机状态(没在连接池中说明是重新连接的)
|
||||||
//6、监听心跳时间,超过1分多钟就clear掉
|
//6、监听心跳时间,超过1分多钟就clear掉
|
||||||
if printNo == "120220915001467" {
|
|
||||||
globals.SugarLogger.Debugf("==%s", utils.Format4Output(t, false))
|
|
||||||
globals.SugarLogger.Debugf("=msgMap=%s", utils.Format4Output(t.MsgMap, false))
|
|
||||||
globals.SugarLogger.Debugf("=bool=%s", utils.Format4Output(t.getClients(printNo) == nil, false))
|
|
||||||
}
|
|
||||||
if t.getClients(printNo) == nil {
|
if t.getClients(printNo) == nil {
|
||||||
addConn(c, t, printNo, status)
|
addConn(c, t, printNo, status)
|
||||||
buildAllMap(t, printNo)
|
buildAllMap(t, printNo)
|
||||||
|
|||||||
Reference in New Issue
Block a user