fix mysql port bug

2020-10-23 20:21:41 +08:00 · 2020-10-23 20:21:41 +08:00 · b7d1ca1b83
parent 045f404de9
commit b7d1ca1b83
1 changed files with 1 additions and 1 deletions
--- 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