eclipse-sailing-analytics/sailing-analytics
1
0 Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-10-17 01:31:01 +00:00
Code Activity

a somewhat more robust way of closing and reconnecting to Igtimi WebSocket servers;

Browse Source 
ignore the onWebSocketClose event if it is caused by the reconnect() call

Change-Id: I0b735d17168855e66ade684f5953a1faaa8e82e4
This commit is contained in:
Axel Uhl committed 2016-07-06 16:50:17 +02:00
1 parent b5b74b8982
commit b884ad9677
2 files changed
+76 -43
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

java/com.sap.sailing.server.gateway/src/com/sap/sailing/server/gateway/impl/WindStatusServlet.java
+6 -4
View File
@@ -248,13 +248,15 @@ public abstract class WindStatusServlet extends SailingServerHttpServlet impleme
@Override
public void windDataReceived(Wind wind, String deviceSerialNumber) {
Deque<IgtimiMessageInfo> messagesPerDevice = lastIgtimiMessages.get(deviceSerialNumber);
if(messagesPerDevice == null) {
if (messagesPerDevice == null) {
messagesPerDevice = new ArrayDeque<IgtimiMessageInfo>(NUMBER_OF_MESSAGES_PER_DEVICE_TO_SHOW);
lastIgtimiMessages.put(deviceSerialNumber, messagesPerDevice);
}
messagesPerDevice.addFirst(new IgtimiMessageInfo(wind));
if(messagesPerDevice.size() > NUMBER_OF_MESSAGES_PER_DEVICE_TO_SHOW) {
messagesPerDevice.pollLast();
synchronized (messagesPerDevice) {
messagesPerDevice.addFirst(new IgtimiMessageInfo(wind));
if (messagesPerDevice.size() > NUMBER_OF_MESSAGES_PER_DEVICE_TO_SHOW) {
messagesPerDevice.pollLast();
}
}
}