LBRYCommunity/lbcd
1
0
Fork 0
Code Issues 17 Pull requests 4 Projects Releases 28 Packages Wiki Activity

Update a few comments.

Browse source
This commit is contained in:
Dave Collins 2013-09-29 15:26:03 -05:00
parent 9880cf4646
commit ea256aeb5a
1 changed files with 7 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
blockmanager.go
View file

@ -118,12 +118,11 @@ func (b *blockManager) startSync(peers *list.List) {
bestPeer.PushGetBlocksMsg(locator, &zeroHash) bestPeer.PushGetBlocksMsg(locator, &zeroHash)
b.syncPeer = bestPeer b.syncPeer = bestPeer
} }
} }
// handleNewCandidateMsg deals with new peers that have signalled they may // handleNewCandidateMsg deals with new peers that have signalled they may
// be considered as a sync peer (they have already successfully negotiated). It // be considered as a sync peer (they have already successfully negotiated). It
// also start syncing if needed. It is invoked from the syncHandler goroutine. // also starts syncing if needed. It is invoked from the syncHandler goroutine.
func (b *blockManager) handleNewCandidateMsg(peers *list.List, p *peer) { func (b *blockManager) handleNewCandidateMsg(peers *list.List, p *peer) {
// Ignore if in the process of shutting down. // Ignore if in the process of shutting down.
if b.shutdown { if b.shutdown {
@ -390,13 +389,12 @@ out:
log.Trace("[BMGR] Block handler done") log.Trace("[BMGR] Block handler done")
} }
// handleNotifyMsg handles notifications from btcchain. Currently it doesn't // handleNotifyMsg handles notifications from btcchain. It does things such
// respond to any notifications, but the idea is that it requests missing blocks // as request orphan block parents and relay accepted blocks to connected peers.
// in response to orphan notifications and updates the wallet for blocks
// connected to and disconnected from the main chain.
func (b *blockManager) handleNotifyMsg(notification *btcchain.Notification) { func (b *blockManager) handleNotifyMsg(notification *btcchain.Notification) {
switch notification.Type { switch notification.Type {
// An orphan block has been accepted by the block chain. // An orphan block has been accepted by the block chain. Request
// its parents from the peer that sent it.
case btcchain.NTOrphanBlock: case btcchain.NTOrphanBlock:
b.blockPeerMutex.Lock() b.blockPeerMutex.Lock()
defer b.blockPeerMutex.Unlock() defer b.blockPeerMutex.Unlock()
@ -412,13 +410,13 @@ func (b *blockManager) handleNotifyMsg(notification *btcchain.Notification) {
} }
peer.PushGetBlocksMsg(locator, orphanRoot) peer.PushGetBlocksMsg(locator, orphanRoot)
delete(b.blockPeer, *orphanRoot) delete(b.blockPeer, *orphanRoot)
break
} else { } else {
log.Warnf("Notification for orphan %v with no peer", log.Warnf("Notification for orphan %v with no peer",
orphanHash) orphanHash)
} }
// A block has been accepted into the block chain. // A block has been accepted into the block chain. Relay it to other
// peers.
case btcchain.NTBlockAccepted: case btcchain.NTBlockAccepted:
block, ok := notification.Data.(*btcutil.Block) block, ok := notification.Data.(*btcutil.Block)
if !ok { if !ok {