0001586: Stage manager doesn't check to see if a file is actually del…

…eted when it qualifies for cleaning.
JumpMind · Feb 16, 2014 · 41c5068 · 41c5068
1 parent 099435b
commit 41c5068
Showing 1 changed file with 1 addition 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
@@ -91,7 +91,7 @@ public long clean(long ttlInMs) {
             for (String key : keys) {
                 IStagedResource resource = resourceList.get(key);
                 boolean resourceIsOld = (System.currentTimeMillis() - resource.getLastUpdateTime()) > ttlInMs;
-                if (resource.isInUse() && (resource.getState() == State.READY || resource.getState() == State.DONE)
+                if ((resource.getState() == State.READY || resource.getState() == State.DONE)
                         && (resourceIsOld || !resource.exists())) {                    
                     if (!resource.isInUse()) {
                         boolean file = resource.isFileResource();