diff --git a/p2p/switch_test.go b/p2p/switch_test.go index a0d76f11d..14ae01aed 100644 --- a/p2p/switch_test.go +++ b/p2p/switch_test.go @@ -5,7 +5,6 @@ import ( "context" "errors" "fmt" - "io" "io/ioutil" "net" "net/http" @@ -607,9 +606,8 @@ func TestSwitchAcceptRoutine(t *testing.T) { err = sw.Start() require.NoError(t, err) t.Cleanup(func() { - if err := sw.Stop(); err != nil { - t.Error(err) - } + err := sw.Stop() + require.NoError(t, err) }) // 0. check there are no peers @@ -634,7 +632,7 @@ func TestSwitchAcceptRoutine(t *testing.T) { } }(c) } - time.Sleep(10 * time.Millisecond) + time.Sleep(100 * time.Millisecond) assert.Equal(t, cfg.MaxNumInboundPeers, sw.Peers().Size()) // 2. check we close new connections if we already have MaxNumInboundPeers peers @@ -647,7 +645,7 @@ func TestSwitchAcceptRoutine(t *testing.T) { err = conn.SetReadDeadline(time.Now().Add(10 * time.Millisecond)) require.NoError(t, err) _, err = conn.Read(one) - assert.Equal(t, io.EOF, err) + assert.Error(t, err) assert.Equal(t, cfg.MaxNumInboundPeers, sw.Peers().Size()) peer.Stop()