aboutsummaryrefslogtreecommitdiffstats
path: root/whisper/whisper_test.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-04-15 18:01:22 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-04-15 18:01:22 +0800
commit6ceb253f743ec0d2bdd9a676c7f365de2201470c (patch)
treed856a141df93719d98100c2cdd4bf2a08bcd7b2c /whisper/whisper_test.go
parent46ea193a49f60bb54cd5fc083adcc6fdf58dbdaf (diff)
downloadgo-tangerine-6ceb253f743ec0d2bdd9a676c7f365de2201470c.tar.gz
go-tangerine-6ceb253f743ec0d2bdd9a676c7f365de2201470c.tar.zst
go-tangerine-6ceb253f743ec0d2bdd9a676c7f365de2201470c.zip
whisper: use async handshakes to handle blocking peers
Diffstat (limited to 'whisper/whisper_test.go')
-rw-r--r--whisper/whisper_test.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/whisper/whisper_test.go b/whisper/whisper_test.go
index 35e2f0524..554a12cb1 100644
--- a/whisper/whisper_test.go
+++ b/whisper/whisper_test.go
@@ -21,7 +21,7 @@ func startTestCluster(n int) []*Whisper {
}
// Wire all the peers to the root one
for i := 1; i < n; i++ {
- src, dst := bufMsgPipe()
+ src, dst := p2p.MsgPipe()
go whispers[0].handlePeer(nodes[i], src)
go whispers[i].handlePeer(nodes[0], dst)