status-im
/
ethereumj-personal
mirror of https://github.com/status-im/ethereumj-personal.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

fixing block request stops after queue buffer filled up

This commit is contained in:
romanman 2014-12-01 22:35:23 +01:00
parent 2c9161dead
commit a2c0d28a13
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ethereumj-core/src/main/java/org/ethereum/net/eth/EthHandler.java
View File

@ -377,7 +377,17 @@ public class EthHandler extends SimpleChannelInboundHandler<EthMessage> {
// Parallel download blocks based on hashQueue // Parallel download blocks based on hashQueue
private void sendGetBlocks() { private void sendGetBlocks() {
BlockQueue queue = blockchain.getQueue(); BlockQueue queue = blockchain.getQueue();
if (queue.size() > CONFIG.maxBlocksQueued()) return; if (queue.size() > CONFIG.maxBlocksQueued()){
logger.info("postpone asking for blocks: queue: {}", queue.size());
getBlocksTimer.schedule(new TimerTask() {
@Override
public void run() {
sendGetBlocks();
}
}, 100);
return;
}
// retrieve list of block hashes from queue // retrieve list of block hashes from queue
// save them locally in case the remote peer // save them locally in case the remote peer