mirror of
https://github.com/fhmq/hmq.git
synced 2026-05-09 00:50:38 +00:00
Close conn when read connect packet error (#136)
This commit is contained in:
@@ -272,6 +272,7 @@ func (b *Broker) handleConnection(typ int, conn net.Conn) {
|
|||||||
packet, err := packets.ReadPacket(conn)
|
packet, err := packets.ReadPacket(conn)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error("read connect packet error: ", zap.Error(err))
|
log.Error("read connect packet error: ", zap.Error(err))
|
||||||
|
conn.Close()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if packet == nil {
|
if packet == nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user