From 41c50682fe2a130809f2b1cf2ed1431d764913f8 Mon Sep 17 00:00:00 2001 From: chenson42 Date: Sun, 16 Feb 2014 18:20:09 +0000 Subject: [PATCH] 0001586: Stage manager doesn't check to see if a file is actually deleted when it qualifies for cleaning. --- .../java/org/jumpmind/symmetric/io/stage/StagingManager.java | 2 +- 1 file changed, 1 insertion(+), 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 index 6692832175..464218f181 100644 --- 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();