Merge pull request #41 from liu2178855/mysqlPort

fix mysql port bug
This commit is contained in:
Four
2020-10-23 20:30:58 +08:00
committed by GitHub

View File

@@ -149,7 +149,7 @@ func (m *Mysql) newPacket(net, transport gopacket.Flow, r io.Reader) *packet {
length:payload.Len(), length:payload.Len(),
payload:payload.Bytes(), payload:payload.Bytes(),
} }
if transport.Src().String() == strconv.Itoa(Port) { if transport.Src().String() == strconv.Itoa(m.port) {
pk.isClientFlow = false pk.isClientFlow = false
}else{ }else{
pk.isClientFlow = true pk.isClientFlow = true