diff --git a/ethereumj-core/src/main/java/org/ethereum/net/MessageQueue.java b/ethereumj-core/src/main/java/org/ethereum/net/MessageQueue.java index 7c25700c..4962b9db 100644 --- a/ethereumj-core/src/main/java/org/ethereum/net/MessageQueue.java +++ b/ethereumj-core/src/main/java/org/ethereum/net/MessageQueue.java @@ -74,6 +74,7 @@ public class MessageQueue { if (msg.getClass() == waitingMessage.getAnswerMessage()){ messageRoundtrip.answer(); + logger.debug("Message round trip covered: [ {} ] ", messageRoundtrip.getMsg().getMessageName()); } } } diff --git a/ethereumj-core/src/main/java/org/ethereum/net/MessageRoundtrip.java b/ethereumj-core/src/main/java/org/ethereum/net/MessageRoundtrip.java index 4cbf08fc..e29c189d 100644 --- a/ethereumj-core/src/main/java/org/ethereum/net/MessageRoundtrip.java +++ b/ethereumj-core/src/main/java/org/ethereum/net/MessageRoundtrip.java @@ -39,7 +39,7 @@ public class MessageRoundtrip { public void saveTime(){lastTimestamp = System.currentTimeMillis();} public boolean hasToRetry(){ - return 5000 < System.currentTimeMillis() - lastTimestamp; + return 20000 < System.currentTimeMillis() - lastTimestamp; } public Message getMsg() {