eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-30 09:26:44 +00:00
Code Activity

compilable version where SwissTiming connector tests currently don't work

Browse Source
This commit is contained in:
Axel Uhl
2011-11-14 08:59:49 +01:00
parent 694cdaab5b
commit 6430364b1e
2 changed files with 25 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.domain.swisstimingadapter.persistence/src/com/sap/sailing/domain/swisstimingadapter/persistence/impl/SwissTimingAdapterPersistenceImpl.java
+13 -29
View File
@@ -63,8 +63,9 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
// initially fill the races cache
Iterable<Race> races = getRaces();
for(Race race: races)
for(Race race: races) {
cachedRaces.put(race.getRaceID(), race);
}
}
@Override
@@ -144,17 +145,14 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
@Override
public Race getRace(String raceID) {
DBCollection races = database.getCollection(CollectionNames.RACES_MASTERDATA.name());
BasicDBObject query = new BasicDBObject();
query.append(FieldNames.RACE_ID.name(), raceID);
DBObject o = races.findOne(query);
if(o != null) {
Race race = swissTimingFactory.createRace((String) o.get(FieldNames.RACE_ID.name()),
(String) o.get(FieldNames.RACE_DESCRIPTION.name()), new MillisecondsTimePoint((Long) o.get(FieldNames.RACE_STARTTIME.name())));
return race;
if (o != null) {
Race race = swissTimingFactory.createRace((String) o.get(FieldNames.RACE_ID.name()),
(String) o.get(FieldNames.RACE_DESCRIPTION.name()),
new MillisecondsTimePoint((Long) o.get(FieldNames.RACE_STARTTIME.name())));
return race;
}
return null;
}
@@ -162,14 +160,13 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
@Override
public Iterable<Race> getRaces() {
DBCollection races = database.getCollection(CollectionNames.RACES_MASTERDATA.name());
DBCursor results = races.find();
List<Race> result = new ArrayList<Race>();
for (DBObject o : results) {
Long startTimeAsMillis = (Long) o.get(FieldNames.RACE_STARTTIME.name());
Race race = swissTimingFactory.createRace((String) o.get(FieldNames.RACE_ID.name()),
(String) o.get(FieldNames.RACE_DESCRIPTION.name()),
new MillisecondsTimePoint((Long) o.get(FieldNames.RACE_STARTTIME.name())));
startTimeAsMillis == null ? null : new MillisecondsTimePoint(startTimeAsMillis));
result.add(race);
}
return result;
@@ -198,34 +195,25 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
@Override
public void storeSailMasterMessage(SailMasterMessage message) {
// Attention: this method is very time critical as we will receive thousands of messages in a short time
DBCollection messageCollection = null;
MessageType type = message.getType();
BasicDBObject objToInsert = new BasicDBObject();
objToInsert.put(FieldNames.MESSAGE_COMMAND.name(), message.getType().name());
objToInsert.put(FieldNames.MESSAGE_SEQUENCE_NUMBER.name(), message.getSequenceNumber());
objToInsert.put(FieldNames.MESSAGE_CONTENT.name(), message.getMessage());
if(type.isRaceSpecific()) {
objToInsert.put(FieldNames.RACE_ID.name(), message.getRaceID());
messageCollection = database.getCollection(CollectionNames.RACES_MESSAGES.name());
}
else {
} else {
messageCollection = database.getCollection(CollectionNames.COMMAND_MESSAGES.name());
}
messageCollection.insert(objToInsert);
if(message.getRaceID() != null && cachedRaces.containsKey(message.getRaceID()) == false) {
// ah, we found a new raceID which is not in the list of known races
// in order to have a more intelligent conflict resolver mechanism we will forward the resolution to a special thread later on
boolean simpleResolution = true;
if(simpleResolution)
{
if(simpleResolution) {
Race newRace = SwissTimingFactory.INSTANCE.createRace(message.getRaceID(), null, null);
storeRace(newRace);
cachedRaces.put(newRace.getRaceID(), newRace);
@@ -236,17 +224,13 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
@Override
public void storeRace(Race race) {
DBCollection racesCollection = database.getCollection(CollectionNames.RACES_MASTERDATA.name());
BasicDBObject query = new BasicDBObject();
query.append(FieldNames.RACE_ID.name(), race.getRaceID());
BasicDBObject result = new BasicDBObject();
result.put(FieldNames.RACE_ID.name(), race.getRaceID());
result.put(FieldNames.RACE_DESCRIPTION.name(), race.getDescription());
result.put(FieldNames.RACE_STARTTIME.name(), new Long(race.getStartTime().asMillis()));
racesCollection.update(query,result);
result.put(FieldNames.RACE_STARTTIME.name(), race.getStartTime() == null ? null : new Long(race.getStartTime().asMillis()));
racesCollection.update(query, result, /* upsrt */ true, /* multi */ false);
}
java/com.sap.sailing.domain.swisstimingadapter.test/src/com/sap/sailing/domain/swisstimingadapter/test/SailMasterConnectivityTest.java
+12 -4
View File
@@ -33,6 +33,7 @@ import com.sap.sailing.domain.swisstimingadapter.SailMasterListener;
import com.sap.sailing.domain.swisstimingadapter.SailMasterMessage;
import com.sap.sailing.domain.swisstimingadapter.StartList;
import com.sap.sailing.domain.swisstimingadapter.SwissTimingFactory;
import com.sap.sailing.domain.swisstimingadapter.impl.RaceImpl;
import com.sap.sailing.domain.swisstimingadapter.persistence.SwissTimingAdapterPersistence;
import com.sap.sailing.util.Util;
import com.sap.sailing.util.Util.Triple;
@@ -47,10 +48,17 @@ public class SailMasterConnectivityTest {
@Before
public void setUp() throws InterruptedException, ParseException {
startSailMasterDummy();
connector = SwissTimingFactory.INSTANCE.getOrCreateSailMasterConnector("localhost", port, SwissTimingAdapterPersistence.INSTANCE);
connector.trackRace("W4702");
connector.trackRace("4711");
connector.trackRace("4712");
SwissTimingAdapterPersistence swissTimingPersistence = SwissTimingAdapterPersistence.INSTANCE;
Race raceW4702 = new RaceImpl("W4702", "W4702");
Race race4711 = new RaceImpl("4711", "4711");
Race race4712 = new RaceImpl("4712", "4712");
swissTimingPersistence.storeRace(raceW4702);
swissTimingPersistence.storeRace(race4711);
swissTimingPersistence.storeRace(race4712);
connector = SwissTimingFactory.INSTANCE.getOrCreateSailMasterConnector("localhost", port, swissTimingPersistence);
connector.trackRace(raceW4702.getRaceID());
connector.trackRace(race4711.getRaceID());
connector.trackRace(race4712.getRaceID());
}
private void startSailMasterDummy() throws InterruptedException {