From e87dc671d11dde399813a76425298a5638f510dc Mon Sep 17 00:00:00 2001 From: Mayank Pande Date: Thu, 11 Apr 2024 14:47:12 +0530 Subject: [PATCH] fix: fix for failure --- containers/container.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/containers/container.go b/containers/container.go index 742381fd..fc65e849 100644 --- a/containers/container.go +++ b/containers/container.go @@ -557,7 +557,7 @@ func (c *Container) onConnectionOpen(pid uint32, fd uint64, src, dst netaddr.IPP } actualDst, err := c.getActualDestination(p, src, dst) dstWorkload := c.ip_resolver.ResolveIP(dst.IP().String()) - actualDestWorkload := c.ip_resolver.ResolveActualIP(actualDst.IP().String()) + if ignoreControlPlane(dstWorkload.Name) { klog.Warningf("Ignoring src workload %s, %s \n", dst.IP().String(), dstWorkload.Name) return @@ -582,6 +582,7 @@ func (c *Container) onConnectionOpen(pid uint32, fd uint64, src, dst netaddr.IPP if failed { c.connectsFailed[dst]++ } else { + actualDestWorkload := c.ip_resolver.ResolveActualIP(actualDst.IP().String()) c.connectsSuccessful[AddrPair{src: dst, dst: *actualDst, srcWorkload: srcWorkload, dstWorkload: dstWorkload, actualDestWorkload: actualDestWorkload}]++ connection := &ActiveConnection{