diff --git a/plugSrc/mysql/build/entry.go b/plugSrc/mysql/build/entry.go index 3859fd6..ff73c31 100644 --- a/plugSrc/mysql/build/entry.go +++ b/plugSrc/mysql/build/entry.go @@ -149,7 +149,7 @@ func (m *Mysql) newPacket(net, transport gopacket.Flow, r io.Reader) *packet { length:payload.Len(), payload:payload.Bytes(), } - if transport.Src().String() == strconv.Itoa(Port) { + if transport.Src().String() == strconv.Itoa(m.port) { pk.isClientFlow = false }else{ pk.isClientFlow = true