import java.io.IOException;\r
import java.text.ParseException;\r
import java.util.HashSet;\r
+import java.util.Map;\r
+import java.util.Set;\r
\r
import javax.xml.bind.ValidationException;\r
\r
System.out.println("Job Status: " + status);\r
Thread.sleep(1000);\r
status = aengine.getJobStatus(jobId);\r
- ConfiguredExecutable<Jronn> result = (ConfiguredExecutable<Jronn>) aengine\r
+ ConfiguredExecutable<Disembl> result = (ConfiguredExecutable<Disembl>) aengine\r
.getResults(jobId);\r
assertNotNull(result);\r
System.out.println("RES:" + result);\r
lr.executeJob();\r
ConfiguredExecutable<?> al1 = lr.waitForResult();\r
assertNotNull(al1.getResults());\r
- HashSet<Score> al2 = confDisembl.getResults();\r
+ Map<String,Set<Score>> al2 = confDisembl.getResults();\r
assertNotNull(al2);\r
assertEquals(al2.size(), 3);\r
assertEquals(al1.getResults(), al2);\r
\r
@Test(groups = {AllTestSuit.test_group_runner})\r
public void readStatistics() {\r
- try {\r
- ConfiguredExecutable<Disembl> confDisembl = Configurator\r
- .configureExecutable(disembl, Executable.ExecProvider.Local);\r
- // For local execution use relavive\r
-\r
- AsyncExecutor sexec = Configurator.getAsyncEngine(confDisembl);\r
- String jobId = sexec.submitJob(confDisembl);\r
- FilePuller fw = FilePuller.newFilePuller(\r
- confDisembl.getWorkDirectory() + File.separator\r
- + Jronn.getStatFile(),\r
- FileWatcher.MIN_CHUNK_SIZE_BYTES);\r
- int count = 0;\r
- long position = 0;\r
- fw.waitForFile(4);\r
- JobStatus status = sexec.getJobStatus(jobId);\r
- while (status != JobStatus.FINISHED) {\r
- if (fw.hasMoreData()) {\r
- ChunkHolder ch = fw.pull(position);\r
- String chunk = ch.getChunk();\r
- position = ch.getNextPosition();\r
- }\r
- count++;\r
- // Make sure the loop is terminated if the job fails\r
- if ((status == JobStatus.UNDEFINED || status == JobStatus.FAILED)) {\r
- break;\r
- }\r
- Thread.sleep(300);\r
- status = sexec.getJobStatus(jobId);\r
- }\r
- assertTrue(count > 1);\r
- ConfiguredExecutable<?> al = sexec.getResults(jobId);\r
- assertNotNull(al.getResults());\r
- } catch (JobSubmissionException e) {\r
- e.printStackTrace();\r
- fail(e.getMessage());\r
- } catch (ResultNotAvailableException e) {\r
- e.printStackTrace();\r
- fail(e.getMessage());\r
- } catch (IOException e) {\r
- e.printStackTrace();\r
- fail(e.getMessage());\r
- } catch (InterruptedException e) {\r
- e.printStackTrace();\r
- fail(e.getMessage());\r
- }\r
+ // No execution statistics is available!\r
}\r
\r
@Test(groups = {AllTestSuit.test_group_runner})\r
// See in details whether executables are the same\r
assertEquals(resurrectedCDisembl.getExecutable(), disembl);\r
\r
- ConfiguredExecutable<Disembl> resJronn = Configurator\r
+ ConfiguredExecutable<Disembl> resDisembl = Configurator\r
.configureExecutable(resurrectedCDisembl.getExecutable(),\r
Executable.ExecProvider.Local);\r
\r
- sexec = Configurator.getSyncEngine(resJronn,\r
+ sexec = Configurator.getSyncEngine(resDisembl,\r
Executable.ExecProvider.Local);\r
sexec.executeJob();\r
al = sexec.waitForResult();\r
RunnerConfig<Disembl> disemblConfig = ConfExecutable\r
.getRunnerOptions(Disembl.class);\r
assertNotNull(disemblConfig);\r
- assertTrue(disemblConfig.getArguments().size() > 0);\r
+ // There is no disembl parameters\r
+ assertTrue(disemblConfig.getArguments().size() == 0);\r
\r
PresetManager<Disembl> disemblPresets = ConfExecutable\r
.getRunnerPresets(Disembl.class);\r