Skip to content

Commit 5555f78

Browse files
add basic pipe test
Signed-off-by: eternal-flame-AD <yume@yumechi.jp>
1 parent c55cc24 commit 5555f78

1 file changed

Lines changed: 39 additions & 0 deletions

File tree

v2/transport/pipe_test.go

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
package transport
2+
3+
import (
4+
"net"
5+
"testing"
6+
)
7+
8+
func TestPipe(t *testing.T) {
9+
listener, _, err := NewListener()
10+
if err != nil {
11+
panic(err)
12+
}
13+
defer listener.Close()
14+
15+
go func() {
16+
conn, err := net.Dial("unix", listener.Addr().String())
17+
if err != nil {
18+
panic(err)
19+
}
20+
conn.Write([]byte("test"))
21+
conn.Close()
22+
}()
23+
24+
accepted, err := listener.Accept()
25+
if err != nil {
26+
panic(err)
27+
}
28+
var buf [1024]byte
29+
n, err := accepted.Read(buf[:])
30+
if err != nil {
31+
panic(err)
32+
}
33+
if string(buf[:n]) != "test" {
34+
panic("expected test, got " + string(buf[:n]))
35+
}
36+
accepted.Write([]byte("test"))
37+
accepted.Close()
38+
39+
}

0 commit comments

Comments
 (0)