interesting
/
btc-crawl
mirror of https://github.com/shazow/btc-crawl.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

oops, actually give up when getting error messages.

This commit is contained in:
Andrey Petrov 2014-05-19 15:26:00 -07:00
parent af0d810fac
commit ff50d25820
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
crawler.go
View File

@ -99,6 +99,11 @@ func (c *Crawler) handleAddress(address string) *Result {
// We can't really tell when we're done receiving peers, so we stop either
// when we get a smaller-than-normal set size or when we've received too
// many unrelated messages.
if len(otherMessages) > tolerateMessages {
logger.Debugf("[%s] Giving up with %d results after tolerating messages: %v.", address, len(r.Peers), otherMessages)
return &r
}
msg, _, err := peer.ReadMessage()
if err != nil {
otherMessages = append(otherMessages, err.Error())
@ -118,10 +123,6 @@ func (c *Crawler) handleAddress(address string) *Result {
}
default:
otherMessages = append(otherMessages, tmsg.Command())
if len(otherMessages) > tolerateMessages {
logger.Debugf("[%s] Giving up with %d results after tolerating messages: %v.", address, len(r.Peers), otherMessages)
return &r
}
}
}
}