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

adding fix

This commit is contained in:
romanman 2014-10-13 09:32:16 -05:00 committed by nicksavers
parent 54aaa14d05
commit e386520856
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -220,7 +220,7 @@ public class EthHandler extends SimpleChannelInboundHandler<EthMessage> {
} }
private void sendStatus() { private void sendStatus() {
byte protocolVersion = 33, networkId = 0; byte protocolVersion = CONFIG.protocolVersion(), networkId = 0;
BigInteger totalDifficulty = this.blockchain.getTotalDifficulty(); BigInteger totalDifficulty = this.blockchain.getTotalDifficulty();
byte[] bestHash = this.blockchain.getLatestBlockHash(); byte[] bestHash = this.blockchain.getLatestBlockHash();
StatusMessage msg = new StatusMessage(protocolVersion, networkId, StatusMessage msg = new StatusMessage(protocolVersion, networkId,

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

@ -129,7 +129,7 @@ public class P2pHandler extends SimpleChannelInboundHandler<P2pMessage> {
} }
private void processPeers(ChannelHandlerContext ctx, PeersMessage peersMessage) { private void processPeers(ChannelHandlerContext ctx, PeersMessage peersMessage) {
// WorldManager.getInstance().getPeerDiscovery().addPeers(peersMessage.getPeers()); WorldManager.getInstance().getPeerDiscovery().addPeers(peersMessage.getPeers());
} }
private void sendPeers() { private void sendPeers() {

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

@ -80,7 +80,7 @@ public class HelloMessage extends P2pMessage {
byte[] clientId = RLP.encodeString(this.clientId); byte[] clientId = RLP.encodeString(this.clientId);
byte[][] capabilities = new byte[this.capabilities.size()][]; byte[][] capabilities = new byte[this.capabilities.size()][];
for (int i = 0; i < this.capabilities.size(); i++) { for (int i = 0; i < this.capabilities.size(); i++) {
capabilities[i] = RLP.encode(this.capabilities.get(i).getBytes()); capabilities[i] = RLP.encodeElement(this.capabilities.get(i).getBytes());
} }
byte[] capabilityList = RLP.encodeList(capabilities); byte[] capabilityList = RLP.encodeList(capabilities);
byte[] peerPort = RLP.encodeInt(this.listenPort); byte[] peerPort = RLP.encodeInt(this.listenPort);