aboutsummaryrefslogtreecommitdiff
path: root/ssh/session_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'ssh/session_test.go')
-rw-r--r--ssh/session_test.go19
1 files changed, 16 insertions, 3 deletions
diff --git a/ssh/session_test.go b/ssh/session_test.go
index c4b9f0e..521677f 100644
--- a/ssh/session_test.go
+++ b/ssh/session_test.go
@@ -36,7 +36,8 @@ func dial(handler serverType, t *testing.T) *Client {
conn, chans, reqs, err := NewServerConn(c1, &conf)
if err != nil {
- t.Fatalf("Unable to handshake: %v", err)
+ t.Errorf("Unable to handshake: %v", err)
+ return
}
go DiscardRequests(reqs)
@@ -647,10 +648,12 @@ func TestSessionID(t *testing.T) {
User: "user",
}
+ srvErrCh := make(chan error, 1)
go func() {
conn, chans, reqs, err := NewServerConn(c1, serverConf)
+ srvErrCh <- err
if err != nil {
- t.Fatalf("server handshake: %v", err)
+ return
}
serverID <- conn.SessionID()
go DiscardRequests(reqs)
@@ -659,10 +662,12 @@ func TestSessionID(t *testing.T) {
}
}()
+ cliErrCh := make(chan error, 1)
go func() {
conn, chans, reqs, err := NewClientConn(c2, "", clientConf)
+ cliErrCh <- err
if err != nil {
- t.Fatalf("client handshake: %v", err)
+ return
}
clientID <- conn.SessionID()
go DiscardRequests(reqs)
@@ -671,6 +676,14 @@ func TestSessionID(t *testing.T) {
}
}()
+ if err := <-srvErrCh; err != nil {
+ t.Fatalf("server handshake: %v", err)
+ }
+
+ if err := <-cliErrCh; err != nil {
+ t.Fatalf("client handshake: %v", err)
+ }
+
s := <-serverID
c := <-clientID
if bytes.Compare(s, c) != 0 {