Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

OVN bump to 23.09.0-139 #4271

Merged
merged 2 commits into from
Apr 12, 2024
Merged

OVN bump to 23.09.0-139 #4271

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
26bd3a7
Dockerfile.fedora:bump OVN to 23.09.0-139
bpickard22 Mar 1, 2024
34b1a4b
Service E2Es: ensure pods can communicate using src port equal to nod…
martinkennelly Apr 11, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion dist/images/Dockerfile.fedora
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ USER root

ENV PYTHONDONTWRITEBYTECODE yes

ARG ovnver=ovn-23.09.0-112.fc39
ARG ovnver=ovn-23.09.0-139.fc39
# Automatically populated when using docker buildx
ARG TARGETPLATFORM
ARG BUILDPLATFORM
Expand Down
31 changes: 31 additions & 0 deletions test/e2e/service.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ import (
e2epodoutput "k8s.io/kubernetes/test/e2e/framework/pod/output"
e2erc "k8s.io/kubernetes/test/e2e/framework/rc"
e2eservice "k8s.io/kubernetes/test/e2e/framework/service"
e2eskipper "k8s.io/kubernetes/test/e2e/framework/skipper"
testutils "k8s.io/kubernetes/test/utils"
)

Expand Down Expand Up @@ -72,6 +73,36 @@ var _ = ginkgo.Describe("Services", func() {
udpPort := int32(rand.Intn(1000) + 10000)
udpPortS := fmt.Sprintf("%d", udpPort)

ginkgo.It("Allow connection to an external IP using a source port that is equal to a node port", func() {
const (
nodePort = 31990
connTimeout = "2"
dstIPv4 = "1.1.1.1"
dstPort = "80"
)
if IsIPv6Cluster(f.ClientSet) {
e2eskipper.Skipf("Test requires IPv4 or IPv4 primary dualstack cluster")
}
ginkgo.By("create node port service")
jig := e2eservice.NewTestJig(cs, f.Namespace.Name, serviceName)
_, err := jig.CreateTCPService(context.TODO(), func(svc *v1.Service) {
svc.Spec.Type = v1.ServiceTypeNodePort
svc.Spec.Ports[0].NodePort = nodePort
})
framework.ExpectNoError(err, "failed to create TCP node port service")
ginkgo.By("create pod selected by node port service")
serverPod := e2epod.NewAgnhostPod(f.Namespace.Name, "svc-backend", nil, nil, nil)
serverPod.Labels = jig.Labels
e2epod.NewPodClient(f).CreateSync(context.TODO(), serverPod)
ginkgo.By("create pod which will connect externally")
clientPod := e2epod.NewAgnhostPod(f.Namespace.Name, "client-for-external", nil, nil, nil)
e2epod.NewPodClient(f).CreateSync(context.TODO(), clientPod)
ginkgo.By("connect externally pinning the source port to equal the node port")
_, err = e2ekubectl.RunKubectl(clientPod.Namespace, "exec", clientPod.Name, "--", "nc",
"-p", strconv.Itoa(nodePort), "-z", "-w", connTimeout, dstIPv4, dstPort)
framework.ExpectNoError(err, "expected connection to succeed using source port identical to node port")
})

ginkgo.It("Creates a host-network service, and ensures that host-network pods can connect to it", func() {
namespace := f.Namespace.Name
jig := e2eservice.NewTestJig(cs, namespace, serviceName)
Expand Down
Loading