poanetwork
/
quorum
mirror of https://github.com/poanetwork/quorum.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

p2p: improve test for peers message 

The test now checks that the number of of addresses is correct
and terminates cleanly.
This commit is contained in:
Felix Lange 2015-01-06 12:15:51 +01:00
parent b0ff946b55
commit 3caa4ad1ba
1 changed files with 43 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
p2p/protocol_test.go
View File

@ -4,6 +4,7 @@ import (
"fmt" "fmt"
"net" "net"
"reflect" "reflect"
"sync"
"testing" "testing"
"github.com/ethereum/go-ethereum/crypto" "github.com/ethereum/go-ethereum/crypto"
@ -36,50 +37,71 @@ func newTestPeer() (peer *Peer) {
} }
func TestBaseProtocolPeers(t *testing.T) { func TestBaseProtocolPeers(t *testing.T) {
cannedPeerList := []*peerAddr{ peerList := []*peerAddr{
{IP: net.ParseIP("1.2.3.4"), Port: 2222, Pubkey: []byte{}}, {IP: net.ParseIP("1.2.3.4"), Port: 2222, Pubkey: []byte{}},
{IP: net.ParseIP("5.6.7.8"), Port: 3333, Pubkey: []byte{}}, {IP: net.ParseIP("5.6.7.8"), Port: 3333, Pubkey: []byte{}},
} }
var ownAddr *peerAddr = &peerAddr{IP: net.ParseIP("1.3.5.7"), Port: 1111, Pubkey: []byte{}} listenAddr := &peerAddr{IP: net.ParseIP("1.3.5.7"), Port: 1111, Pubkey: []byte{}}
rw1, rw2 := MsgPipe() rw1, rw2 := MsgPipe()
defer rw1.Close()
wg := new(sync.WaitGroup)
// run matcher, close pipe when addresses have arrived // run matcher, close pipe when addresses have arrived
addrChan := make(chan *peerAddr, len(cannedPeerList)) numPeers := len(peerList) + 1
addrChan := make(chan *peerAddr)
wg.Add(1)
go func() { go func() {
for _, want := range cannedPeerList { i := 0
got := <-addrChan for got := range addrChan {
t.Logf("got peer: %+v", got) var want *peerAddr
switch {
case i < len(peerList):
want = peerList[i]
case i == len(peerList):
want = listenAddr // listenAddr should be the last thing sent
}
t.Logf("got peer %d/%d: %v", i+1, numPeers, got)
if !reflect.DeepEqual(want, got) { if !reflect.DeepEqual(want, got) {
t.Errorf("mismatch: got %#v, want %#v", got, want) t.Errorf("mismatch: got %+v, want %+v", got, want)
}
i++
if i == numPeers {
break
} }
} }
close(addrChan) if i != numPeers {
var own []*peerAddr t.Errorf("wrong number of peers received: got %d, want %d", i, numPeers)
var got *peerAddr
for got = range addrChan {
own = append(own, got)
} }
if len(own) != 1 || !reflect.DeepEqual(ownAddr, own[0]) { rw1.Close()
t.Errorf("mismatch: peers own address is incorrectly or not given, got %v, want %#v", ownAddr) wg.Done()
}
rw2.Close()
}() }()
// run first peer
// run first peer (in background)
peer1 := newTestPeer() peer1 := newTestPeer()
peer1.ourListenAddr = ownAddr peer1.ourListenAddr = listenAddr
peer1.otherPeers = func() []*Peer { peer1.otherPeers = func() []*Peer {
pl := make([]*Peer, len(cannedPeerList)) pl := make([]*Peer, len(peerList))
for i, addr := range cannedPeerList { for i, addr := range peerList {
pl[i] = &Peer{listenAddr: addr} pl[i] = &Peer{listenAddr: addr}
} }
return pl return pl
} }
go runBaseProtocol(peer1, rw1) wg.Add(1)
go func() {
runBaseProtocol(peer1, rw1)
wg.Done()
}()
// run second peer // run second peer
peer2 := newTestPeer() peer2 := newTestPeer()
peer2.newPeerAddr = addrChan // feed peer suggestions into matcher peer2.newPeerAddr = addrChan // feed peer suggestions into matcher
if err := runBaseProtocol(peer2, rw2); err != ErrPipeClosed { if err := runBaseProtocol(peer2, rw2); err != ErrPipeClosed {
t.Errorf("peer2 terminated with unexpected error: %v", err) t.Errorf("peer2 terminated with unexpected error: %v", err)
} }
// terminate matcher
close(addrChan)
wg.Wait()
} }
func TestBaseProtocolDisconnect(t *testing.T) { func TestBaseProtocolDisconnect(t *testing.T) {