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

EthereumListener update

This commit is contained in:
romanman 2014-08-06 17:31:05 +03:00
parent 628be155e1
commit cbb556c1a9
3 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ethereumj-core/src/main/java/org/ethereum/core/Blockchain.java
View File

@ -147,6 +147,20 @@ public class Blockchain {
if (listener != null)
listener.trace(String.format("Block chain size: [ %d ]", this.getSize()));
EthereumListener ethereumListener = WorldManager.getInstance().getListener();
if (ethereumListener != null)
ethereumListener.onBlock(block);
/*
if (lastBlock.getNumber() >= 30) {
System.out.println("** checkpoint **");
this.close();
WorldManager.getInstance().getRepository().close();
System.exit(1);
}
*/
}
public void processBlock(Block block) {

3
ethereumj-core/src/main/java/org/ethereum/listener/EthereumListener.java
View File

@ -1,5 +1,7 @@
package org.ethereum.listener;
import org.ethereum.core.Block;
/**
* www.ethereumJ.com
*
@ -10,4 +12,5 @@ package org.ethereum.listener;
public interface EthereumListener {
public void trace(String output);
public void onBlock(Block block);
}

4
ethereumj-core/src/main/java/org/ethereum/net/client/EthereumProtocolHandler.java
View File

@ -66,6 +66,7 @@ public class EthereumProtocolHandler extends ChannelInboundHandlerAdapter {
logger.info("Send: " + StaticMessages.HELLO_MESSAGE.toString());
msgQueue.sendMessage(StaticMessages.HELLO_MESSAGE);
sendPing();
// sample for pinging in background
timer.scheduleAtFixedRate(new TimerTask() {
@ -249,6 +250,8 @@ public class EthereumProtocolHandler extends ChannelInboundHandlerAdapter {
RLPList rlpList = RLP.decode2(payload);
GetChainMessage getChainMessage = new GetChainMessage(rlpList);
logger.info(getChainMessage.toString());
if (peerListener != null) peerListener.console(getChainMessage.toString());
}
@ -323,6 +326,7 @@ public class EthereumProtocolHandler extends ChannelInboundHandlerAdapter {
SystemProperties.CONFIG.maxBlocksQueued()) return;
Block lastBlock = WorldManager.getInstance().getBlockchain().getBlockQueue().getLast();
if (lastBlock == null) return;
byte[] hash = lastBlock.getHash();
GetChainMessage chainMessage =