blockpool: fix removePeer bug

This commit is contained in:
Ethan Buchman 2017-04-15 02:22:03 -04:00
parent 585ce45a5e
commit 00847cdc6b
1 changed files with 3 additions and 1 deletions

View File

@ -240,7 +240,9 @@ func (pool *BlockPool) RemovePeer(peerID string) {
func (pool *BlockPool) removePeer(peerID string) {
for _, requester := range pool.requesters {
if requester.getPeerID() == peerID {
if requester.getBlock() != nil {
pool.numPending++
}
go requester.redo() // pick another peer and ...
}
}