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

little fixes 8

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-06-21 23:52:14 +02:00
parent 0a9f3f4e1f
commit bc6fa41b5d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/main/java/com/usatiuk/dhfs/storage/objects/repository/distributed/RemoteHostManager.java
View File

@@ -60,7 +60,6 @@ public class RemoteHostManager {
} }
public void handleConnectionSuccess(String host) { public void handleConnectionSuccess(String host) {
Log.info("Connected to " + host);
if (_transientPeersState.runReadLocked(d -> d.getStates().getOrDefault( if (_transientPeersState.runReadLocked(d -> d.getStates().getOrDefault(
host, new TransientPeersStateData.TransientPeerState(TransientPeersStateData.TransientPeerState.ConnectionState.NOT_SEEN) host, new TransientPeersStateData.TransientPeerState(TransientPeersStateData.TransientPeerState.ConnectionState.NOT_SEEN)
)).getState().equals(TransientPeersStateData.TransientPeerState.ConnectionState.REACHABLE)) return; )).getState().equals(TransientPeersStateData.TransientPeerState.ConnectionState.REACHABLE)) return;
@@ -70,6 +69,7 @@ public class RemoteHostManager {
curState.setState(TransientPeersStateData.TransientPeerState.ConnectionState.REACHABLE); curState.setState(TransientPeersStateData.TransientPeerState.ConnectionState.REACHABLE);
return null; return null;
}); });
Log.info("Connected to " + host);
syncHandler.doInitialResync(host); syncHandler.doInitialResync(host);
} }