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

Review and fix docs.

Browse source
This commit is contained in:
Mawuli Adzoe 2015-09-24 13:12:04 +00:00
parent 5983c9b98e
commit 03d423cebf
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
blockmanager.go
View file

@ -657,7 +657,7 @@ func (b *blockManager) handleBlockMsg(bmsg *blockMsg) {
b.updateChainState(newestSha, newestHeight) b.updateChainState(newestSha, newestHeight)
// Update this peer's latest block height, for future // Update this peer's latest block height, for future
// potential sync node candidancy. // potential sync node candidacy.
heightUpdate = int32(newestHeight) heightUpdate = int32(newestHeight)
blkShaUpdate = newestSha blkShaUpdate = newestSha
@ -672,7 +672,7 @@ func (b *blockManager) handleBlockMsg(bmsg *blockMsg) {
// Update the block height for this peer. But only send a message to // Update the block height for this peer. But only send a message to
// the server for updating peer heights if this is an orphan or our // the server for updating peer heights if this is an orphan or our
// chain is "current". This avoid sending a spammy amount of messages // chain is "current". This avoids sending a spammy amount of messages
// if we're syncing the chain from scratch. // if we're syncing the chain from scratch.
if blkShaUpdate != nil && heightUpdate != 0 { if blkShaUpdate != nil && heightUpdate != 0 {
bmsg.peer.UpdateLastBlockHeight(heightUpdate) bmsg.peer.UpdateLastBlockHeight(heightUpdate)
@ -922,7 +922,7 @@ func (b *blockManager) handleInvMsg(imsg *invMsg) {
} }
} }
// If this inv contains a block annoucement, and this isn't coming from // If this inv contains a block announcement, and this isn't coming from
// our current sync peer or we're current, then update the last // our current sync peer or we're current, then update the last
// announced block for this peer. We'll use this information later to // announced block for this peer. We'll use this information later to
// update the heights of peers based on blocks we've accepted that they // update the heights of peers based on blocks we've accepted that they
@ -1235,7 +1235,7 @@ func (b *blockManager) handleNotifyMsg(notification *blockchain.Notification) {
r.ntfnMgr.NotifyBlockConnected(block) r.ntfnMgr.NotifyBlockConnected(block)
} }
// If we're maintaing the address index, and it is up to date // If we're maintaining the address index, and it is up to date
// then update it based off this new block. // then update it based off this new block.
if cfg.AddrIndex && b.server.addrIndexer.IsCaughtUp() { if cfg.AddrIndex && b.server.addrIndexer.IsCaughtUp() {
b.server.addrIndexer.UpdateAddressIndex(block) b.server.addrIndexer.UpdateAddressIndex(block)