github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-18 04:54:54 +00:00
Code Issues Projects Releases Wiki Activity

Track connection using IP+port in server to fix conntrack test flakes

Browse Source 
Signed-off-by: arkadeepsen <arsen@redhat.com>
Co-authored-by: Patryk Diak <pdiak@redhat.com>
This commit is contained in:
arkadeepsen
2025-09-19 20:24:33 +05:30
parent b2f9a821ea
commit d957c90153
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
test/images/regression-issue-74839/main.go
View File

@@ -100,17 +100,18 @@ func probe(ip string) {
log.Printf("tcp packet: %+v, flag: %v, data: %v, addr: %v", pkt, pkt.FlagString(), data, addr)
ipPort := fmt.Sprintf("%s:%d", addr.String(), pkt.DestPort)
if pkt.Flags&SYN != 0 {
pending[addr.String()] = pkt.Seq + 1
pending[ipPort] = pkt.Seq + 1
continue
}
if pkt.Flags&RST != 0 {
log.Println("ERROR: RST received")
}
if pkt.Flags&ACK != 0 {
if seq, ok := pending[addr.String()]; ok {
if seq, ok := pending[ipPort]; ok {
log.Println("connection established")
delete(pending, addr.String())
delete(pending, ipPort)
badPkt := &tcpPacket{
SrcPort: pkt.DestPort,