aboutsummaryrefslogtreecommitdiffstats
path: root/p2p/handshake_test.go
diff options
context:
space:
mode:
authorFelix Lange <fjl@twurst.com>2015-05-08 21:54:35 +0800
committerFelix Lange <fjl@twurst.com>2015-05-08 22:09:54 +0800
commit914e57e49bea0617515e1935972c5990a222cd7b (patch)
tree5b3f05c7b3b72e1d35f8fb3900ba49c2491383fa /p2p/handshake_test.go
parent23454dcfcb75b9e421d0c3bfe67d33ab49633c5c (diff)
downloaddexon-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.go5
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)
}