From 7691b33f6a34918ec2e5fdff0e50d1a9ce2aa248 Mon Sep 17 00:00:00 2001
From: Manfred Karrer <mk@nucleo.io>
Date: Fri, 11 Mar 2016 10:28:02 +0100
Subject: [PATCH] Add more logs to republish offer after connection loss,
 increase delay

---
 .../java/io/bitsquare/trade/offer/OpenOfferManager.java    | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/core/src/main/java/io/bitsquare/trade/offer/OpenOfferManager.java b/core/src/main/java/io/bitsquare/trade/offer/OpenOfferManager.java
index 59d1e39cc5..143857b57b 100644
--- a/core/src/main/java/io/bitsquare/trade/offer/OpenOfferManager.java
+++ b/core/src/main/java/io/bitsquare/trade/offer/OpenOfferManager.java
@@ -61,7 +61,7 @@ import static io.bitsquare.util.Validator.nonEmptyStringOf;
 public class OpenOfferManager implements PeerManager.Listener, DecryptedDirectMessageListener {
     private static final Logger log = LoggerFactory.getLogger(OpenOfferManager.class);
 
-    private static final long RETRY_REPUBLISH_DELAY_SEC = Timer.STRESS_TEST ? 1 : 5;
+    private static final long RETRY_REPUBLISH_DELAY_SEC = Timer.STRESS_TEST ? 1 : 10;
     private static final long REPUBLISH_AGAIN_AT_STARTUP_DELAY_SEC = Timer.STRESS_TEST ? 1 : 10;
     private static final long REPUBLISH_INTERVAL_MS = Timer.STRESS_TEST ? 3000 : 2 * Offer.TTL;
     private static final long REFRESH_INTERVAL_MS = Timer.STRESS_TEST ? 1000 : (long) (Offer.TTL * 0.5);
@@ -198,6 +198,7 @@ public class OpenOfferManager implements PeerManager.Listener, DecryptedDirectMe
 
     @Override
     public void onAllConnectionsLost() {
+        log.info("onAllConnectionsLost");
         stopped = true;
         stopPeriodicRefreshOffersTimer();
         stopPeriodicRepublishOffersTimer();
@@ -208,12 +209,14 @@ public class OpenOfferManager implements PeerManager.Listener, DecryptedDirectMe
 
     @Override
     public void onNewConnectionAfterAllConnectionsLost() {
+        log.info("onNewConnectionAfterAllConnectionsLost");
         stopped = false;
         restart();
     }
 
     @Override
     public void onAwakeFromStandby() {
+        log.info("onAwakeFromStandby");
         stopped = false;
         if (!p2PService.getNetworkNode().getAllConnections().isEmpty())
             restart();
@@ -464,7 +467,7 @@ public class OpenOfferManager implements PeerManager.Listener, DecryptedDirectMe
     }
 
     private void restart() {
-        Log.traceCall();
+        log.info("Restart after connection loss");
         if (retryRepublishOffersTimer == null)
             retryRepublishOffersTimer = UserThread.runAfter(() -> {
                 stopped = false;