From 178f3ae7b0a8103f8f4bbe77f15f1ba63137c590 Mon Sep 17 00:00:00 2001 From: romanman Date: Mon, 14 Jul 2014 21:47:13 +0300 Subject: [PATCH] Fix for bigger retry interval --- ethereumj-core/src/main/java/org/ethereum/net/MessageQueue.java | 1 + .../src/main/java/org/ethereum/net/MessageRoundtrip.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) 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() {