diff options
author | Felix Lange <fjl@twurst.com> | 2015-05-08 21:54:35 +0800 |
---|---|---|
committer | Felix Lange <fjl@twurst.com> | 2015-05-08 22:09:54 +0800 |
commit | 914e57e49bea0617515e1935972c5990a222cd7b (patch) | |
tree | 5b3f05c7b3b72e1d35f8fb3900ba49c2491383fa /p2p/handshake_test.go | |
parent | 23454dcfcb75b9e421d0c3bfe67d33ab49633c5c (diff) | |
download | dexon-914e57e49bea0617515e1935972c5990a222cd7b.tar dexon-914e57e49bea0617515e1935972c5990a222cd7b.tar.gz dexon-914e57e49bea0617515e1935972c5990a222cd7b.tar.bz2 dexon-914e57e49bea0617515e1935972c5990a222cd7b.tar.lz dexon-914e57e49bea0617515e1935972c5990a222cd7b.tar.xz dexon-914e57e49bea0617515e1935972c5990a222cd7b.tar.zst dexon-914e57e49bea0617515e1935972c5990a222cd7b.zip |
p2p: fix disconnect at capacity
With the introduction of static/trusted nodes, the peer count
can go above MaxPeers. Update the capacity check to handle this.
While here, decouple the trusted nodes check from the handshake
by passing a function instead.
Diffstat (limited to 'p2p/handshake_test.go')
-rw-r--r-- | p2p/handshake_test.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/p2p/handshake_test.go b/p2p/handshake_test.go index 9018e14f2..ab75921a3 100644 --- a/p2p/handshake_test.go +++ b/p2p/handshake_test.go @@ -141,9 +141,10 @@ func TestSetupConn(t *testing.T) { fd0, fd1 := net.Pipe() done := make(chan struct{}) + keepalways := func(discover.NodeID) bool { return true } go func() { defer close(done) - conn0, err := setupConn(fd0, prv0, hs0, node1, false, nil) + conn0, err := setupConn(fd0, prv0, hs0, node1, keepalways) if err != nil { t.Errorf("outbound side error: %v", err) return @@ -156,7 +157,7 @@ func TestSetupConn(t *testing.T) { } }() - conn1, err := setupConn(fd1, prv1, hs1, nil, false, nil) + conn1, err := setupConn(fd1, prv1, hs1, nil, keepalways) if err != nil { t.Fatalf("inbound side error: %v", err) } |