1
// Copyright 2012 The Go Authors. All rights reserved.
2
// Use of this source code is governed by a BSD-style
3
// license that can be found in the LICENSE file.
5
// +build darwin dragonfly freebsd linux netbsd openbsd
19
func TestPortForward(t *testing.T) {
20
server := newServer(t)
21
defer server.Shutdown()
22
conn := server.Dial(clientConfig())
25
sshListener, err := conn.Listen("tcp", "localhost:0")
31
sshConn, err := sshListener.Accept()
33
t.Fatalf("listen.Accept failed: %v", err)
36
_, err = io.Copy(sshConn, sshConn)
37
if err != nil && err != io.EOF {
38
t.Fatalf("ssh client copy: %v", err)
43
forwardedAddr := sshListener.Addr().String()
44
tcpConn, err := net.Dial("tcp", forwardedAddr)
46
t.Fatalf("TCP dial failed: %v", err)
49
readChan := make(chan []byte)
51
data, _ := ioutil.ReadAll(tcpConn)
56
data := make([]byte, 100*1000)
58
data[i] = byte(i % 255)
62
for len(sent) < 1000*1000 {
63
// Send random sized chunks
64
m := rand.Intn(len(data))
65
n, err := tcpConn.Write(data[:m])
69
sent = append(sent, data[:n]...)
71
if err := tcpConn.(*net.TCPConn).CloseWrite(); err != nil {
72
t.Errorf("tcpConn.CloseWrite: %v", err)
77
if len(sent) != len(read) {
78
t.Fatalf("got %d bytes, want %d", len(read), len(sent))
80
if bytes.Compare(sent, read) != 0 {
81
t.Fatalf("read back data does not match")
84
if err := sshListener.Close(); err != nil {
85
t.Fatalf("sshListener.Close: %v", err)
88
// Check that the forward disappeared.
89
tcpConn, err = net.Dial("tcp", forwardedAddr)
92
t.Errorf("still listening to %s after closing", forwardedAddr)
96
func TestAcceptClose(t *testing.T) {
97
server := newServer(t)
98
defer server.Shutdown()
99
conn := server.Dial(clientConfig())
101
sshListener, err := conn.Listen("tcp", "localhost:0")
106
quit := make(chan error, 1)
109
c, err := sshListener.Accept()
120
case <-time.After(1 * time.Second):
121
t.Errorf("timeout: listener did not close.")
123
t.Logf("quit as expected (error %v)", err)
127
// Check that listeners exit if the underlying client transport dies.
128
func TestPortForwardConnectionClose(t *testing.T) {
129
server := newServer(t)
130
defer server.Shutdown()
131
conn := server.Dial(clientConfig())
133
sshListener, err := conn.Listen("tcp", "localhost:0")
138
quit := make(chan error, 1)
141
c, err := sshListener.Accept()
150
// It would be even nicer if we closed the server side, but it
151
// is more involved as the fd for that side is dup()ed.
152
server.clientConn.Close()
155
case <-time.After(1 * time.Second):
156
t.Errorf("timeout: listener did not close.")
158
t.Logf("quit as expected (error %v)", err)