Package loss notify (#1053)

* add notifications about lost packages

Signed-off-by: Andrey Parfenov <a1994ndrey@gmail.com>

Author: Andrey1994

OpenBCI_GUI/PacketLossTracker.pde

@@ -46,6 +46,13 @@ class PacketLossTracker {
 
     protected ArrayList<Integer> sampleIndexArray = new ArrayList<Integer>();
 
+    // use these vars for notification at the bottom
+    private boolean notificationShown = false;
+    protected String lostPackagesMsg = "Lost packets detected, open packet loss widget for more info";
+    protected String noLostPackagesMsg = "Data streaming is running as usual";
+    protected int windowSizeNotificationMs = 5000;
+    protected double thresholdNotification = 1.0;
+
     PacketLossTracker(int _sampleIndexChannel, int _timestampChannel, int _minSampleIndex, int _maxSampleIndex) {        
         this(_sampleIndexChannel, _timestampChannel,  _minSampleIndex, _maxSampleIndex, new RealTimeProvider());
     }
@@ -153,6 +160,7 @@ class PacketLossTracker {
         }
 
         packetRecords.push(currentRecord);
+        checkCurrentStreamStatus();
     }
 
     private void incrementLastSampleIndexLocation() {
@@ -165,6 +173,22 @@ class PacketLossTracker {
     protected void reset() {
         lastSample = null;
     }
+
+    protected void checkCurrentStreamStatus() {
+        PacketRecord lastMillisPacketRecord = getCumulativePacketRecordForLast(windowSizeNotificationMs);
+        if (lastMillisPacketRecord.getLostPercent() > thresholdNotification) {
+            if (!notificationShown) {
+                notificationShown = true;
+                outputWarn(lostPackagesMsg);
+            }
+        }
+        else {
+            if (notificationShown) {
+                notificationShown = false;
+                outputInfo(noLostPackagesMsg);
+            }
+        }
+    }
 }
 
 // sample index range 1-255, odd numbers only (skips evens)

OpenBCI_GUI_unittests/OpenBCI_GUI_UnitTests.pde

@@ -51,4 +51,12 @@ private void notifySuccess(boolean success) {
         PrintWriter output = createWriter(failFileName);
         output.close();
     }
-}
+}
+
+private void outputWarn(String str) {
+    println("warn stub for tests");
+}
+
+private void outputInfo(String str) {
+    println("info stub for tests");
+}

OpenBCI_GUI_unittests/run-unittests.py

@@ -11,7 +11,7 @@
 #           Once we get rid of globals we could copy all PDEs
 files_to_unittest = [
     "PacketLossTracker.pde",
-    "TimeTrackingQueue.pde",
+    "TimeTrackingQueue.pde"
 ]
 
 def main ():