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())) {