eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-25 06:58:39 +00:00
Code Activity

fixed potential concurrency issues in WindStatusServlet

Browse Source
This commit is contained in:
Axel Uhl
2014-09-30 18:16:48 +02:00
parent 3533a802fb
commit ff23160814
5 changed files with 20 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.domain.igtimiadapter/src/com/sap/sailing/domain/igtimiadapter/impl/IgtimiConnectionImpl.java
+1 -2
View File
@@ -304,8 +304,7 @@ public class IgtimiConnectionImpl implements IgtimiConnection {
}
final Map<TrackedRace, Integer> result;
if (!deviceSerialNumbers.isEmpty()) {
IgtimiWindReceiver windReceiver = new IgtimiWindReceiver(deviceSerialNumbers,
correctByDeclination ? DeclinationService.INSTANCE : null);
IgtimiWindReceiver windReceiver = new IgtimiWindReceiver(correctByDeclination ? DeclinationService.INSTANCE : null);
final WindListenerSendingToTrackedRace windListener = new WindListenerSendingToTrackedRace(
trackedRaces, Activator.getInstance().getWindTrackerFactory());
windReceiver.addListener(windListener);
java/com.sap.sailing.domain.igtimiadapter/src/com/sap/sailing/domain/igtimiadapter/impl/IgtimiWindTracker.java
+1 -2
View File
@@ -48,8 +48,7 @@ public class IgtimiWindTracker extends AbstractWindTracker implements WindTracke
Iterable<String> devicesWeShouldListenTo = connection.getWindDevices();
if (!stopping) {
LiveDataConnection liveConnection = connection.getOrCreateLiveConnection(devicesWeShouldListenTo);
IgtimiWindReceiver windReceiver = new IgtimiWindReceiver(devicesWeShouldListenTo,
correctByDeclination ? DeclinationService.INSTANCE : null);
IgtimiWindReceiver windReceiver = new IgtimiWindReceiver(correctByDeclination ? DeclinationService.INSTANCE : null);
liveConnection.addListener(windReceiver);
windReceiver.addListener(new WindListenerSendingToTrackedRace(Collections.singleton(getTrackedRace()), windTrackerFactory));
liveConnectionsAndDeviceSerialNumber.put(liveConnection, new Util.Pair<Iterable<String>, Account>(devicesWeShouldListenTo, account));
java/com.sap.sailing.domain.igtimiadapter/src/com/sap/sailing/domain/igtimiadapter/shared/IgtimiWindReceiver.java
+1 -1
View File
@@ -109,7 +109,7 @@ public class IgtimiWindReceiver implements BulkFixReceiver {
}
}
public IgtimiWindReceiver(Iterable<String> deviceSerialNumbers, DeclinationService declinationService) {
public IgtimiWindReceiver(DeclinationService declinationService) {
receiver = new FixReceiver();
this.declinationService = declinationService;
listeners = new ConcurrentHashMap<>();