From 03850d352249bbaf096a7002bede7bfe6f3bb5dd Mon Sep 17 00:00:00 2001 From: Stepan Usatiuk Date: Sun, 23 Mar 2025 16:05:29 +0100 Subject: [PATCH] Server: use linked list for autosync/sync lists --- .../usatiuk/dhfs/objects/repository/AutosyncProcessor.java | 5 +++-- .../com/usatiuk/dhfs/objects/repository/SyncHandler.java | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/AutosyncProcessor.java b/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/AutosyncProcessor.java index c799c7ee..bbda7429 100644 --- a/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/AutosyncProcessor.java +++ b/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/AutosyncProcessor.java @@ -15,7 +15,8 @@ import jakarta.inject.Inject; import org.apache.commons.lang3.concurrent.BasicThreadFactory; import org.eclipse.microprofile.config.inject.ConfigProperty; -import java.util.ArrayList; +import java.util.LinkedList; +import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; @@ -47,7 +48,7 @@ public class AutosyncProcessor { executorService.submit(() -> { Log.info("Adding all to autosync"); - ArrayList objs = new ArrayList<>(); + List objs = new LinkedList<>(); txm.run(() -> { try (var it = curTx.getIterator(IteratorStart.GE, JObjectKey.first())) { while (it.hasNext()) { diff --git a/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/SyncHandler.java b/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/SyncHandler.java index 320c05be..7581db67 100644 --- a/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/SyncHandler.java +++ b/dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/repository/SyncHandler.java @@ -110,7 +110,7 @@ public class SyncHandler { } public void doInitialSync(PeerId peer) { - ArrayList objs = new ArrayList<>(); + List objs = new LinkedList<>(); txm.run(() -> { Log.tracev("Will do initial sync for {0}", peer); try (var it = curTx.getIterator(IteratorStart.GE, JObjectKey.first())) {