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

no tolerance for failed snapshots

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-07-06 23:41:47 +02:00
parent bede493713
commit fc7369419a
1 changed files with 18 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
server/src/main/java/com/usatiuk/dhfs/storage/objects/repository/distributed/PersistentRemoteHostsService.java
View File

@@ -7,6 +7,8 @@ import com.usatiuk.dhfs.storage.objects.jrepository.JObjectResolver;
import com.usatiuk.dhfs.storage.objects.repository.distributed.peersync.PeerDirectory;
import com.usatiuk.dhfs.storage.objects.repository.distributed.peersync.PersistentPeerInfo;
import com.usatiuk.dhfs.storage.objects.repository.distributed.peertrust.PeerTrustManager;
import io.grpc.Status;
import io.grpc.StatusRuntimeException;
import io.quarkus.logging.Log;
import io.quarkus.runtime.ShutdownEvent;
import io.quarkus.runtime.StartupEvent;
@@ -23,7 +25,6 @@ import java.nio.file.Paths;
import java.security.KeyPair;
import java.security.cert.X509Certificate;
import java.util.List;
import java.util.Objects;
import java.util.Optional;
import java.util.UUID;
import java.util.concurrent.ExecutorService;
@@ -121,19 +122,6 @@ public class PersistentRemoteHostsService {
return (JObject<PersistentPeerInfo>) got;
}
private List<PersistentPeerInfo> getPeersSnapshot() {
return getPeerDirectory().runReadLocked(JObject.ResolutionStrategy.LOCAL_ONLY, (m, d) -> {
return d.getPeers().stream().map(u -> {
try {
return getPeer(u).runReadLocked(JObject.ResolutionStrategy.LOCAL_ONLY, (m2, d2) -> d2);
} catch (Exception e) {
Log.warn("Error making snapshot of peer " + u, e);
return null;
}
}).filter(Objects::nonNull).toList();
});
}
public UUID getSelfUuid() {
if (_selfUuid == null)
throw new IllegalStateException();
@@ -151,7 +139,22 @@ public class PersistentRemoteHostsService {
}
public List<PersistentPeerInfo> getHosts() {
return getPeersSnapshot().stream().filter(i -> !i.getUuid().equals(_selfUuid)).toList();
for (int i = 0; i < 5; i++) {
try {
return getPeerDirectory()
.runReadLocked(JObject.ResolutionStrategy.LOCAL_ONLY,
(m, d) -> d.getPeers().stream()
.map(u -> getPeer(u).runReadLocked(JObject.ResolutionStrategy.LOCAL_ONLY, (m2, d2) -> d2))
.filter(e -> !e.getUuid().equals(_selfUuid)).toList());
} catch (Exception e) {
Log.warn("Error when making snapshot of hosts ", e);
try {
Thread.sleep(i * 2);
} catch (InterruptedException ignored) {
}
}
}
throw new StatusRuntimeException(Status.ABORTED.withDescription("Could not make a snapshot of peers in 5 tries!"));
}
public boolean addHost(PersistentPeerInfo persistentPeerInfo) {