"github.com/vapor/p2p/discover/dht"
"github.com/vapor/p2p/discover/mdns"
"github.com/vapor/p2p/netutil"
- "github.com/vapor/p2p/signlib"
security "github.com/vapor/p2p/security"
+ "github.com/vapor/p2p/signlib"
"github.com/vapor/version"
)
const (
logModule = "p2p"
- minNumOutboundPeers = 4
+ minNumOutboundPeers = 3
maxNumLANPeers = 5
//magicNumber used to generate unique netID
magicNumber = uint64(0x054c5638)
}
peer := newPeer(pc, peerNodeInfo, sw.reactorsByCh, sw.chDescs, sw.StopPeerForError, isLAN)
- if err := sw.security.DoFilter(peer.remoteAddrHost(), peer.PubKey()); err != nil {
+ if err := sw.security.DoFilter(peer.RemoteAddrHost(), peer.PubKey()); err != nil {
return err
}
func (sw *Switch) dialPeers(addresses []*NetAddress) {
connectedPeers := make(map[string]struct{})
for _, peer := range sw.Peers().List() {
- connectedPeers[peer.remoteAddrHost()] = struct{}{}
+ connectedPeers[peer.RemoteAddrHost()] = struct{}{}
}
var wg sync.WaitGroup