mirror of
https://github.com/status-im/ethereumj-personal.git
synced 2025-01-22 09:50:17 +00:00
Polish whitespace and imports
- Replace leading tabs with spaces - Add space before opening curly brace - Optimize imports using shared .idea/codeStyleSettings.xml - Do not align assignments on equals sign - Remove unnecessary extra newlines
This commit is contained in:
parent
364e774d4e
commit
8089f6e57c
@ -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;
|
||||||
@ -166,10 +171,11 @@ public class BlockchainImpl implements Blockchain {
|
|||||||
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();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -417,7 +422,6 @@ public class BlockchainImpl implements Blockchain {
|
|||||||
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());
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -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
|
||||||
|
@ -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;
|
||||||
|
@ -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
|
||||||
|
|
||||||
|
@ -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() {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user