mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-08-01 16:57:28 +00:00
Swap TcpID
without overwriting it
This commit is contained in:
parent
d0f0e187cb
commit
3ca6437320
@ -41,16 +41,18 @@ type TcpID struct {
|
||||
Ident string
|
||||
}
|
||||
|
||||
func (t *TcpID) Swap() {
|
||||
func (t *TcpID) Swap() *TcpID {
|
||||
srcIP := t.SrcIP
|
||||
dstIP := t.DstIP
|
||||
srcPort := t.SrcPort
|
||||
dstPort := t.DstPort
|
||||
|
||||
t.SrcIP = dstIP
|
||||
t.SrcPort = dstPort
|
||||
t.DstIP = srcIP
|
||||
t.DstPort = srcPort
|
||||
return &TcpID{
|
||||
SrcIP: dstIP,
|
||||
SrcPort: dstPort,
|
||||
DstIP: srcIP,
|
||||
DstPort: srcPort,
|
||||
}
|
||||
}
|
||||
|
||||
type GenericMessage struct {
|
||||
|
@ -89,8 +89,7 @@ func (d dissecting) Dissect(b *bufio.Reader, isClient bool, tcpID *api.TcpID, em
|
||||
}
|
||||
success = true
|
||||
} else if isClient {
|
||||
tcpID.Swap()
|
||||
err = handleHTTP1ClientStream(b, tcpID, emitter)
|
||||
err = handleHTTP1ClientStream(b, tcpID.Swap(), emitter)
|
||||
if err == io.EOF || err == io.ErrUnexpectedEOF {
|
||||
break
|
||||
} else if err != nil {
|
||||
|
Loading…
Reference in New Issue
Block a user