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: try to download all on start only when it's enabled, duh

Browse Source
This commit is contained in:
Stepan Usatiuk
2025-03-23 16:24:13 +01:00
parent 03850d3522
commit e80e33568b
1 changed files with 27 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/AutosyncProcessor.java
View File

@@ -34,6 +34,9 @@ public class AutosyncProcessor {
Transaction curTx;
@Inject
RemoteTransaction remoteTx;
@ConfigProperty(name = "dhfs.objects.autosync.download-all")
boolean downloadAll;
private ExecutorService _autosyncExcecutor;
void init(@Observes @Priority(300) StartupEvent event) {
@@ -46,31 +49,32 @@ public class AutosyncProcessor {
_autosyncExcecutor.submit(this::autosync);
}
executorService.submit(() -> {
Log.info("Adding all to autosync");
List<JObjectKey> objs = new LinkedList<>();
txm.run(() -> {
try (var it = curTx.getIterator(IteratorStart.GE, JObjectKey.first())) {
while (it.hasNext()) {
var key = it.peekNextKey();
objs.add(key);
// TODO: Nested transactions
it.skip();
}
}
});
for (var obj : objs) {
if (downloadAll)
executorService.submit(() -> {
Log.info("Adding all to autosync");
List<JObjectKey> objs = new LinkedList<>();
txm.run(() -> {
var gotObj = curTx.get(JData.class, obj).orElse(null);
if (!(gotObj instanceof RemoteObjectMeta meta))
return;
if (!meta.hasLocalData())
add(meta.key());
try (var it = curTx.getIterator(IteratorStart.GE, JObjectKey.first())) {
while (it.hasNext()) {
var key = it.peekNextKey();
objs.add(key);
// TODO: Nested transactions
it.skip();
}
}
});
}
Log.info("Adding all to autosync: finished");
});
for (var obj : objs) {
txm.run(() -> {
var gotObj = curTx.get(JData.class, obj).orElse(null);
if (!(gotObj instanceof RemoteObjectMeta meta))
return;
if (!meta.hasLocalData())
add(meta.key());
});
}
Log.info("Adding all to autosync: finished");
});
}
void shutdown(@Observes @Priority(10) ShutdownEvent event) {