diff --git a/plugSrc/mysql/build/entry.go b/plugSrc/mysql/build/entry.go index 563acee..4a1ba39 100644 --- a/plugSrc/mysql/build/entry.go +++ b/plugSrc/mysql/build/entry.go @@ -188,13 +188,12 @@ func (stm *stream) resolve() { for { select { case packet := <- stm.packets: - if packet.length == 0 { - break - } - if packet.isClientFlow { - stm.resolveClientPacket(packet.payload, packet.seq) - } else { - stm.resolveServerPacket(packet.payload, packet.seq) + if packet.length != 0 { + if packet.isClientFlow { + stm.resolveClientPacket(packet.payload, packet.seq) + } else { + stm.resolveServerPacket(packet.payload, packet.seq) + } } } }