stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-29 04:57:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

Server: fix logs in PeerManager

Browse Source 
somehow it doesn't like the format of toString of some objects
This commit is contained in:
Stepan Usatiuk
2025-03-16 00:13:15 +01:00
parent 1fd3b9e5e0
commit be1f5d12c9
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/PeerManager.java
View File

@@ -1,7 +1,6 @@
package com.usatiuk.dhfs.objects.repository; package com.usatiuk.dhfs.objects.repository;
import com.usatiuk.dhfs.objects.PeerId; import com.usatiuk.dhfs.objects.PeerId;
import com.usatiuk.dhfs.objects.transaction.TransactionManager;
import com.usatiuk.dhfs.objects.repository.peerdiscovery.PeerAddress; import com.usatiuk.dhfs.objects.repository.peerdiscovery.PeerAddress;
import com.usatiuk.dhfs.objects.repository.peerdiscovery.PeerDiscoveryDirectory; import com.usatiuk.dhfs.objects.repository.peerdiscovery.PeerDiscoveryDirectory;
import com.usatiuk.dhfs.objects.repository.peersync.PeerInfo; import com.usatiuk.dhfs.objects.repository.peersync.PeerInfo;
@@ -10,6 +9,7 @@ import com.usatiuk.dhfs.objects.repository.peersync.api.PeerSyncApiClientDynamic
import com.usatiuk.dhfs.objects.repository.peertrust.PeerTrustManager; import com.usatiuk.dhfs.objects.repository.peertrust.PeerTrustManager;
import com.usatiuk.dhfs.objects.repository.webapi.AvailablePeerInfo; import com.usatiuk.dhfs.objects.repository.webapi.AvailablePeerInfo;
import com.usatiuk.dhfs.objects.transaction.Transaction; import com.usatiuk.dhfs.objects.transaction.Transaction;
import com.usatiuk.dhfs.objects.transaction.TransactionManager;
import io.quarkus.logging.Log; import io.quarkus.logging.Log;
import io.quarkus.runtime.StartupEvent; import io.quarkus.runtime.StartupEvent;
import io.quarkus.scheduler.Scheduled; import io.quarkus.scheduler.Scheduled;
@@ -68,16 +68,16 @@ public class PeerManager {
.<Callable<Void>>map(host -> () -> { .<Callable<Void>>map(host -> () -> {
try { try {
if (isReachable(host)) if (isReachable(host))
Log.trace("Heartbeat: " + host); Log.tracev("Heartbeat: {0}", host);
else else
Log.debug("Trying to connect to " + host); Log.debugv("Trying to connect to {0}", host);
var bestAddr = selectBestAddress(host.id()); var bestAddr = selectBestAddress(host.id());
if (pingCheck(host, bestAddr)) if (pingCheck(host, bestAddr))
handleConnectionSuccess(host, bestAddr); handleConnectionSuccess(host, bestAddr);
else else
handleConnectionError(host); handleConnectionError(host);
} catch (Exception e) { } catch (Exception e) {
Log.error("Failed to connect to " + host, e); Log.errorv("Failed to connect to {0} because {1}", host, e);
} }
return null; return null;
}).toList(), 30, TimeUnit.SECONDS); //FIXME: }).toList(), 30, TimeUnit.SECONDS); //FIXME:
@@ -112,7 +112,7 @@ public class PeerManager {
if (wasReachable) return; if (wasReachable) return;
Log.info("Connected to " + host); Log.infov("Connected to {0}", host);
// for (var l : _connectedListeners) { // for (var l : _connectedListeners) {
// l.apply(host); // l.apply(host);
@@ -123,7 +123,7 @@ public class PeerManager {
boolean wasReachable = isReachable(host); boolean wasReachable = isReachable(host);
if (wasReachable) if (wasReachable)
Log.info("Lost connection to " + host); Log.infov("Lost connection to {0}", host);
_states.remove(host.id()); _states.remove(host.id());
@@ -140,7 +140,7 @@ public class PeerManager {
return true; return true;
}); });
} catch (Exception ignored) { } catch (Exception ignored) {
Log.debug("Host " + host + " is unreachable: " + ignored.getMessage() + " " + ignored.getCause()); Log.debugv("Host {0} is unreachable: {1}, {2}", host, ignored.getMessage(), ignored.getCause());
return false; return false;
} }
} }