From 3f45db81fd7c7e0fa577bc94a9c6ab5234f88c02 Mon Sep 17 00:00:00 2001
From: brinn <brinn>
Date: Sun, 13 Jul 2008 17:55:24 +0000
Subject: [PATCH] [DMV-31] ensure the incoming and the local processor thread
create the right marker file for their successor when they are finished
SVN: 7191
---
.../systemsx/cisd/datamover/IncomingProcessorTest.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/datamover/sourceTest/java/ch/systemsx/cisd/datamover/IncomingProcessorTest.java b/datamover/sourceTest/java/ch/systemsx/cisd/datamover/IncomingProcessorTest.java
index b585a1d8fa8..ef1634c48e2 100644
--- a/datamover/sourceTest/java/ch/systemsx/cisd/datamover/IncomingProcessorTest.java
+++ b/datamover/sourceTest/java/ch/systemsx/cisd/datamover/IncomingProcessorTest.java
@@ -116,12 +116,12 @@ public final class IncomingProcessorTest
assertEquals("Marker file " + markerFile + " still there", false, markerFile
.exists());
}
-
+
public void canceling()
{
fail("Invocation of 'canceling()' not expected.");
}
-
+
};
@BeforeMethod
@@ -134,7 +134,7 @@ public final class IncomingProcessorTest
mover = context.mock(IPathMover.class);
remover = context.mock(IPathRemover.class);
exitHandler = context.mock(IExitHandler.class);
-
+
FileUtilities.deleteRecursively(TEST_FOLDER);
TEST_FOLDER.mkdirs();
exampleScript = new File(TEST_FOLDER, EXAMPLE_SCRIPT_NAME);
@@ -220,7 +220,6 @@ public final class IncomingProcessorTest
assertEquals("", logRecorder.getLogContent());
context.assertIsSatisfied();
}
-
@Test
public void testWithDataCompletedScriptWhichFailsInitially() throws IOException
@@ -302,7 +301,7 @@ public final class IncomingProcessorTest
will(returnValue(remover));
}
});
- return IncomingProcessor.createMovingProcess(parameters, MARKER_FILE,
+ return IncomingProcessor.createMovingProcess(parameters, MARKER_FILE, null,
fileSysOpertationFactory, new MockTimeProvider(), localBufferDirs);
}
--
GitLab