mirror of
https://github.com/nspcc-dev/neo-go.git
synced 2024-12-04 19:19:44 +00:00
network: fix tx requests, we can't ask more than 500 txes at once
This commit is contained in:
parent
9756ed2b06
commit
363c24d128
1 changed files with 11 additions and 4 deletions
|
@ -887,10 +887,17 @@ func (s *Server) requestTx(hashes ...util.Uint256) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
msg := s.MkMsg(CMDGetData, payload.NewInventory(payload.TXType, hashes))
|
for i := 0; i < len(hashes)/payload.MaxHashesCount; i++ {
|
||||||
// It's high priority because it directly affects consensus process,
|
start := i * payload.MaxHashesCount
|
||||||
// even though it's getdata.
|
stop := (i + 1) * payload.MaxHashesCount
|
||||||
s.broadcastHPMessage(msg)
|
if stop < len(hashes) {
|
||||||
|
stop = len(hashes)
|
||||||
|
}
|
||||||
|
msg := s.MkMsg(CMDGetData, payload.NewInventory(payload.TXType, hashes[start:stop]))
|
||||||
|
// It's high priority because it directly affects consensus process,
|
||||||
|
// even though it's getdata.
|
||||||
|
s.broadcastHPMessage(msg)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// iteratePeersWithSendMsg sends given message to all peers using two functions
|
// iteratePeersWithSendMsg sends given message to all peers using two functions
|
||||||
|
|
Loading…
Reference in a new issue