aboutsummaryrefslogtreecommitdiffstats
path: root/swarm/network/stream/syncer_test.go
diff options
context:
space:
mode:
authorJanoš Guljaš <janos@users.noreply.github.com>2018-11-16 04:06:27 +0800
committerViktor Trón <viktor.tron@gmail.com>2018-11-16 04:06:27 +0800
commit324027640bcaf137b8c9e96bc26f0833711497af (patch)
tree5d0dba8509addd3ac1a5c93469ebf2c6c6285086 /swarm/network/stream/syncer_test.go
parentb91766fe6db6e484f2fd75f617307a48ff85600e (diff)
downloaddexon-324027640bcaf137b8c9e96bc26f0833711497af.tar
dexon-324027640bcaf137b8c9e96bc26f0833711497af.tar.gz
dexon-324027640bcaf137b8c9e96bc26f0833711497af.tar.bz2
dexon-324027640bcaf137b8c9e96bc26f0833711497af.tar.lz
dexon-324027640bcaf137b8c9e96bc26f0833711497af.tar.xz
dexon-324027640bcaf137b8c9e96bc26f0833711497af.tar.zst
dexon-324027640bcaf137b8c9e96bc26f0833711497af.zip
swarm/network/simulation: use simulations.Event instead p2p.PeerEvent (#18098)
Diffstat (limited to 'swarm/network/stream/syncer_test.go')
-rw-r--r--swarm/network/stream/syncer_test.go5
1 files changed, 2 insertions, 3 deletions
diff --git a/swarm/network/stream/syncer_test.go b/swarm/network/stream/syncer_test.go
index a543cae05..f4e055451 100644
--- a/swarm/network/stream/syncer_test.go
+++ b/swarm/network/stream/syncer_test.go
@@ -28,7 +28,6 @@ import (
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/node"
- "github.com/ethereum/go-ethereum/p2p"
"github.com/ethereum/go-ethereum/p2p/enode"
"github.com/ethereum/go-ethereum/p2p/simulations/adapters"
"github.com/ethereum/go-ethereum/swarm/log"
@@ -151,13 +150,13 @@ func testSyncBetweenNodes(t *testing.T, nodes, conns, chunkCount int, skipCheck
disconnections := sim.PeerEvents(
context.Background(),
sim.NodeIDs(),
- simulation.NewPeerEventsFilter().Type(p2p.PeerEventTypeDrop),
+ simulation.NewPeerEventsFilter().Drop(),
)
go func() {
for d := range disconnections {
if d.Error != nil {
- log.Error("peer drop", "node", d.NodeID, "peer", d.Event.Peer)
+ log.Error("peer drop", "node", d.NodeID, "peer", d.PeerID)
t.Fatal(d.Error)
}
}