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

Add MerkleBlock deadline to CmdGetData

Browse source
This commit is contained in:
Chris Pacia 2016-12-19 19:28:09 -05:00 • committed by Dave Collins
parent 4f12c97d0f
commit 765ca28711
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
peer/peer.go
View file

@ -1227,8 +1227,9 @@ func (p *Peer) maybeAddDeadline(pendingResponses map[string]time.Time, msgCmd st
pendingResponses[wire.CmdInv] = deadline pendingResponses[wire.CmdInv] = deadline
case wire.CmdGetData: case wire.CmdGetData:
// Expects a block, tx, or notfound message. // Expects a block, merkleblock, tx, or notfound message.
pendingResponses[wire.CmdBlock] = deadline pendingResponses[wire.CmdBlock] = deadline
pendingResponses[wire.CmdMerkleBlock] = deadline
pendingResponses[wire.CmdTx] = deadline pendingResponses[wire.CmdTx] = deadline
pendingResponses[wire.CmdNotFound] = deadline pendingResponses[wire.CmdNotFound] = deadline
@ -1285,10 +1286,13 @@ out:
switch msgCmd := msg.message.Command(); msgCmd { switch msgCmd := msg.message.Command(); msgCmd {
case wire.CmdBlock: case wire.CmdBlock:
fallthrough fallthrough
case wire.CmdMerkleBlock:
fallthrough
case wire.CmdTx: case wire.CmdTx:
fallthrough fallthrough
case wire.CmdNotFound: case wire.CmdNotFound:
delete(pendingResponses, wire.CmdBlock) delete(pendingResponses, wire.CmdBlock)
delete(pendingResponses, wire.CmdMerkleBlock)
delete(pendingResponses, wire.CmdTx) delete(pendingResponses, wire.CmdTx)
delete(pendingResponses, wire.CmdNotFound) delete(pendingResponses, wire.CmdNotFound)