@@ -1438,7 +1438,7 @@ var _ = SkipDescribeIf(helpers.DoesNotRunOn54OrLaterKernel,
14381438 // Test must run with KPR enabled, see below comments.
14391439 Context ("Validate toEntities KubeAPIServer" , func () {
14401440 var (
1441- k8s1Name , k8s1IP string
1441+ k8s1IP string
14421442 k8s1PodName , k8s2PodName string
14431443 k8s1PodIP , k8s2PodIP string
14441444 outsideNodeName string
@@ -1477,7 +1477,7 @@ var _ = SkipDescribeIf(helpers.DoesNotRunOn54OrLaterKernel,
14771477 testNamespace ,
14781478 fmt .Sprintf ("-l %s" , testDS ), helpers .HelperTimeout ),
14791479 ).Should (BeNil ())
1480- k8s1Name , k8s1IP = kubectl .GetNodeInfo (helpers .K8s1 )
1480+ _ , k8s1IP = kubectl .GetNodeInfo (helpers .K8s1 )
14811481 k8s1PodName , k8s1PodIP = kubectl .GetPodOnNodeLabeledWithOffset (helpers .K8s1 , testDS , 0 )
14821482 k8s2PodName , k8s2PodIP = kubectl .GetPodOnNodeLabeledWithOffset (helpers .K8s2 , testDS , 0 )
14831483 if helpers .ExistNodeWithoutCilium () {
@@ -1506,52 +1506,6 @@ var _ = SkipDescribeIf(helpers.DoesNotRunOn54OrLaterKernel,
15061506 expectHostSuccess , expectRemoteNodeSuccess , expectPodSuccess , expectWorldSuccess bool ,
15071507 ) {
15081508 var wg sync.WaitGroup
1509- wg .Add (1 )
1510- go func () {
1511- defer GinkgoRecover ()
1512- defer wg .Done ()
1513- switch helpers .GetCurrentIntegration () {
1514- case helpers .CIIntegrationEKS , helpers .CIIntegrationEKSChaining :
1515- By ("Checking ingress connectivity from k8s1 node to k8s1 pod (host)" )
1516- default :
1517- // We need to bypass this check as in a non-managed
1518- // environment like kind, the kube-apiserver is
1519- // running locally on K8s1. This means that local host
1520- // traffic cannot be disambiguated from kube-apiserver
1521- // traffic.
1522- By ("Bypassing check for ingress connectivity for host, which cannot be done in non-managed environments" )
1523- return
1524- }
1525- res := kubectl .ExecInHostNetNS (context .TODO (), k8s1Name ,
1526- helpers .CurlFail (k8s1PodIP ))
1527- ExpectWithOffset (1 , res ).To (getMatcher (expectHostSuccess ),
1528- "HTTP ingress connectivity to pod %q from local host" , k8s1PodIP )
1529- }()
1530-
1531- wg .Add (1 )
1532- go func () {
1533- defer GinkgoRecover ()
1534- defer wg .Done ()
1535- switch helpers .GetCurrentIntegration () {
1536- case helpers .CIIntegrationEKS , helpers .CIIntegrationEKSChaining :
1537- By ("Checking ingress connectivity from k8s1 node to k8s2 pod (remote-node)" )
1538- default :
1539- // We need to bypass this check as in a two node
1540- // cluster, the kube-apiserver will be running on at
1541- // least one of the two nodes, which means that any
1542- // traffic to or from will be considered to / from
1543- // kube-apiserver, and not remote-node. If we had a
1544- // third node with Cilium installed, then we wouldn't
1545- // need to bypass this check.
1546- By ("Bypassing check for ingress connectivity for remote-node, which cannot be done in a two-node cluster" )
1547- return
1548- }
1549- res := kubectl .ExecInHostNetNS (context .TODO (), k8s1Name ,
1550- helpers .CurlFail (k8s2PodIP ))
1551- ExpectWithOffset (1 , res ).To (getMatcher (expectRemoteNodeSuccess ),
1552- "HTTP ingress connectivity to pod %q from remote node" , k8s2PodIP )
1553- }()
1554-
15551509 wg .Add (1 )
15561510 go func () {
15571511 defer GinkgoRecover ()
0 commit comments