|
@@ -746,7 +746,7 @@ func TestKeepAlive_Timeout(t *testing.T) {
|
|
server, _ := Server(conn2, testConf())
|
|
server, _ := Server(conn2, testConf())
|
|
defer server.Close()
|
|
defer server.Close()
|
|
|
|
|
|
- clientLogs := captureLogs(client)
|
|
|
|
|
|
+ _ = captureLogs(client) // Client logs aren't part of the test
|
|
serverLogs := captureLogs(server)
|
|
serverLogs := captureLogs(server)
|
|
|
|
|
|
errCh := make(chan error, 1)
|
|
errCh := make(chan error, 1)
|
|
@@ -768,18 +768,10 @@ func TestKeepAlive_Timeout(t *testing.T) {
|
|
t.Fatalf("timeout waiting for timeout")
|
|
t.Fatalf("timeout waiting for timeout")
|
|
}
|
|
}
|
|
|
|
|
|
- if !client.IsClosed() {
|
|
|
|
- t.Fatalf("client should have closed")
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
if !server.IsClosed() {
|
|
if !server.IsClosed() {
|
|
t.Fatalf("server should have closed")
|
|
t.Fatalf("server should have closed")
|
|
}
|
|
}
|
|
|
|
|
|
- if clientLogs.Len() != 0 {
|
|
|
|
- t.Fatalf("client log incorect: %v", clientLogs.logs())
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
if !serverLogs.match([]string{"[ERR] yamux: keepalive failed: i/o deadline reached"}) {
|
|
if !serverLogs.match([]string{"[ERR] yamux: keepalive failed: i/o deadline reached"}) {
|
|
t.Fatalf("server log incorect: %v", serverLogs.logs())
|
|
t.Fatalf("server log incorect: %v", serverLogs.logs())
|
|
}
|
|
}
|