diff --git a/netsync/manager.go b/netsync/manager.go index 3215a86a..cac40e5a 100644 --- a/netsync/manager.go +++ b/netsync/manager.go @@ -1392,6 +1392,7 @@ out: isOrphan: false, err: err, } + continue out } msg.reply <- processBlockResponse{ @@ -1642,7 +1643,7 @@ func (sm *SyncManager) SyncPeerID() int32 { // ProcessBlock makes use of ProcessBlock on an internal instance of a block // chain. func (sm *SyncManager) ProcessBlock(block *btcutil.Block, flags blockchain.BehaviorFlags) (bool, error) { - reply := make(chan processBlockResponse, 1) + reply := make(chan processBlockResponse) sm.msgChan <- processBlockMsg{block: block, flags: flags, reply: reply} response := <-reply return response.isOrphan, response.err