github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #103158 from rajaskakodkar/sctp_test

Browse Source 
Fix "should not mistakenly treat 'protocol: SCTP' as 'protocol: TCP', even if the plugin doesn't support SCTP" test
This commit is contained in:
Kubernetes Prow Robot 2021-06-28 07:59:37 -07:00 committed by GitHub
commit c2882f3142
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
test/e2e/network/netpol/network_policy.go
View File

@ -1064,8 +1064,8 @@ var _ = common.SIGDescribe("Netpol", func() {
// traffic that is supposed to be blocked. // traffic that is supposed to be blocked.
ginkgo.It("should not mistakenly treat 'protocol: SCTP' as 'protocol: TCP', even if the plugin doesn't support SCTP [Feature:NetworkPolicy]", func() { ginkgo.It("should not mistakenly treat 'protocol: SCTP' as 'protocol: TCP', even if the plugin doesn't support SCTP [Feature:NetworkPolicy]", func() {
nsX, _, _, model, k8s := getK8SModel(f) nsX, _, _, model, k8s := getK8SModel(f)
ginkgo.By("Creating a default-deny ingress policy.") ginkgo.By("Creating a default-deny ingress policy.")
// Empty podSelector blocks the entire namespace
policy := GenNetworkPolicyWithNameAndPodSelector("deny-ingress", metav1.LabelSelector{}, SetSpecIngressRules()) policy := GenNetworkPolicyWithNameAndPodSelector("deny-ingress", metav1.LabelSelector{}, SetSpecIngressRules())
CreatePolicy(k8s, policy, nsX) CreatePolicy(k8s, policy, nsX)
@ -1077,7 +1077,7 @@ var _ = common.SIGDescribe("Netpol", func() {
ginkgo.By("Trying to connect to TCP port 81, which should be blocked by the deny-ingress policy.") ginkgo.By("Trying to connect to TCP port 81, which should be blocked by the deny-ingress policy.")
reachability := NewReachability(model.AllPods(), true) reachability := NewReachability(model.AllPods(), true)
reachability.ExpectAllIngress(NewPodString(nsX, "a"), false) reachability.ExpectPeer(&Peer{}, &Peer{Namespace: nsX}, false)
ValidateOrFail(k8s, model, &TestCase{ToPort: 81, Protocol: v1.ProtocolTCP, Reachability: reachability}) ValidateOrFail(k8s, model, &TestCase{ToPort: 81, Protocol: v1.ProtocolTCP, Reachability: reachability})
}) })