X-Git-Url: http://git.osdn.net/view?p=bytom%2Fvapor.git;a=blobdiff_plain;f=p2p%2Fswitch.go;h=d3daa7c649b838315b06f144312653e569650c6e;hp=ef8306d331af28474cc0552a73fa61652cc4b055;hb=refs%2Fheads%2Fblock_fetcher;hpb=807d99726f6a0610fa9c835e2aabd983801d3510 diff --git a/p2p/switch.go b/p2p/switch.go index ef8306d3..d3daa7c6 100644 --- a/p2p/switch.go +++ b/p2p/switch.go @@ -19,15 +19,15 @@ import ( "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) @@ -199,7 +199,7 @@ func (sw *Switch) AddPeer(pc *peerConn, isLAN bool) error { } 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 } @@ -419,7 +419,7 @@ func (sw *Switch) dialPeerWorker(a *NetAddress, wg *sync.WaitGroup) { 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