Skip to content
Snippets Groups Projects
Commit 22ac1d34 authored by brinn's avatar brinn
Browse files

Do not throw a timeout exception when markerfile deletion stalls, but put it...

Do not throw a timeout exception when markerfile deletion stalls, but put it in the asynchronous queue.

SVN: 27474
parent f6df14b4
No related branches found
No related tags found
No related merge requests found
...@@ -27,6 +27,7 @@ import org.apache.commons.lang.time.StopWatch; ...@@ -27,6 +27,7 @@ import org.apache.commons.lang.time.StopWatch;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;
import ch.systemsx.cisd.base.exceptions.IOExceptionUnchecked; import ch.systemsx.cisd.base.exceptions.IOExceptionUnchecked;
import ch.systemsx.cisd.base.exceptions.TimeoutExceptionUnchecked;
import ch.systemsx.cisd.common.action.IDelegatedActionWithResult; import ch.systemsx.cisd.common.action.IDelegatedActionWithResult;
import ch.systemsx.cisd.common.exceptions.EnvironmentFailureException; import ch.systemsx.cisd.common.exceptions.EnvironmentFailureException;
import ch.systemsx.cisd.common.exceptions.HighLevelException; import ch.systemsx.cisd.common.exceptions.HighLevelException;
...@@ -34,6 +35,7 @@ import ch.systemsx.cisd.common.exceptions.UserFailureException; ...@@ -34,6 +35,7 @@ import ch.systemsx.cisd.common.exceptions.UserFailureException;
import ch.systemsx.cisd.common.filesystem.FileConstants; import ch.systemsx.cisd.common.filesystem.FileConstants;
import ch.systemsx.cisd.common.filesystem.FileUtilities; import ch.systemsx.cisd.common.filesystem.FileUtilities;
import ch.systemsx.cisd.common.filesystem.IFileOperations; import ch.systemsx.cisd.common.filesystem.IFileOperations;
import ch.systemsx.cisd.common.filesystem.QueueingPathRemoverService;
import ch.systemsx.cisd.common.logging.LogCategory; import ch.systemsx.cisd.common.logging.LogCategory;
import ch.systemsx.cisd.common.logging.LogFactory; import ch.systemsx.cisd.common.logging.LogFactory;
import ch.systemsx.cisd.common.mail.IMailClient; import ch.systemsx.cisd.common.mail.IMailClient;
...@@ -450,7 +452,13 @@ public class DataSetRegistrationAlgorithm ...@@ -450,7 +452,13 @@ public class DataSetRegistrationAlgorithm
state.transaction.commit(); state.transaction.commit();
} finally } finally
{ {
getFileOperations().delete(markerFile); try
{
getFileOperations().delete(markerFile);
} catch (TimeoutExceptionUnchecked ex)
{
QueueingPathRemoverService.removeRecursively(markerFile);
}
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment