0002578: Staging can clear ready batches which slows initial load

it looks like 0 is hard-coded to mean clean everything from staging
JumpMind · May 3, 2016 · 1803ab9 · 1803ab9 · nameless-one · Jun 30, 2016
1 parent 869f9cf
commit 1803ab9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java
@@ -95,7 +95,8 @@ public long clean(long ttlInMs) {
                 if (resource != null) {
                     boolean resourceIsOld = (System.currentTimeMillis() - resource
                             .getLastUpdateTime()) > ttlInMs;
-                    if (resource.getState() == State.DONE && (resourceIsOld || !resource.exists())) {
+                    if ((resource.getState() == State.DONE || (resource.getState() == State.READY && ttlInMs == 0)) 
+                            && (resourceIsOld || !resource.exists())) {
                         if (!resource.isInUse()) {
                             boolean file = resource.isFileResource();
                             long size = resource.getSize();