fix sleep thread until race loading progress == 1.0

This commit is contained in:
Christopher Ronnewinkel (D036654)
2013-03-26 16:43:16 +01:00
parent 197154ccb5
commit 8bff095f54
6 changed files with 41 additions and 4 deletions
@@ -65,6 +65,14 @@ public class TestRacingEventPersistence {
for (RaceDefinition r : races) {
RegattaAndRaceIdentifier raceIdentifier = new RegattaNameAndRaceName(regatta, r.getName());
TrackedRace tr = service.getExistingTrackedRace(raceIdentifier);
try {
while (tr.getStatus().getLoadingProgress() < 1.0)
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
racesList.add(tr);
}
@@ -117,7 +117,9 @@ public class RaceDataAccessTest {
RegattaAndRaceIdentifier raceIdentifier = new RegattaNameAndRaceName(regatta, race.getName());
TrackedRace tr = service.getExistingTrackedRace(raceIdentifier);
while (tr.getStatus().getLoadingProgress() < 1.0)
Thread.sleep(1000);
System.out.println("Competitors:");
Iterable<Competitor> competitors = tr.getRace().getCompetitors();
System.out.println("" + competitors);
@@ -74,6 +74,14 @@ public class TracTracReaderFromURLs implements TracTracReader {
for (RaceDefinition r : races) {
RegattaAndRaceIdentifier raceIdentifier = new RegattaNameAndRaceName(regatta, r.getName());
TrackedRace tr = service.getExistingTrackedRace(raceIdentifier);
try {
while (tr.getStatus().getLoadingProgress() < 1.0)
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
racesList.add(tr);
}
}
@@ -52,6 +52,14 @@ public class TracTracWriter {
for (RaceDefinition r : races) {
RegattaAndRaceIdentifier raceIdentifier = new RegattaNameAndRaceName(regatta, r.getName());
TrackedRace tr = service.getExistingTrackedRace(raceIdentifier);
try {
while (tr.getStatus().getLoadingProgress() < 1.0)
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
racesList.add(tr);
}
System.out.println("start writing");
@@ -256,6 +256,13 @@ public class PathGeneratorTracTrac extends PathGeneratorBase {
Regatta regatta = this.raceHandle.getRegatta();
TrackedRace trackedRace = this.service.getTrackedRace(regatta, raceDef);
try {
while (trackedRace.getStatus().getLoadingProgress() < 1.0)
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Iterator<Competitor> competitors = raceDef.getCompetitors().iterator();
Competitor competitor = null;
@@ -314,6 +321,13 @@ public class PathGeneratorTracTrac extends PathGeneratorBase {
Regatta regatta = this.raceHandle.getRegatta();
TrackedRace trackedRace = this.service.getTrackedRace(regatta, raceDef);
try {
while (trackedRace.getStatus().getLoadingProgress() < 1.0)
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Iterator<Competitor> competitors = raceDef.getCompetitors().iterator();
Competitor competitor = null;
@@ -71,9 +71,6 @@ public class SimulatorUtils {
RaceLogStore raceLogStore, WindStore windStore, long timeoutInMilliseconds) throws Exception {
RacesHandle raceHandle = service.addTracTracRace(paramURL, liveURI, storedURI, raceLogStore, windStore,
timeoutInMilliseconds);
// synchronized (this) {
// this.wait();
// }
return raceHandle;
}