mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-22 22:45:21 +01:00
Code Issues Projects Releases Packages Wiki Activity

Request blocks in case we have not received it

Browse source 
Once we get a new block from BitcoinJ we start a timer and check in 10
seconds if we have received the block from the P2P network. If not we
request it from the seed nodes.
This commit is contained in:
Manfred Karrer 2019-04-16 20:36:58 -05:00
parent 1e991d1b6e
commit 7df35f3ce8
No known key found for this signature in database
GPG key ID: 401250966A6B2C46
1 changed files with 33 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
core/src/main/java/bisq/core/dao/node/lite/LiteNode.java
View file

@ -17,6 +17,7 @@
package bisq.core.dao.node.lite;
import bisq.core.btc.wallet.BsqWalletService;
import bisq.core.dao.node.BsqNode;
import bisq.core.dao.node.explorer.ExportJsonFilesService;
import bisq.core.dao.node.full.RawBlock;
@ -31,6 +32,7 @@ import bisq.core.dao.state.DaoStateSnapshotService;
import bisq.network.p2p.P2PService;
import bisq.network.p2p.network.Connection;
import bisq.common.Timer;
import bisq.common.UserThread;
import com.google.inject.Inject;
@ -48,7 +50,11 @@ import org.jetbrains.annotations.Nullable;
*/
@Slf4j
public class LiteNode extends BsqNode {
private static final int CHECK_FOR_BLOCK_RECEIVED_DELAY_SEC = 10;
private final LiteNodeNetworkService liteNodeNetworkService;
private final BsqWalletService bsqWalletService;
private Timer checkForBlockReceivedTimer;
///////////////////////////////////////////////////////////////////////////////////////////
@ -62,10 +68,12 @@ public class LiteNode extends BsqNode {
DaoStateSnapshotService daoStateSnapshotService,
P2PService p2PService,
LiteNodeNetworkService liteNodeNetworkService,
BsqWalletService bsqWalletService,
ExportJsonFilesService exportJsonFilesService) {
super(blockParser, daoStateService, daoStateSnapshotService, p2PService, exportJsonFilesService);
this.liteNodeNetworkService = liteNodeNetworkService;
this.bsqWalletService = bsqWalletService;
}
@ -78,6 +86,31 @@ public class LiteNode extends BsqNode {
super.onInitialized();
liteNodeNetworkService.start();
bsqWalletService.addNewBestBlockListener(block -> {
int height = block.getHeight();
log.info("New block at height {} from bsqWalletService", height);
// Check if we are done with parsing
if (!daoStateService.isParseBlockChainComplete())
return;
if (checkForBlockReceivedTimer != null) {
// In case we received a new block before out timer gets called we stop the old timer
checkForBlockReceivedTimer.stop();
}
// We expect to receive the new BSQ block from the network shortly after BitcoinJ has been aware of it.
// If we don't receive it we request it manually from seed nodes
checkForBlockReceivedTimer = UserThread.runAfter(() -> {
if (daoStateService.getChainHeight() < height) {
log.warn("We did not receive a block from the network {} seconds after we saw the new block in BicoinJ. " +
"We request from our seed nodes missing blocks from block height {}.",
CHECK_FOR_BLOCK_RECEIVED_DELAY_SEC, daoStateService.getChainHeight());
liteNodeNetworkService.requestBlocks(daoStateService.getChainHeight());
}
}, CHECK_FOR_BLOCK_RECEIVED_DELAY_SEC);
});
}
@Override