Merge pull request #1181 from OpenBCI/process-widget-data-background-networking

Process widget data in background when widgets are closed

Author: retiutut

CHANGELOG.md

@@ -4,6 +4,7 @@
 - Update repository to Processing 4.2 #1111
 - Add Software Marker Widget #1091
 - Add channel labels for Cyton Digital Channels in GUI CSV files and also label unused channels #1108
+- Process all data in the background when widgets are closed and sending over Networking stream #1094
 
 # v5.2.1
 

Networking-Test-Kit/LSL/lslStreamTest_3Streams.py

@@ -35,22 +35,21 @@ def testLSLSamplingRates():
             if i == 0:
                 chunk, timestamps = inlet.pull_chunk()
                 if timestamps:
+                    print("Stream 1 Chunk: ", chunk)
                     for sample in chunk:
-                        if sample:
-                            num_samples_1 += 1
-                            #print(sample)
+                        num_samples_1 += 1
             elif i == 1:
                 chunk, timestamps_2 = inlet_2.pull_chunk()
                 if timestamps_2:
+                    print("Stream 2 Chunk: ", chunk)
                     for sample in chunk:
                         num_samples_2 += 1
-                        #print(sample)
             elif i == 2:
                 chunk, timestamps_3 = inlet_3.pull_chunk()
                 if timestamps_3:
+                    print("Stream 3 Chunk: ", chunk)
                     for sample in chunk:
                         num_samples_3 += 1
-                        #print(sample)
             #print("Stream", i + 1, " == ", chunk)
     print( "Stream 1 Sampling Rate == ", num_samples_1 / duration_seconds, " | Type : EEG")
     print( "Stream 2 Sampling Rate == ", num_samples_2 / duration_seconds, " | Type : AUX")

Networking-Test-Kit/LSL/lslStreamTest_BandPowerAllChannels.py

@@ -0,0 +1,44 @@
+"""Example program to show how to read a GUI BandPower data over LSL."""
+import time
+from pylsl import StreamInlet, resolve_stream
+from time import sleep
+
+# Example Sample
+# F
+#[0.0, 0.8485075831413269, 9.373364448547363, 0.0013413801789283752, 0.001849484397098422]
+
+# First resolve an EEG stream on the lab network
+print("looking for an EEG stream...")
+streams = resolve_stream('type', 'EEG')
+
+# Create a new inlet to read from the stream
+inlet = StreamInlet(streams[0])
+duration = 5
+num_channels = 8
+
+sleep(1)
+
+def testLSLSamplingRate():
+    start = time.time()
+    total_samples = 0
+    num_samples_channel_0 = 0
+    print( "Testing Sampling Rates..." )
+
+    while time.time() <= start + duration:
+        # Get chunks of samples
+        sample, timestamp = inlet.pull_sample()
+        if sample:
+            print("\nNew chunk! Sample size == {}".format(len(sample)) )
+            total_samples += 1
+            print(sample, timestamp)
+            if sample[0] == 0.0:
+                num_samples_channel_0 += 1
+
+
+    print( "Valid Samples and Duration == {} / {}".format(total_samples, duration) )
+    print( "Average Sampling Rate == {}".format(total_samples / duration) )
+    print( "Valid Samples Channel 0 and Duration == {} / {}".format(num_samples_channel_0, duration) )
+    print( "Average Sampling Rate Channel 0 == {}".format(num_samples_channel_0 / duration) )
+
+
+testLSLSamplingRate()

OpenBCI_GUI/DataProcessing.pde

@@ -277,14 +277,13 @@ class DataProcessing {
             headWidePower[i] = sum/nchan;   // averaging power over all channels
         }
 
-        //find strongest channel
+        // Calculate data used for Headplot
+        // Find strongest channel
         int refChanInd = findMax(data_std_uV);
         //println("EEG_Processing: strongest chan (one referenced) = " + (refChanInd+1));
         float[] refData_uV = dataProcessingFilteredBuffer[refChanInd];  //use the filtered data
         refData_uV = Arrays.copyOfRange(refData_uV, refData_uV.length-((int)fs_Hz), refData_uV.length);   //just grab the most recent second of data
-
-
-        //compute polarity of each channel
+        // Compute polarity of each channel
         for (int Ichan=0; Ichan < nchan; Ichan++) {
             float[] fooData_filt = dataProcessingFilteredBuffer[Ichan];  //use the filtered data
             fooData_filt = Arrays.copyOfRange(fooData_filt, fooData_filt.length-((int)fs_Hz), fooData_filt.length);   //just grab the most recent second of data
@@ -296,7 +295,18 @@ class DataProcessing {
             }
         }
 
-        //Compute EMG values independent of widgets
+        /////////////////////////////////////////////////////////////
+        // Compute widget values independent of widgets being open //
+        //                       -RW #1094                         //
+        /////////////////////////////////////////////////////////////
         emgSettings.values.process(dataProcessingFilteredBuffer);
+        w_focus.updateFocusWidgetData();
+        w_bandPower.updateBandPowerWidgetData();
+        w_emgJoystick.updateEmgJoystickWidgetData();
+        if (w_pulsesensor != null) {
+            w_pulsesensor.updatePulseSensorWidgetData();
+        }
+
+        w_networking.updateNetworkingWidgetData();
     }
 }