collab/hmq
3
0
Fork 0
mirror of https://github.com/fhmq/hmq.git synced 2026-04-24 10:38:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

modify readloop

Browse Source
This commit is contained in:
zhouyuyan
2017-09-22 12:08:11 +08:00
parent 4646042b7f
commit eeab0c6b7d
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
broker/client.go
View File

@@ -96,16 +96,12 @@ func (c *client) readLoop(msgPool *MessagePool) {
nowTime = uint16(time.Now().Unix())
if 0 != c.info.keepalive && nowTime-lastIn > c.info.keepalive*3/2 {
log.Errorf("Client %s has exceeded timeout, disconnecting.\n", c.info.clientID)
msg := &Message{client: c, packet: DisconnectdPacket}
msgPool.queue <- msg
return
break
}
packet, err := packets.ReadPacket(nc)
if err != nil {
log.Error("read packet error: ", err)
msg := &Message{client: c, packet: DisconnectdPacket}
msgPool.queue <- msg
return
break
}
// log.Info("recv buf: ", packet)
lastIn = uint16(time.Now().Unix())
@@ -115,6 +111,8 @@ func (c *client) readLoop(msgPool *MessagePool) {
}
msgPool.queue <- msg
}
msg := &Message{client: c, packet: DisconnectdPacket}
msgPool.queue <- msg
msgPool.Reduce()
}