From 3ee2c48a1d5599c4e6754636d1755b1e1e897301 Mon Sep 17 00:00:00 2001 From: Dimitri Sokolyuk Date: Sun, 27 Aug 2017 17:22:56 +0200 Subject: Add vendor --- vendor/github.com/tarm/serial/basic_test.go | 69 +++++++++++++++++++++++++++++ 1 file changed, 69 insertions(+) create mode 100644 vendor/github.com/tarm/serial/basic_test.go (limited to 'vendor/github.com/tarm/serial/basic_test.go') diff --git a/vendor/github.com/tarm/serial/basic_test.go b/vendor/github.com/tarm/serial/basic_test.go new file mode 100644 index 0000000..7b9af3e --- /dev/null +++ b/vendor/github.com/tarm/serial/basic_test.go @@ -0,0 +1,69 @@ +// +build linux + +package serial + +import ( + "os" + "testing" + "time" +) + +func TestConnection(t *testing.T) { + port0 := os.Getenv("PORT0") + port1 := os.Getenv("PORT1") + if port0 == "" || port1 == "" { + t.Skip("Skipping test because PORT0 or PORT1 environment variable is not set") + } + c0 := &Config{Name: port0, Baud: 115200} + c1 := &Config{Name: port1, Baud: 115200} + + s1, err := OpenPort(c0) + if err != nil { + t.Fatal(err) + } + + s2, err := OpenPort(c1) + if err != nil { + t.Fatal(err) + } + + ch := make(chan int, 1) + go func() { + buf := make([]byte, 128) + var readCount int + for { + n, err := s2.Read(buf) + if err != nil { + t.Fatal(err) + } + readCount++ + t.Logf("Read %v %v bytes: % 02x %s", readCount, n, buf[:n], buf[:n]) + select { + case <-ch: + ch <- readCount + close(ch) + default: + } + } + }() + + if _, err = s1.Write([]byte("hello")); err != nil { + t.Fatal(err) + } + if _, err = s1.Write([]byte(" ")); err != nil { + t.Fatal(err) + } + time.Sleep(time.Second) + if _, err = s1.Write([]byte("world")); err != nil { + t.Fatal(err) + } + time.Sleep(time.Second / 10) + + ch <- 0 + s1.Write([]byte(" ")) // We could be blocked in the read without this + c := <-ch + exp := 5 + if c >= exp { + t.Fatalf("Expected less than %v read, got %v", exp, c) + } +} -- cgit v1.2.3