stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-28 20:47:49 +01:00
Code Issues Packages Projects Releases Wiki Activity

a bit more cleanup with metadata 2

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-06-16 21:04:19 +02:00
parent 23cd3e4345
commit 01deb2fd33
3 changed files with 5 additions and 2 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/RemoteObjectServiceClient.java
View File

@@ -33,7 +33,7 @@ public class RemoteObjectServiceClient {
var meta = metaOpt.get();
if (meta.getMtime() != reply.getObject().getHeader().getMtime()) {
if (!meta.getAssumeUnique() && (meta.getAssumeUnique() != reply.getObject().getHeader().getAssumeUnique())) {
Log.error("Conflict!");
Log.error("Race when trying to fetch");
throw new NotImplementedException();
}
}

3
server/src/main/java/com/usatiuk/dhfs/storage/objects/repository/distributed/SyncHandler.java
View File

@@ -43,7 +43,8 @@ public class SyncHandler {
try {
objectPersistentStore.deleteObject(request.getName());
} catch (Exception ignored) {
} catch (Exception e) {
Log.info("Couldn't delete object from persistent store: ", e);
}
jObjectManager.invalidateJObject(data.getName());

2
server/src/test/java/com/usatiuk/dhfs/TestDataCleaner.java
View File

@@ -1,5 +1,6 @@
package com.usatiuk.dhfs;
import io.quarkus.logging.Log;
import io.quarkus.runtime.ShutdownEvent;
import io.quarkus.runtime.StartupEvent;
import jakarta.annotation.Priority;
@@ -24,6 +25,7 @@ public class TestDataCleaner {
purgeDirectory(Path.of(tempDirectory).toFile());
purgeDirectory(Path.of(tempDirectoryIdx).toFile());
} catch (Exception ignored) {
Log.warn("Couldn't cleanup test data on init");
}
}