This commit is contained in:
Jae Kwon 2015-01-14 00:02:34 -08:00
parent 694a10e0a7
commit 44a60a89c6
2 changed files with 5 additions and 2 deletions

View File

@ -132,13 +132,15 @@ func daemon() {
// If seedNode is provided by config, dial out. // If seedNode is provided by config, dial out.
if config.App.GetString("SeedNode") != "" { if config.App.GetString("SeedNode") != "" {
peer, err := n.sw.DialPeerWithAddress(p2p.NewNetAddressString(config.App.GetString("SeedNode"))) addr := p2p.NewNetAddressString(config.App.GetString("SeedNode"))
peer, err := n.sw.DialPeerWithAddress(addr)
if err != nil { if err != nil {
log.Error("Error dialing seed", "error", err) log.Error("Error dialing seed", "error", err)
//n.book.MarkAttempt(addr) //n.book.MarkAttempt(addr)
return return
} else { } else {
log.Info("Connected to seed", "peer", peer) log.Info("Connected to seed", "peer", peer)
n.book.AddAddress(addr, addr)
} }
} }

View File

@ -152,6 +152,7 @@ FOR_LOOP:
func (pexR *PEXReactor) ensurePeers() { func (pexR *PEXReactor) ensurePeers() {
numOutPeers, _, numDialing := pexR.sw.NumPeers() numOutPeers, _, numDialing := pexR.sw.NumPeers()
numToDial := minNumOutboundPeers - (numOutPeers + numDialing) numToDial := minNumOutboundPeers - (numOutPeers + numDialing)
log.Info("Ensure peers", "numOutPeers", numOutPeers, "numDialing", numDialing, "numToDial", numToDial)
if numToDial <= 0 { if numToDial <= 0 {
return return
} }
@ -164,7 +165,7 @@ func (pexR *PEXReactor) ensurePeers() {
var picked *NetAddress var picked *NetAddress
// Try to fetch a new peer 3 times. // Try to fetch a new peer 3 times.
// This caps the maximum number of tries to 3 * numToDial. // This caps the maximum number of tries to 3 * numToDial.
for j := 0; i < 3; j++ { for j := 0; j < 3; j++ {
picked = pexR.book.PickAddress(newBias) picked = pexR.book.PickAddress(newBias)
if picked == nil { if picked == nil {
return return