Merge pull request openshift-kni#17 from fedepaol/sctp_tester

Move the sctptester source code from baremetal deploy repo to here.

Author: openshift-merge-robot

functests/sctp/sctp.go

@@ -28,7 +28,7 @@ var testerImage string
 func init() {
 	testerImage = os.Getenv("SCTPTEST_IMAGE")
 	if testerImage == "" {
-		testerImage = "fedepaol/sctptest:v1.1"
+		testerImage = "quay.io/fpaoline/sctptester:v1.0"
 	}
 }
 
@@ -200,7 +200,7 @@ func jobForNode(name, node, app string, cmd []string, args []string) *k8sv1.Pod
 			Containers: []k8sv1.Container{
 				{
 					Name:    name,
-					Image:   "quay.io/wcaban/net-toolbox:latest",
+					Image:   testerImage,
 					Command: cmd,
 					Args:    args,
 				},

go.mod

@@ -6,6 +6,7 @@ require (
 	github.com/ghodss/yaml v1.0.0
 	github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b
 	github.com/imdario/mergo v0.3.8 // indirect
+	github.com/ishidawataru/sctp v0.0.0-20180918013207-6e2cb1366111
 	github.com/onsi/ginkgo v1.10.3
 	github.com/onsi/gomega v1.7.1
 	github.com/openshift/api v3.9.1-0.20191213091414-3fbf6bcf78e8+incompatible // indirect

go.sum

@@ -390,6 +390,7 @@ github.com/imdario/mergo v0.3.7/go.mod h1:2EnlNZ0deacrJVfApfmtdGgDfMuh/nq6Ok1EcJ
 github.com/imdario/mergo v0.3.8 h1:CGgOkSJeqMRmt0D9XLWExdT4m4F1vd3FV3VPt+0VxkQ=
 github.com/imdario/mergo v0.3.8/go.mod h1:2EnlNZ0deacrJVfApfmtdGgDfMuh/nq6Ok1EcJh5FfA=
 github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
+github.com/ishidawataru/sctp v0.0.0-20180918013207-6e2cb1366111 h1:NAAiV9ass6VReWFjuxqrMIq12WKlSULI6Gs3PxQghLA=
 github.com/ishidawataru/sctp v0.0.0-20180918013207-6e2cb1366111/go.mod h1:DM4VvS+hD/kDi1U1QsX2fnZowwBhqD0Dk3bRPKF/Oc8=
 github.com/j-keck/arping v0.0.0-20160618110441-2cf9dc699c56/go.mod h1:ymszkNOg6tORTn+6F6j+Jc8TOr5osrynvN6ivFWZ2GA=
 github.com/jellevandenhooff/dkim v0.0.0-20150330215556-f50fe3d243e1/go.mod h1:E0B/fFc00Y+Rasa88328GlI/XbtyysCtTHZS8h7IrBU=

tools/sctptester/Dockerfile

@@ -0,0 +1,12 @@
+
+FROM golang:1.13 AS builder
+WORKDIR /gotest
+COPY . .
+RUN go mod init github.com/openshift-kni/cnf-features-deploy/sctptester
+RUN go get
+RUN go build -o sctptest
+
+FROM centos:7
+COPY --from=builder /gotest/sctptest /usr/bin/sctptest
+RUN yum install -y lksctp-tools
+CMD ["/usr/bin/sctptest"]

tools/sctptester/main.go

@@ -0,0 +1,84 @@
+package main
+
+import (
+	"flag"
+	"log"
+	"net"
+
+	"github.com/ishidawataru/sctp"
+)
+
+func main() {
+	var server = flag.Bool("server", false, "")
+	var ip = flag.String("ip", "0.0.0.0", "")
+	var port = flag.Int("port", 0, "")
+	var lport = flag.Int("lport", 0, "")
+
+	flag.Parse()
+
+	if *server {
+		doServer(*ip, *port)
+	} else {
+		doClient(*ip, *port, *lport)
+	}
+
+}
+
+func doClient(serverAddr string, port int, localport int) {
+	address, err := net.ResolveIPAddr("ip", serverAddr)
+
+	server := &sctp.SCTPAddr{
+		IPAddrs: []net.IPAddr{*address},
+		Port:    port,
+	}
+
+	var laddr *sctp.SCTPAddr
+	if localport != 0 {
+		laddr = &sctp.SCTPAddr{
+			Port: localport,
+		}
+	}
+	conn, err := sctp.DialSCTP("sctp", laddr, server)
+	if err != nil {
+		log.Fatalf("failed to dial: %v", err)
+	}
+
+	log.Printf("Dail LocalAddr: %s; RemoteAddr: %s", conn.LocalAddr(), conn.RemoteAddr())
+	info := sctp.SndRcvInfo{
+		Stream: uint16(0),
+		PPID:   uint32(0),
+	}
+
+	n, err := conn.SCTPWrite([]byte("hello"), &info)
+	if err != nil {
+		log.Fatalf("failed to write: %v", err)
+	}
+	log.Printf("write: len %d", n)
+
+}
+
+func doServer(serverAddr string, port int) {
+	address, err := net.ResolveIPAddr("ip", serverAddr)
+
+	listenAddr := &sctp.SCTPAddr{
+		IPAddrs: []net.IPAddr{*address},
+		Port:    port,
+	}
+	ln, err := sctp.ListenSCTP("sctp", listenAddr)
+	if err != nil {
+		log.Fatalf("failed to listen: %v", err)
+	}
+	log.Printf("Listen on %s", ln.Addr())
+
+	conn, err := ln.Accept()
+	if err != nil {
+		log.Fatalf("failed to accept: %v", err)
+	}
+	log.Printf("Accepted Connection from RemoteAddr: %s", conn.RemoteAddr())
+	buf := make([]byte, 512)
+	n, err := conn.Read(buf)
+	if err != nil {
+		log.Fatalf("read failed: %v", err)
+	}
+	log.Printf("Received: %s", string(buf[:n]))
+}