Darien Figueroa / Mbed OS Final_Program

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   USBDevice

hspguisourcev301/HspGuiSourceV301/HSPGui/Presenter/StreamPresenter.cs@3:36de8b9e4b1a, 2021-04-10 (annotated)

Committer:
darienf
Date:
Sat Apr 10 03:05:42 2021 +0000
Revision:
3:36de8b9e4b1a
ayoooo

Who changed what in which revision?

UserRevisionLine numberNew contents of line
darienf 3:36de8b9e4b1a 1 /*******************************************************************************
darienf 3:36de8b9e4b1a 2 * Copyright (C) 2016 Maxim Integrated Products, Inc., All rights Reserved.
darienf 3:36de8b9e4b1a 3 *
darienf 3:36de8b9e4b1a 4 * This software is protected by copyright laws of the United States and
darienf 3:36de8b9e4b1a 5 * of foreign countries. This material may also be protected by patent laws
darienf 3:36de8b9e4b1a 6 * and technology transfer regulations of the United States and of foreign
darienf 3:36de8b9e4b1a 7 * countries. This software is furnished under a license agreement and/or a
darienf 3:36de8b9e4b1a 8 * nondisclosure agreement and may only be used or reproduced in accordance
darienf 3:36de8b9e4b1a 9 * with the terms of those agreements. Dissemination of this information to
darienf 3:36de8b9e4b1a 10 * any party or parties not specified in the license agreement and/or
darienf 3:36de8b9e4b1a 11 * nondisclosure agreement is expressly prohibited.
darienf 3:36de8b9e4b1a 12 *
darienf 3:36de8b9e4b1a 13 * The above copyright notice and this permission notice shall be included
darienf 3:36de8b9e4b1a 14 * in all copies or substantial portions of the Software.
darienf 3:36de8b9e4b1a 15 *
darienf 3:36de8b9e4b1a 16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
darienf 3:36de8b9e4b1a 17 * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
darienf 3:36de8b9e4b1a 18 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
darienf 3:36de8b9e4b1a 19 * IN NO EVENT SHALL MAXIM INTEGRATED BE LIABLE FOR ANY CLAIM, DAMAGES
darienf 3:36de8b9e4b1a 20 * OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
darienf 3:36de8b9e4b1a 21 * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
darienf 3:36de8b9e4b1a 22 * OTHER DEALINGS IN THE SOFTWARE.
darienf 3:36de8b9e4b1a 23 *
darienf 3:36de8b9e4b1a 24 * Except as contained in this notice, the name of Maxim Integrated
darienf 3:36de8b9e4b1a 25 * Products, Inc. shall not be used except as stated in the Maxim Integrated
darienf 3:36de8b9e4b1a 26 * Products, Inc. Branding Policy.
darienf 3:36de8b9e4b1a 27 *
darienf 3:36de8b9e4b1a 28 * The mere transfer of this software does not imply any licenses
darienf 3:36de8b9e4b1a 29 * of trade secrets, proprietary technology, copyrights, patents,
darienf 3:36de8b9e4b1a 30 * trademarks, maskwork rights, or any other form of intellectual
darienf 3:36de8b9e4b1a 31 * property whatsoever. Maxim Integrated Products, Inc. retains all
darienf 3:36de8b9e4b1a 32 * ownership rights.
darienf 3:36de8b9e4b1a 33 *******************************************************************************
darienf 3:36de8b9e4b1a 34 */
darienf 3:36de8b9e4b1a 35
darienf 3:36de8b9e4b1a 36 using System;
darienf 3:36de8b9e4b1a 37 using System.Collections.Generic;
darienf 3:36de8b9e4b1a 38 using System.Linq;
darienf 3:36de8b9e4b1a 39 using System.Text;
darienf 3:36de8b9e4b1a 40
darienf 3:36de8b9e4b1a 41 using RPCSupport;
darienf 3:36de8b9e4b1a 42 using RPCSupport.Streaming;
darienf 3:36de8b9e4b1a 43 using HealthSensorPlatform.CustomControls;
darienf 3:36de8b9e4b1a 44 using HealthSensorPlatform.Model;
darienf 3:36de8b9e4b1a 45 using HealthSensorPlatform.View;
darienf 3:36de8b9e4b1a 46
darienf 3:36de8b9e4b1a 47 namespace HealthSensorPlatform.Presenter
darienf 3:36de8b9e4b1a 48 {
darienf 3:36de8b9e4b1a 49 public class StreamPresenter
darienf 3:36de8b9e4b1a 50 {
darienf 3:36de8b9e4b1a 51 const double NoData = -5000;
darienf 3:36de8b9e4b1a 52 const int NoRToR = -1;
darienf 3:36de8b9e4b1a 53
darienf 3:36de8b9e4b1a 54 private RPCClient rpcClient;
darienf 3:36de8b9e4b1a 55 private EcgView ecgView;
darienf 3:36de8b9e4b1a 56 private IFormView formView;
darienf 3:36de8b9e4b1a 57 private int rToRRaw = NoRToR;
darienf 3:36de8b9e4b1a 58 private PaceData paceData;
darienf 3:36de8b9e4b1a 59 private bool start = false;
darienf 3:36de8b9e4b1a 60
darienf 3:36de8b9e4b1a 61 public StreamPresenter()
darienf 3:36de8b9e4b1a 62 {
darienf 3:36de8b9e4b1a 63
darienf 3:36de8b9e4b1a 64 }
darienf 3:36de8b9e4b1a 65
darienf 3:36de8b9e4b1a 66 public StreamPresenter(EcgView ecgView)
darienf 3:36de8b9e4b1a 67 {
darienf 3:36de8b9e4b1a 68 this.ecgView = ecgView;
darienf 3:36de8b9e4b1a 69 }
darienf 3:36de8b9e4b1a 70
darienf 3:36de8b9e4b1a 71 public StreamPresenter(RPCClient rpcClient, EcgView ecgView, IFormView formView)
darienf 3:36de8b9e4b1a 72 {
darienf 3:36de8b9e4b1a 73 this.rpcClient = rpcClient;
darienf 3:36de8b9e4b1a 74 this.ecgView = ecgView;
darienf 3:36de8b9e4b1a 75 this.formView = formView;
darienf 3:36de8b9e4b1a 76
darienf 3:36de8b9e4b1a 77 ecgView.StreamingStartStop += new EventHandler<StreamingStartStopEventArgs>(OnStreamingStartStop);
darienf 3:36de8b9e4b1a 78 rpcClient.streaming.PartialArrayIntAvailable += new EventHandler<PartialArrayIntAvailableEventArgs>(OnStreamData);
darienf 3:36de8b9e4b1a 79 }
darienf 3:36de8b9e4b1a 80
darienf 3:36de8b9e4b1a 81 private void OnStreamingStartStop(object sender, StreamingStartStopEventArgs e)
darienf 3:36de8b9e4b1a 82 {
darienf 3:36de8b9e4b1a 83 start = e.state;
darienf 3:36de8b9e4b1a 84
darienf 3:36de8b9e4b1a 85 if (ecgView.Connected && !start) // Clear Interrupts on stream start and stop, start to prevent RPC Int Assignment freeze
darienf 3:36de8b9e4b1a 86 {
darienf 3:36de8b9e4b1a 87 rpcClient.MAX30001.WriteReg(0x02, 0x03); // Stop Interrupts
darienf 3:36de8b9e4b1a 88 rpcClient.MAX30001.WriteReg(0x03, 0x03); // Stop Interrupts
darienf 3:36de8b9e4b1a 89 }
darienf 3:36de8b9e4b1a 90
darienf 3:36de8b9e4b1a 91 formView.EcgLogFileItem(false);
darienf 3:36de8b9e4b1a 92 formView.BioZLogFileItem(false);
darienf 3:36de8b9e4b1a 93 formView.RtoRLogFileItem(false);
darienf 3:36de8b9e4b1a 94 formView.PaceLogFileItem(false);
darienf 3:36de8b9e4b1a 95 }
darienf 3:36de8b9e4b1a 96
darienf 3:36de8b9e4b1a 97 private void OnStreamData(object sender, PartialArrayIntAvailableEventArgs e)
darienf 3:36de8b9e4b1a 98 {
darienf 3:36de8b9e4b1a 99 int leadOffState;
darienf 3:36de8b9e4b1a 100 if (start && e.array1.Length > 0) // Ignore events unless started (from flash logging)
darienf 3:36de8b9e4b1a 101 {
darienf 3:36de8b9e4b1a 102 leadOffState = e.array1[0];
darienf 3:36de8b9e4b1a 103
darienf 3:36de8b9e4b1a 104 switch(e.reportID)
darienf 3:36de8b9e4b1a 105 {
darienf 3:36de8b9e4b1a 106 case PartialArrayIntAvailableEventArgs.PACKET_MAX30001_LEADOFF_DC:
darienf 3:36de8b9e4b1a 107 ecgView.SetDCLeadOff(leadOffState);
darienf 3:36de8b9e4b1a 108 break;
darienf 3:36de8b9e4b1a 109 case PartialArrayIntAvailableEventArgs.PACKET_MAX30001_LEADOFF_AC:
darienf 3:36de8b9e4b1a 110 ecgView.SetACLeadOff(leadOffState);
darienf 3:36de8b9e4b1a 111 break;
darienf 3:36de8b9e4b1a 112 }
darienf 3:36de8b9e4b1a 113
darienf 3:36de8b9e4b1a 114 switch (e.reportID)
darienf 3:36de8b9e4b1a 115 {
darienf 3:36de8b9e4b1a 116 case PartialArrayIntAvailableEventArgs.PACKET_MAX30001_ECG:
darienf 3:36de8b9e4b1a 117 ProcessEcg(e.array1);
darienf 3:36de8b9e4b1a 118 break;
darienf 3:36de8b9e4b1a 119 case PartialArrayIntAvailableEventArgs.PACKET_MAX30001_BIOZ:
darienf 3:36de8b9e4b1a 120 ProcessBioZ(e.array1);
darienf 3:36de8b9e4b1a 121 break;
darienf 3:36de8b9e4b1a 122 case PartialArrayIntAvailableEventArgs.PACKET_MAX30001_PACE:
darienf 3:36de8b9e4b1a 123 ProcessPace(e.array1);
darienf 3:36de8b9e4b1a 124 break;
darienf 3:36de8b9e4b1a 125 case PartialArrayIntAvailableEventArgs.PACKET_MAX30001_RTOR:
darienf 3:36de8b9e4b1a 126 rToRRaw = e.array1[0];
darienf 3:36de8b9e4b1a 127 ecgView.DisplayRToR(e.array1[0]);
darienf 3:36de8b9e4b1a 128 break;
darienf 3:36de8b9e4b1a 129 }
darienf 3:36de8b9e4b1a 130 }
darienf 3:36de8b9e4b1a 131 }
darienf 3:36de8b9e4b1a 132
darienf 3:36de8b9e4b1a 133 void ProcessBioZ(int[] rawData)
darienf 3:36de8b9e4b1a 134 {
darienf 3:36de8b9e4b1a 135 BioZFifo[] bioZFifo;
darienf 3:36de8b9e4b1a 136 double[] bioZImpedance;
darienf 3:36de8b9e4b1a 137
darienf 3:36de8b9e4b1a 138 bioZFifo = ConvertBioZ(rawData);
darienf 3:36de8b9e4b1a 139
darienf 3:36de8b9e4b1a 140 bioZImpedance = new double[bioZFifo.Length];
darienf 3:36de8b9e4b1a 141 for (int i = 0; i < bioZFifo.Length; i++)
darienf 3:36de8b9e4b1a 142 {
darienf 3:36de8b9e4b1a 143 bioZImpedance[i] = bioZFifo[i].Data;
darienf 3:36de8b9e4b1a 144 }
darienf 3:36de8b9e4b1a 145 ecgView.DisplayBioZ(bioZImpedance);
darienf 3:36de8b9e4b1a 146 }
darienf 3:36de8b9e4b1a 147
darienf 3:36de8b9e4b1a 148 public BioZFifo[] ConvertBioZ(int[] data)
darienf 3:36de8b9e4b1a 149 {
darienf 3:36de8b9e4b1a 150 BioZFifo[] impedence = new BioZFifo[data.Length];
darienf 3:36de8b9e4b1a 151 EcgView.ChartInfo chartInfo = ecgView.BioZInfo;
darienf 3:36de8b9e4b1a 152 int dataShift;
darienf 3:36de8b9e4b1a 153
darienf 3:36de8b9e4b1a 154 for (int i = 0; i < data.Length; i++)
darienf 3:36de8b9e4b1a 155 {
darienf 3:36de8b9e4b1a 156 dataShift = data[i] >> chartInfo.Shift;
darienf 3:36de8b9e4b1a 157
darienf 3:36de8b9e4b1a 158 // Two's Complement Conversions
darienf 3:36de8b9e4b1a 159 if (dataShift > chartInfo.Threshold)
darienf 3:36de8b9e4b1a 160 {
darienf 3:36de8b9e4b1a 161 dataShift -= chartInfo.Offset;
darienf 3:36de8b9e4b1a 162 }
darienf 3:36de8b9e4b1a 163
darienf 3:36de8b9e4b1a 164 // 1.9734 = 1/2^19 * 1e-6
darienf 3:36de8b9e4b1a 165 impedence[i].Data = dataShift * 1.9073486328125 /
darienf 3:36de8b9e4b1a 166 (chartInfo.Gain * ((chartInfo.CurrentGenerator == 0) ? 1 : chartInfo.CurrentGenerator));
darienf 3:36de8b9e4b1a 167 impedence[i].BTag = data[i] & 0x07;
darienf 3:36de8b9e4b1a 168 }
darienf 3:36de8b9e4b1a 169
darienf 3:36de8b9e4b1a 170 return impedence;
darienf 3:36de8b9e4b1a 171 }
darienf 3:36de8b9e4b1a 172
darienf 3:36de8b9e4b1a 173 public double[] ProcessEcg(int[] rawData)
darienf 3:36de8b9e4b1a 174 {
darienf 3:36de8b9e4b1a 175 EcgFifo[] ecgFifo;
darienf 3:36de8b9e4b1a 176 double[] ecgVoltage = new double[rawData.Length];
darienf 3:36de8b9e4b1a 177 double[] rToRInterval = null;
darienf 3:36de8b9e4b1a 178
darienf 3:36de8b9e4b1a 179 // Pace File Log
darienf 3:36de8b9e4b1a 180 string[] paceRegisterLog = new string[rawData.Length];
darienf 3:36de8b9e4b1a 181
darienf 3:36de8b9e4b1a 182 List<EcgView.PacePoint> pacePoints = new List<EcgView.PacePoint>();
darienf 3:36de8b9e4b1a 183
darienf 3:36de8b9e4b1a 184 ecgFifo = ConvertEcg(rawData);
darienf 3:36de8b9e4b1a 185
darienf 3:36de8b9e4b1a 186 // ECG
darienf 3:36de8b9e4b1a 187 for (int i = 0; i < ecgFifo.Length; i++)
darienf 3:36de8b9e4b1a 188 {
darienf 3:36de8b9e4b1a 189 ecgVoltage[i] = ecgFifo[i].Data;
darienf 3:36de8b9e4b1a 190
darienf 3:36de8b9e4b1a 191 if (ecgFifo[i].PTag != 0x07 && paceData != null) // Pace Event
darienf 3:36de8b9e4b1a 192 {
darienf 3:36de8b9e4b1a 193 PaceData.PaceRegister paceRegister = paceData.PaceGroup(ecgFifo[i].PTag); // Register Group
darienf 3:36de8b9e4b1a 194 PaceData.PaceEdge[] paceEdges = paceRegister.Edge; // Pace Edge
darienf 3:36de8b9e4b1a 195
darienf 3:36de8b9e4b1a 196 // Pace Charting Data
darienf 3:36de8b9e4b1a 197 int k = 0;
darienf 3:36de8b9e4b1a 198 PaceData.PaceEdge edge;
darienf 3:36de8b9e4b1a 199 do
darienf 3:36de8b9e4b1a 200 {
darienf 3:36de8b9e4b1a 201 edge = paceEdges[k];
darienf 3:36de8b9e4b1a 202 // Convert Pace into ECG samples
darienf 3:36de8b9e4b1a 203 // (Pace Raw / (2 * FMSTR )) / (1 / ECG Sample Rate) = Pace Raw * ECG Sample Rate / (2 * FMSTR)
darienf 3:36de8b9e4b1a 204 pacePoints.Add(new EcgView.PacePoint(i + (edge.Data * ecgView.SampleRateEcg / (2 * ecgView.MasterClockFrequency)), edge.Polarity));
darienf 3:36de8b9e4b1a 205
darienf 3:36de8b9e4b1a 206 k++;
darienf 3:36de8b9e4b1a 207 }
darienf 3:36de8b9e4b1a 208 while (!(edge.Last == true || k >= 6));
darienf 3:36de8b9e4b1a 209 }
darienf 3:36de8b9e4b1a 210 }
darienf 3:36de8b9e4b1a 211
darienf 3:36de8b9e4b1a 212 // R to R
darienf 3:36de8b9e4b1a 213 if (ecgView.EnableRToR)
darienf 3:36de8b9e4b1a 214 {
darienf 3:36de8b9e4b1a 215 rToRInterval = new double[rawData.Length];
darienf 3:36de8b9e4b1a 216 for (int i = 0; i < rToRInterval.Length; i++)
darienf 3:36de8b9e4b1a 217 {
darienf 3:36de8b9e4b1a 218 rToRInterval[i] = NoData;
darienf 3:36de8b9e4b1a 219 }
darienf 3:36de8b9e4b1a 220
darienf 3:36de8b9e4b1a 221 if (rToRRaw > 0)
darienf 3:36de8b9e4b1a 222 {
darienf 3:36de8b9e4b1a 223 rToRInterval[0] = ecgVoltage[0]; // Plot at height of ECG signal
darienf 3:36de8b9e4b1a 224 rToRRaw = NoRToR;
darienf 3:36de8b9e4b1a 225 }
darienf 3:36de8b9e4b1a 226 }
darienf 3:36de8b9e4b1a 227
darienf 3:36de8b9e4b1a 228 ecgView.DisplayEcg(ecgVoltage, pacePoints.ToArray(), rToRInterval);
darienf 3:36de8b9e4b1a 229
darienf 3:36de8b9e4b1a 230 return ecgVoltage;
darienf 3:36de8b9e4b1a 231 }
darienf 3:36de8b9e4b1a 232
darienf 3:36de8b9e4b1a 233 public EcgFifo[] ConvertEcg(int[] data)
darienf 3:36de8b9e4b1a 234 {
darienf 3:36de8b9e4b1a 235 EcgFifo[] voltage = new EcgFifo[data.Length];
darienf 3:36de8b9e4b1a 236 EcgView.ChartInfo chartInfo = ecgView.EcgInfo;
darienf 3:36de8b9e4b1a 237 int dataShift;
darienf 3:36de8b9e4b1a 238
darienf 3:36de8b9e4b1a 239 for (int i = 0; i < data.Length; i++)
darienf 3:36de8b9e4b1a 240 {
darienf 3:36de8b9e4b1a 241 dataShift = data[i] >> chartInfo.Shift;
darienf 3:36de8b9e4b1a 242
darienf 3:36de8b9e4b1a 243 // Two's Complement Conversions
darienf 3:36de8b9e4b1a 244 if (dataShift > chartInfo.Threshold)
darienf 3:36de8b9e4b1a 245 {
darienf 3:36de8b9e4b1a 246 dataShift -= chartInfo.Offset;
darienf 3:36de8b9e4b1a 247 }
darienf 3:36de8b9e4b1a 248
darienf 3:36de8b9e4b1a 249 voltage[i].Data = 1000 * 7.62939453125e-6 * dataShift / chartInfo.Gain;
darienf 3:36de8b9e4b1a 250 voltage[i].PTag = data[i] & 0x07;
darienf 3:36de8b9e4b1a 251 voltage[i].ETag = (data[i] >> 3) & 0x07;
darienf 3:36de8b9e4b1a 252 }
darienf 3:36de8b9e4b1a 253
darienf 3:36de8b9e4b1a 254 return voltage;
darienf 3:36de8b9e4b1a 255 }
darienf 3:36de8b9e4b1a 256
darienf 3:36de8b9e4b1a 257 public PaceData ProcessPace(int[] data)
darienf 3:36de8b9e4b1a 258 {
darienf 3:36de8b9e4b1a 259 paceData = new PaceData(data);
darienf 3:36de8b9e4b1a 260
darienf 3:36de8b9e4b1a 261 return paceData;
darienf 3:36de8b9e4b1a 262 }
darienf 3:36de8b9e4b1a 263
darienf 3:36de8b9e4b1a 264 }
darienf 3:36de8b9e4b1a 265 }