Darien Figueroa / Mbed 2 deprecated repo3

repo time

Dependencies:   mbed MAX14720 MAX30205 USBDevice

HspGuiSourceV301/HSPGui/Presenter/StreamPresenter.cs@20:6d2af70c92ab, 2021-04-06 (annotated)

Committer:
darienf
Date:
Tue Apr 06 06:41:40 2021 +0000
Revision:
20:6d2af70c92ab
another repo

Who changed what in which revision?

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