diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-12-16 18:03:08 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-12-16 18:03:08 +0300 |
| commit | 6b76a30c04cb74dd9a759789f75bba2eea86a1fb (patch) | |
| tree | 802dd014510e6d871a8faa32a4c3073ac8d86fa3 /pkg/test/defer_test.go | |
| parent | 6fed9dd0dd62718f78eca11e30a71c2712636fbd (diff) | |
add defer test
Diffstat (limited to 'pkg/test/defer_test.go')
| -rw-r--r-- | pkg/test/defer_test.go | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/pkg/test/defer_test.go b/pkg/test/defer_test.go new file mode 100644 index 0000000..215e0b1 --- /dev/null +++ b/pkg/test/defer_test.go @@ -0,0 +1,32 @@ +package test + +import ( + "testing" +) + +func TestDeferSocket(t *testing.T) { + c, s := newClientServer(t) + defer closeClientServer(c, s) + + c.Exec("add name T listen,addr=-:0 defer,addr=@[addr]") + + out := xDial(t, "tcp", c.Get("tunnel.T.listen")) + defer out.Close() + + listen := xListen(t, "tcp", "127.0.0.1:0") + defer listen.Close() + + c.Set("addr", listen.Addr()) + + xWrite(t, out, xData) + + in := xAccept(t, listen) + defer in.Close() + + buf := make([]byte, len(xData)) + xReadFull(t, in, buf) + + if r := string(buf); r != xData { + t.Fatalf("wrong reply: send '%s', recv '%s'", xData, r) + } +} |
