1
This commit is contained in:
@@ -73,8 +73,6 @@ func handleConn(c net.Conn) error {
|
||||
return err
|
||||
}
|
||||
|
||||
globals.SugarLogger.Debugf("=====buffer := %s", string(buffer))
|
||||
globals.SugarLogger.Debugf("=====buffer := %s", utils.Format4Output(c.LocalAddr(), false))
|
||||
//看是心跳还是打印回调
|
||||
data := hex.EncodeToString(buffer[:n])
|
||||
var (
|
||||
@@ -262,10 +260,10 @@ func doPrint(t *TcpClient, key string) (err error) {
|
||||
}
|
||||
|
||||
if _, err = c.Write(data); err != nil {
|
||||
globals.SugarLogger.Debugf("=====2 %v", err)
|
||||
globals.SugarLogger.Debugf("handleTcpMessages err [%v]", err)
|
||||
//close(t.TimeoutMap[key])
|
||||
delete(t.TimeoutMap, key)
|
||||
//delete(t.TimeoutMap, key)
|
||||
delete(PrintObject, key)
|
||||
} else {
|
||||
//等待回调
|
||||
dataStr := <-t.CallBackMap[key]
|
||||
|
||||
Reference in New Issue
Block a user