From 5c798a61cde72449c21e5375ea32599c883be7aa Mon Sep 17 00:00:00 2001
From: tpylak <tpylak>
Date: Thu, 4 Oct 2007 08:05:27 +0000
Subject: [PATCH] removing dead code
SVN: 1957
---
.../systemsx/cisd/datamover/IncomingProcessor.java | 12 ------------
1 file changed, 12 deletions(-)
diff --git a/datamover/source/java/ch/systemsx/cisd/datamover/IncomingProcessor.java b/datamover/source/java/ch/systemsx/cisd/datamover/IncomingProcessor.java
index d4013da54c9..289307d9714 100644
--- a/datamover/source/java/ch/systemsx/cisd/datamover/IncomingProcessor.java
+++ b/datamover/source/java/ch/systemsx/cisd/datamover/IncomingProcessor.java
@@ -86,7 +86,6 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory
this.bufferDirs = bufferDirs;
}
-
public TimerTask createRecoverableTimerTask()
{
return new IncomingProcessorRecoveryTask();
@@ -217,7 +216,6 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory
{
recoverIncomingInProgress(bufferDirs.getCopyInProgressDir(), bufferDirs.getCopyCompleteDir());
}
- recoverIncomingCopyComplete(bufferDirs.getCopyCompleteDir());
if (operationLog.isDebugEnabled())
{
operationLog.debug("Recovery is finished.");
@@ -281,15 +279,5 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory
}
}
}
-
- // schedule processing of all resources which were previously copied
- private void recoverIncomingCopyComplete(File copyCompleteDir)
- {
- final File[] files = incomingReadOperations.tryListFiles(copyCompleteDir, errorLog);
- if (files == null || files.length == 0)
- {
- return; // directory is empty, no recovery is needed
- }
- }
}
}
--
GitLab