Skip to content
Snippets Groups Projects
Commit 5c798a61 authored by tpylak's avatar tpylak
Browse files

removing dead code

SVN: 1957
parent 4ea802a7
No related branches found
No related tags found
No related merge requests found
...@@ -86,7 +86,6 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory ...@@ -86,7 +86,6 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory
this.bufferDirs = bufferDirs; this.bufferDirs = bufferDirs;
} }
public TimerTask createRecoverableTimerTask() public TimerTask createRecoverableTimerTask()
{ {
return new IncomingProcessorRecoveryTask(); return new IncomingProcessorRecoveryTask();
...@@ -217,7 +216,6 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory ...@@ -217,7 +216,6 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory
{ {
recoverIncomingInProgress(bufferDirs.getCopyInProgressDir(), bufferDirs.getCopyCompleteDir()); recoverIncomingInProgress(bufferDirs.getCopyInProgressDir(), bufferDirs.getCopyCompleteDir());
} }
recoverIncomingCopyComplete(bufferDirs.getCopyCompleteDir());
if (operationLog.isDebugEnabled()) if (operationLog.isDebugEnabled())
{ {
operationLog.debug("Recovery is finished."); operationLog.debug("Recovery is finished.");
...@@ -281,15 +279,5 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory ...@@ -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
}
}
} }
} }
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