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

Merge remote-tracking branch 'origin/master'

This commit is contained in:
Roman Mandeleil 2014-12-29 14:54:23 +02:00
parent f11787ce59 7015d42221
commit 0dd09c4d4c
10 changed files with 82 additions and 93 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ethereumj-core/build.gradle
View File

@ -70,7 +70,7 @@ javadoc {
options.author = true options.author = true
options.header = project.name options.header = project.name
options.addStringOption('Xdoclint:all,-missing', '-quiet') options.addStringOption('Xdoclint:all,-missing', '-quiet')
options.encoding ="UTF-8" options.encoding = "UTF-8"
options.links( options.links(
"http://docs.oracle.com/javase/8/docs/api/", "http://docs.oracle.com/javase/8/docs/api/",
"http://netty.io/4.0/api/" "http://netty.io/4.0/api/"

16
ethereumj-core/src/main/java/org/ethereum/core/BlockchainImpl.java
View File

@ -9,9 +9,12 @@ import org.ethereum.net.BlockQueue;
import org.ethereum.net.server.ChannelManager; import org.ethereum.net.server.ChannelManager;
import org.ethereum.util.AdvancedDeviceUtils; import org.ethereum.util.AdvancedDeviceUtils;
import org.ethereum.vm.ProgramInvokeFactory; import org.ethereum.vm.ProgramInvokeFactory;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.spongycastle.util.encoders.Hex; import org.spongycastle.util.encoders.Hex;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.util.FileSystemUtils; import org.springframework.util.FileSystemUtils;
@ -20,7 +23,9 @@ import java.io.BufferedWriter;
import java.io.File; import java.io.File;
import java.io.FileWriter; import java.io.FileWriter;
import java.io.IOException; import java.io.IOException;
import java.math.BigInteger; import java.math.BigInteger;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
@ -162,14 +167,15 @@ public class BlockchainImpl implements Blockchain {
} }
// cut on the chain got lastBlock + 1 > n // cut on the chain got lastBlock + 1 > n
if (block.getNumber() > bestBlock.getNumber() + 1){ if (block.getNumber() > bestBlock.getNumber() + 1) {
channelManager.ethSync(); channelManager.ethSync();
} }
if (!hasParentOnTheChain(block) && block.getNumber() > bestBlock.getNumber()) {
if (!hasParentOnTheChain(block) && block.getNumber() > bestBlock.getNumber()){ if (1 == 1)
return; // todo: temporary cancel the rollback
if (1==1)return; // todo: temporary cancel the rollback
logger.info("*** Blockchain will rollback and resynchronise now "); logger.info("*** Blockchain will rollback and resynchronise now ");
long rollbackIdx = bestBlock.getNumber() - 30; long rollbackIdx = bestBlock.getNumber() - 30;
@ -233,7 +239,6 @@ public class BlockchainImpl implements Blockchain {
logger.info("Sync done"); logger.info("Sync done");
syncDoneCalled = true; syncDoneCalled = true;
listener.onSyncDone(); listener.onSyncDone();
} }
} }
@ -416,8 +421,7 @@ public class BlockchainImpl implements Blockchain {
if (logger.isDebugEnabled()) if (logger.isDebugEnabled())
logger.debug("block added to the blockChain: index: [{}]", block.getNumber()); logger.debug("block added to the blockChain: index: [{}]", block.getNumber());
if (block.getNumber() % 100 == 0) if (block.getNumber() % 100 == 0)
logger.info("*** Last block added [ #{} ]", block.getNumber()); logger.info("*** Last block added [ #{} ]", block.getNumber());
} }

30
ethereumj-core/src/main/java/org/ethereum/core/Denomination.java
View File

