Update a few comments.
This commit is contained in:
parent
b97db056c1
commit
f1cd96ceb5
1 changed files with 5 additions and 3 deletions
|
@ -320,8 +320,8 @@ func (b *blockManager) handleInvMsg(imsg *invMsg) {
|
||||||
|
|
||||||
// We already have the final block advertised by this
|
// We already have the final block advertised by this
|
||||||
// inventory message, so force a request for more. This
|
// inventory message, so force a request for more. This
|
||||||
// should only really happen if we're on a really long
|
// should only happen if we're on a really long side
|
||||||
// side chain.
|
// chain.
|
||||||
if i == lastBlock {
|
if i == lastBlock {
|
||||||
// Request blocks after this one up to the
|
// Request blocks after this one up to the
|
||||||
// final one the remote peer knows about (zero
|
// final one the remote peer knows about (zero
|
||||||
|
@ -376,6 +376,8 @@ out:
|
||||||
case bmsg := <-b.blockQueue:
|
case bmsg := <-b.blockQueue:
|
||||||
b.handleBlockMsg(bmsg)
|
b.handleBlockMsg(bmsg)
|
||||||
bmsg.peer.blockProcessed <- true
|
bmsg.peer.blockProcessed <- true
|
||||||
|
|
||||||
|
// Handle new inventory messages.
|
||||||
case imsg := <-b.invQueue:
|
case imsg := <-b.invQueue:
|
||||||
b.handleInvMsg(imsg)
|
b.handleInvMsg(imsg)
|
||||||
|
|
||||||
|
@ -464,7 +466,7 @@ func (b *blockManager) QueueBlock(block *btcutil.Block, p *peer) {
|
||||||
|
|
||||||
// QueueInv adds the passed inv message and peer to the block handling queue.
|
// QueueInv adds the passed inv message and peer to the block handling queue.
|
||||||
func (b *blockManager) QueueInv(inv *btcwire.MsgInv, p *peer) {
|
func (b *blockManager) QueueInv(inv *btcwire.MsgInv, p *peer) {
|
||||||
// No channel handlign ehre because peers do not need to block on inv
|
// No channel handling here because peers do not need to block on inv
|
||||||
// messages.
|
// messages.
|
||||||
if b.shutdown {
|
if b.shutdown {
|
||||||
return
|
return
|
||||||
|
|
Loading…
Reference in a new issue