summaryrefslogtreecommitdiffhomepage
path: root/runsc/container/uds_test_app.go
diff options
context:
space:
mode:
Diffstat (limited to 'runsc/container/uds_test_app.go')
-rw-r--r--runsc/container/uds_test_app.go83
1 files changed, 0 insertions, 83 deletions
diff --git a/runsc/container/uds_test_app.go b/runsc/container/uds_test_app.go
deleted file mode 100644
index bef98ac66..000000000
--- a/runsc/container/uds_test_app.go
+++ /dev/null
@@ -1,83 +0,0 @@
-// Copyright 2018 Google Inc.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-// Binary uds-test-app opens a socket and reads a series of numbers
-// which are then written to an output file.
-package main
-
-import (
- "flag"
- "fmt"
- "log"
- "net"
- "os"
- "strconv"
- "time"
-)
-
-var (
- fileName = flag.String("file", "", "name of output file")
- socketPath = flag.String("socket", "", "path to socket")
-)
-
-func server(listener net.Listener, f *os.File) {
- buf := make([]byte, 16)
-
- for {
- c, err := listener.Accept()
- if err != nil {
- log.Fatal("error accepting connection:", err)
- }
- nr, err := c.Read(buf)
- if err != nil {
- log.Fatal("error reading from buf:", err)
- }
- data := buf[0:nr]
- fmt.Fprintf(f, string(data)+"\n")
- }
-}
-
-func main() {
- flag.Parse()
- if *fileName == "" || *socketPath == "" {
- log.Fatalf("Flags cannot be empty, given: fileName=%s, socketPath=%s", *fileName, *socketPath)
- }
- outputFile, err := os.OpenFile(*fileName, os.O_WRONLY|os.O_CREATE, 0666)
- if err != nil {
- log.Fatal("error opening output file:", err)
- }
-
- socket := *socketPath
- defer os.Remove(socket)
-
- listener, err := net.Listen("unix", socket)
- if err != nil {
- log.Fatal("error listening on socket:", err)
- }
-
- go server(listener, outputFile)
- for i := 0; ; i++ {
-
- conn, err := net.Dial("unix", socket)
- if err != nil {
- log.Fatal("error dialing:", err)
- }
- if _, err := conn.Write([]byte(strconv.Itoa(i))); err != nil {
- log.Fatal("error writing:", err)
- }
- conn.Close()
- time.Sleep(100 * time.Millisecond)
- }
-
-}