@ -5,14 +5,9 @@ import java.math.BigInteger;
public enum Denomination { public enum Denomination {
WEI(newBigInt(0)), WEI(newBigInt(0)),
ADA(newBigInt(3)),
BABBAGE(newBigInt(6)),
SHANNON(newBigInt(9)),
SZABO(newBigInt(12)), SZABO(newBigInt(12)),
FINNY(newBigInt(15)), FINNEY(newBigInt(15)),
ETHER(newBigInt(18)), ETHER(newBigInt(18));
EINSTEIN(newBigInt(21)),
DOUGLAS(newBigInt(42));
private BigInteger amount; private BigInteger amount;
@ -33,30 +28,15 @@ public enum Denomination {
} }
public static String toFriendlyString(BigInteger value) { public static String toFriendlyString(BigInteger value) {
if(value.compareTo(DOUGLAS.value()) == 1 || value.compareTo(DOUGLAS.value()) == 0) { if (value.compareTo(ETHER.value()) == 1 || value.compareTo(ETHER.value()) == 0) {
return Float.toString(value.divide(DOUGLAS.value()).floatValue()) + " DOUGLAS";
}
else if(value.compareTo(EINSTEIN.value()) == 1 || value.compareTo(EINSTEIN.value()) == 0) {
return Float.toString(value.divide(EINSTEIN.value()).floatValue()) + " EINSTEIN";
}
else if(value.compareTo(ETHER.value()) == 1 || value.compareTo(ETHER.value()) == 0) {
return Float.toString(value.divide(ETHER.value()).floatValue()) + " ETHER"; return Float.toString(value.divide(ETHER.value()).floatValue()) + " ETHER";
} }
else if(value.compareTo(FINNY.value()) == 1 || value.compareTo(FINNY.value()) == 0) { else if(value.compareTo(FINNEY.value()) == 1 || value.compareTo(FINNEY.value()) == 0) {
return Float.toString(value.divide(FINNY.value()).floatValue()) + " FINNY"; return Float.toString(value.divide(FINNEY.value()).floatValue()) + " FINNEY";
} }
else if(value.compareTo(SZABO.value()) == 1 || value.compareTo(SZABO.value()) == 0) { else if(value.compareTo(SZABO.value()) == 1 || value.compareTo(SZABO.value()) == 0) {
return Float.toString(value.divide(SZABO.value()).floatValue()) + " SZABO"; return Float.toString(value.divide(SZABO.value()).floatValue()) + " SZABO";
} }
else if(value.compareTo(SHANNON.value()) == 1 || value.compareTo(SHANNON.value()) == 0) {
return Float.toString(value.divide(SHANNON.value()).floatValue()) + " SHANNON";
}
else if(value.compareTo(BABBAGE.value()) == 1 || value.compareTo(BABBAGE.value()) == 0) {
return Float.toString(value.divide(BABBAGE.value()).floatValue()) + " BABBAGE";
}
else if(value.compareTo(ADA.value()) == 1 || value.compareTo(ADA.value()) == 0) {
return Float.toString(value.divide(ADA.value()).floatValue()) + " ADA";
}
else else
return Float.toString(value.divide(WEI.value()).floatValue()) + " WEI"; return Float.toString(value.divide(WEI.value()).floatValue()) + " WEI";
} }

22
ethereumj-core/src/main/java/org/ethereum/net/BlockQueue.java
View File

@ -65,18 +65,18 @@ public class BlockQueue {
@Autowired @Autowired
Blockchain blockchain; Blockchain blockchain;
public BlockQueue() { public BlockQueue() {
timer.scheduleAtFixedRate(new TimerTask() { timer.scheduleAtFixedRate(new TimerTask() {
public void run() { public void run() {
nudgeQueue(); nudgeQueue();
} }
}, 10, 10); }, 10, 10);
} }
/** /**
* Processing the queue adding blocks to the chain. * Processing the queue adding blocks to the chain.
*/ */
private void nudgeQueue() { private void nudgeQueue() {
try { try {
if (blockReceivedQueue.isEmpty()) if (blockReceivedQueue.isEmpty())
return; return;

2
ethereumj-core/src/main/java/org/ethereum/net/MessageQueue.java
View File

@ -77,7 +77,7 @@ public class MessageQueue {
ctx.close(); ctx.close();
} }
public void receivedMessage(Message msg) throws InterruptedException { public void receivedMessage(Message msg) throws InterruptedException {
worldManager.getListener().trace("[Recv: " + msg + "]"); worldManager.getListener().trace("[Recv: " + msg + "]");

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

@ -164,8 +164,6 @@ public class EthHandler extends SimpleChannelInboundHandler<EthMessage> {
} }
} }
private void processTransactions(TransactionsMessage msg) { private void processTransactions(TransactionsMessage msg) {
Set<Transaction> txSet = msg.getTransactions(); Set<Transaction> txSet = msg.getTransactions();
@ -249,9 +247,6 @@ public class EthHandler extends SimpleChannelInboundHandler<EthMessage> {
private void processBlockHashes(BlockHashesMessage blockHashesMessage) { private void processBlockHashes(BlockHashesMessage blockHashesMessage) {
List<byte[]> receivedHashes = blockHashesMessage.getBlockHashes(); List<byte[]> receivedHashes = blockHashesMessage.getBlockHashes();
// receivedHashes.forEach(hash -> System.out.println(Hex.toHexString(hash)));
BlockQueue chainQueue = blockchain.getQueue(); BlockQueue chainQueue = blockchain.getQueue();
// result is empty, peer has no more hashes // result is empty, peer has no more hashes
@ -285,7 +280,7 @@ public class EthHandler extends SimpleChannelInboundHandler<EthMessage> {
List<Block> blockList = blocksMessage.getBlocks(); List<Block> blockList = blocksMessage.getBlocks();
if (!blockList.isEmpty()){ if (!blockList.isEmpty()) {
Block block = blockList.get(blockList.size()-1); Block block = blockList.get(blockList.size()-1);
if (block.getNumber() > lastBlock.getNumber()) if (block.getNumber() > lastBlock.getNumber())
lastBlock = blockList.get(blockList.size()-1); lastBlock = blockList.get(blockList.size()-1);
@ -513,7 +508,7 @@ public class EthHandler extends SimpleChannelInboundHandler<EthMessage> {
blockchain.getQueue().addHash(hash); blockchain.getQueue().addHash(hash);
} }
public void doSync(){ public void doSync() {
logger.info("Sync force activated, block: {}", lastBlock); logger.info("Sync force activated, block: {}", lastBlock);
syncStatus = SyncSatus.HASH_RETRIEVING; syncStatus = SyncSatus.HASH_RETRIEVING;
setBestHash(lastBlock.getHash()); setBestHash(lastBlock.getHash());

63
ethereumj-core/src/main/java/org/ethereum/net/message/StaticMessages.java
View File

@ -5,7 +5,12 @@ import org.ethereum.crypto.HashUtil;
import org.ethereum.net.client.Capability; import org.ethereum.net.client.Capability;
import org.ethereum.net.eth.EthHandler; import org.ethereum.net.eth.EthHandler;
import org.ethereum.net.eth.GetTransactionsMessage; import org.ethereum.net.eth.GetTransactionsMessage;
import org.ethereum.net.p2p.*; import org.ethereum.net.p2p.DisconnectMessage;
import org.ethereum.net.p2p.GetPeersMessage;
import org.ethereum.net.p2p.HelloMessage;
import org.ethereum.net.p2p.P2pHandler;
import org.ethereum.net.p2p.PingMessage;
import org.ethereum.net.p2p.PongMessage;
import org.ethereum.net.shh.ShhHandler; import org.ethereum.net.shh.ShhHandler;
import org.spongycastle.util.encoders.Hex; import org.spongycastle.util.encoders.Hex;
@ -22,38 +27,38 @@ import java.util.List;
*/ */
public class StaticMessages { public class StaticMessages {
public static final String PEER_ID = Hex.toHexString(HashUtil.randomPeerId()); public static final String PEER_ID = Hex.toHexString(HashUtil.randomPeerId());
public final static PingMessage PING_MESSAGE = new PingMessage(); public final static PingMessage PING_MESSAGE = new PingMessage();
public final static PongMessage PONG_MESSAGE = new PongMessage(); public final static PongMessage PONG_MESSAGE = new PongMessage();
public final static HelloMessage HELLO_MESSAGE = generateHelloMessage(); public final static HelloMessage HELLO_MESSAGE = generateHelloMessage();
public final static GetPeersMessage GET_PEERS_MESSAGE = new GetPeersMessage(); public final static GetPeersMessage GET_PEERS_MESSAGE = new GetPeersMessage();
public final static GetTransactionsMessage GET_TRANSACTIONS_MESSAGE = new GetTransactionsMessage(); public final static GetTransactionsMessage GET_TRANSACTIONS_MESSAGE = new GetTransactionsMessage();
public final static DisconnectMessage DISCONNECT_MESSAGE = new DisconnectMessage(ReasonCode.REQUESTED); public final static DisconnectMessage DISCONNECT_MESSAGE = new DisconnectMessage(ReasonCode.REQUESTED);
public static final byte[] SYNC_TOKEN = Hex.decode("22400891"); public static final byte[] SYNC_TOKEN = Hex.decode("22400891");
private static HelloMessage generateHelloMessage() { private static HelloMessage generateHelloMessage() {
String helloAnnouncement = buildHelloAnnouncement(); String helloAnnouncement = buildHelloAnnouncement();
byte p2pVersion = P2pHandler.VERSION; byte p2pVersion = P2pHandler.VERSION;
List<Capability> capabilities = Arrays.asList( List<Capability> capabilities = Arrays.asList(
new Capability(Capability.ETH, EthHandler.VERSION), new Capability(Capability.ETH, EthHandler.VERSION),
new Capability(Capability.SHH, ShhHandler.VERSION)); new Capability(Capability.SHH, ShhHandler.VERSION));
int listenPort = SystemProperties.CONFIG.listenPort(); int listenPort = SystemProperties.CONFIG.listenPort();
return new HelloMessage(p2pVersion, helloAnnouncement, return new HelloMessage(p2pVersion, helloAnnouncement,
capabilities, listenPort, PEER_ID); capabilities, listenPort, PEER_ID);
} }
private static String buildHelloAnnouncement() { private static String buildHelloAnnouncement() {
String version = SystemProperties.CONFIG.projectVersion(); String version = SystemProperties.CONFIG.projectVersion();
String system = System.getProperty("os.name"); String system = System.getProperty("os.name");
if (system.contains(" ")) if (system.contains(" "))
system = system.substring(0, system.indexOf(" ")); system = system.substring(0, system.indexOf(" "));
if (System.getProperty("java.vm.vendor").contains("Android")) if (System.getProperty("java.vm.vendor").contains("Android"))
system = "Android"; system = "Android";
String phrase = SystemProperties.CONFIG.helloPhrase(); String phrase = SystemProperties.CONFIG.helloPhrase();
return String.format("Ethereum(J)/v%s/%s/%s/Java", version, phrase, system); return String.format("Ethereum(J)/v%s/%s/%s/Java", version, phrase, system);
} }
} }

19
ethereumj-core/src/main/java/org/ethereum/net/p2p/P2pHandler.java
View File

@ -1,7 +1,5 @@
package org.ethereum.net.p2p; package org.ethereum.net.p2p;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import org.ethereum.core.Block; import org.ethereum.core.Block;
import org.ethereum.core.Transaction; import org.ethereum.core.Transaction;
import org.ethereum.manager.WorldManager; import org.ethereum.manager.WorldManager;
@ -16,19 +14,30 @@ import org.ethereum.net.message.StaticMessages;
import org.ethereum.net.peerdiscovery.PeerInfo; import org.ethereum.net.peerdiscovery.PeerInfo;
import org.ethereum.net.shh.ShhHandler; import org.ethereum.net.shh.ShhHandler;
import org.ethereum.net.shh.ShhMessageCodes; import org.ethereum.net.shh.ShhMessageCodes;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope; import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.util.*;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.Timer;
import java.util.TimerTask;
import static org.ethereum.net.message.StaticMessages.*; import static org.ethereum.net.message.StaticMessages.*;
/** /**
* Process the basic protocol messages between every peer on the network. * Process the basic protocol messages between every peer on the network.
* *
@ -277,8 +286,6 @@ public class P2pHandler extends SimpleChannelInboundHandler<P2pMessage> {
return handshakeHelloMessage; return handshakeHelloMessage;
} }
private void startTimers() { private void startTimers() {
// sample for pinging in background // sample for pinging in background

4
ethereumj-core/src/main/java/org/ethereum/net/server/ChannelManager.java
View File

@ -108,9 +108,7 @@ public class ChannelManager {
} }
public void reconnect(){ public void reconnect(){
for (Channel channel : channels){ channels.forEach(c -> c.p2pHandler.sendDisconnect());
channel.p2pHandler.sendDisconnect();
}
} }
public void ethSync() { public void ethSync() {