From 02c05cbbb78a8c8960386b4519eee829aa49a2c5 Mon Sep 17 00:00:00 2001 From: jingtao01 Date: Thu, 6 Jun 2019 19:01:43 +0800 Subject: [PATCH] update --- plugSrc/mysql/build/entry.go | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) 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) + } } } }