Skip to content
Snippets Groups Projects
Commit 1978835c authored by tpylak's avatar tpylak
Browse files

bugfix: when incoming directory was not treated as a remote one, than recovery...

bugfix: when incoming directory was not treated as a remote one, than recovery process did not work correctly.

SVN: 1570
parent f46621fe
No related branches found
No related tags found
No related merge requests found
...@@ -137,8 +137,11 @@ public class MonitorStarter ...@@ -137,8 +137,11 @@ public class MonitorStarter
private void recoverIncomingAfterShutdown(FileStore incomingStore, IReadPathOperations incomingReadOperations, private void recoverIncomingAfterShutdown(FileStore incomingStore, IReadPathOperations incomingReadOperations,
boolean isIncomingRemote, LazyPathHandler localProcessor) boolean isIncomingRemote, LazyPathHandler localProcessor)
{ {
recoverIncomingInProgress(incomingStore, incomingReadOperations, bufferDirs.getCopyInProgressDir(), bufferDirs if (isIncomingRemote)
.getCopyCompleteDir(), parameters.getPrefixForIncoming()); {
recoverIncomingInProgress(incomingStore, incomingReadOperations, bufferDirs.getCopyInProgressDir(),
bufferDirs.getCopyCompleteDir(), parameters.getPrefixForIncoming());
}
recoverIncomingCopyComplete(bufferDirs.getCopyCompleteDir(), localProcessor); recoverIncomingCopyComplete(bufferDirs.getCopyCompleteDir(), localProcessor);
} }
......
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