mirror of
https://gitlab.com/pholy/OSCAR-code.git
synced 2025-04-05 10:40:42 +00:00
Move PRS1 F3V03 parsing into separate F3 parser file.
No change in functionality.
Use git blame dd9a087 to follow the history before this refactoring.
This commit is contained in:
sawinglogz
parent
ded4ea4d8f
commit
26ce41927b
@ -2756,129 +2756,6 @@ void PRS1Import::ImportEvent(qint64 t, PRS1ParsedEvent* e)
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
const QVector<PRS1ParsedEventType> ParsedEventsF3V0 = {
|
|
||||||
PRS1IPAPAverageEvent::TYPE,
|
|
||||||
PRS1EPAPAverageEvent::TYPE,
|
|
||||||
PRS1TotalLeakEvent::TYPE,
|
|
||||||
PRS1TidalVolumeEvent::TYPE,
|
|
||||||
PRS1FlowRateEvent::TYPE,
|
|
||||||
PRS1PatientTriggeredBreathsEvent::TYPE,
|
|
||||||
PRS1RespiratoryRateEvent::TYPE,
|
|
||||||
PRS1MinuteVentilationEvent::TYPE,
|
|
||||||
// No LEAK, unlike F3V3
|
|
||||||
PRS1HypopneaCount::TYPE,
|
|
||||||
PRS1ClearAirwayCount::TYPE, // TODO
|
|
||||||
PRS1ObstructiveApneaCount::TYPE, // TODO
|
|
||||||
// No PP, FL, VS, RERA, PB, LL
|
|
||||||
// No TB
|
|
||||||
};
|
|
||||||
|
|
||||||
const QVector<PRS1ParsedEventType> ParsedEventsF3V3 = {
|
|
||||||
PRS1IPAPAverageEvent::TYPE,
|
|
||||||
PRS1EPAPAverageEvent::TYPE,
|
|
||||||
PRS1TotalLeakEvent::TYPE,
|
|
||||||
PRS1TidalVolumeEvent::TYPE,
|
|
||||||
PRS1FlowRateEvent::TYPE,
|
|
||||||
PRS1PatientTriggeredBreathsEvent::TYPE,
|
|
||||||
PRS1RespiratoryRateEvent::TYPE,
|
|
||||||
PRS1MinuteVentilationEvent::TYPE,
|
|
||||||
PRS1LeakEvent::TYPE,
|
|
||||||
PRS1HypopneaCount::TYPE,
|
|
||||||
PRS1ClearAirwayCount::TYPE,
|
|
||||||
PRS1ObstructiveApneaCount::TYPE,
|
|
||||||
// No PP, FL, VS, RERA, PB, LL
|
|
||||||
// No TB
|
|
||||||
};
|
|
||||||
|
|
||||||
// 1061, 1061T, 1160P series
|
|
||||||
bool PRS1DataChunk::ParseEventsF3V03(void)
|
|
||||||
{
|
|
||||||
// NOTE: Older ventilators (BiPAP S/T and AVAPS) machines don't use timestamped events like everything else.
|
|
||||||
// Instead, they use a fixed interval format like waveforms do (see PRS1_HTYPE_INTERVAL).
|
|
||||||
|
|
||||||
if (this->family != 3 || (this->familyVersion != 0 && this->familyVersion != 3)) {
|
|
||||||
qWarning() << "ParseEventsF3V03 called with family" << this->family << "familyVersion" << this->familyVersion;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
if (this->fileVersion == 3) {
|
|
||||||
// NOTE: The original comment in the header for ParseF3EventsV3 said there was a 1060P with fileVersion 3.
|
|
||||||
// We've never seen that, so warn if it ever shows up.
|
|
||||||
qWarning() << "F3V3 event file with fileVersion 3?";
|
|
||||||
}
|
|
||||||
|
|
||||||
int t = 0;
|
|
||||||
static const int record_size = 0x10;
|
|
||||||
int size = this->m_data.size()/record_size;
|
|
||||||
CHECK_VALUE(this->m_data.size() % record_size, 0);
|
|
||||||
unsigned char * h = (unsigned char *)this->m_data.data();
|
|
||||||
|
|
||||||
static const qint64 block_duration = 120;
|
|
||||||
|
|
||||||
// Make sure the assumptions here agree with the header
|
|
||||||
CHECK_VALUE(this->htype, PRS1_HTYPE_INTERVAL);
|
|
||||||
CHECK_VALUE(this->interval_count, size);
|
|
||||||
CHECK_VALUE(this->interval_seconds, block_duration);
|
|
||||||
for (auto & channel : this->waveformInfo) {
|
|
||||||
CHECK_VALUE(channel.interleave, 1);
|
|
||||||
}
|
|
||||||
|
|
||||||
for (int x=0; x < size; x++) {
|
|
||||||
// Use the timestamp of the end of this interval, to be consistent with other parsers,
|
|
||||||
// but see note below regarding the duration of the final interval.
|
|
||||||
t += block_duration;
|
|
||||||
|
|
||||||
// TODO: The duration of the final interval isn't clearly defined in this format:
|
|
||||||
// there appears to be no way (apart from looking at the summary or waveform data)
|
|
||||||
// to determine the end time, which may truncate the last interval.
|
|
||||||
//
|
|
||||||
// TODO: What if there are multiple "final" intervals in a session due to multiple
|
|
||||||
// mask-on slices?
|
|
||||||
this->AddEvent(new PRS1IPAPAverageEvent(t, h[0] | (h[1] << 8)));
|
|
||||||
this->AddEvent(new PRS1EPAPAverageEvent(t, h[2] | (h[3] << 8)));
|
|
||||||
this->AddEvent(new PRS1TotalLeakEvent(t, h[4]));
|
|
||||||
this->AddEvent(new PRS1TidalVolumeEvent(t, h[5]));
|
|
||||||
this->AddEvent(new PRS1FlowRateEvent(t, h[6]));
|
|
||||||
this->AddEvent(new PRS1PatientTriggeredBreathsEvent(t, h[7]));
|
|
||||||
this->AddEvent(new PRS1RespiratoryRateEvent(t, h[8]));
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
if (h[9] < 4 || h[9] > 65) UNEXPECTED_VALUE(h[9], "4-65");
|
|
||||||
} else {
|
|
||||||
if (h[9] < 4 || h[9] > 84) UNEXPECTED_VALUE(h[9], "5-84"); // not sure what this is.. encore doesn't graph it.
|
|
||||||
}
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
// 1 shows as Apnea (AP) alarm
|
|
||||||
// 2 shows as a Patient Disconnect (PD) alarm
|
|
||||||
// 4 shows as a Low Minute Vent (LMV) alarm
|
|
||||||
// 8 shows as a Low Pressure (LP) alarm
|
|
||||||
// 10 shows as PD + LP in the same interval
|
|
||||||
if (h[10] & ~(0x01 | 0x02 | 0x04 | 0x08)) UNEXPECTED_VALUE(h[10], "known bits");
|
|
||||||
} else {
|
|
||||||
// This is probably the same as F3V0, but we don't yet have the sample data to confirm.
|
|
||||||
CHECK_VALUES(h[10], 0, 8); // 8 shows as a Low Pressure (LP) alarm
|
|
||||||
}
|
|
||||||
this->AddEvent(new PRS1MinuteVentilationEvent(t, h[11]));
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
CHECK_VALUE(h[12], 0);
|
|
||||||
this->AddEvent(new PRS1HypopneaCount(t, h[13])); // count of hypopnea events
|
|
||||||
this->AddEvent(new PRS1ClearAirwayCount(t, h[14])); // count of clear airway events
|
|
||||||
this->AddEvent(new PRS1ObstructiveApneaCount(t, h[15])); // count of obstructive events
|
|
||||||
} else {
|
|
||||||
this->AddEvent(new PRS1HypopneaCount(t, h[12])); // count of hypopnea events
|
|
||||||
this->AddEvent(new PRS1ClearAirwayCount(t, h[13])); // count of clear airway events
|
|
||||||
this->AddEvent(new PRS1ObstructiveApneaCount(t, h[14])); // count of obstructive events
|
|
||||||
this->AddEvent(new PRS1LeakEvent(t, h[15]));
|
|
||||||
}
|
|
||||||
this->AddEvent(new PRS1IntervalBoundaryEvent(t));
|
|
||||||
|
|
||||||
h += record_size;
|
|
||||||
}
|
|
||||||
|
|
||||||
this->duration = t;
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
#if 0
|
#if 0
|
||||||
// Currently unused, apparently an abandoned effort to massage F0 pressure/IPAP/EPAP data.
|
// Currently unused, apparently an abandoned effort to massage F0 pressure/IPAP/EPAP data.
|
||||||
extern EventDataType CatmullRomSpline(EventDataType p0, EventDataType p1, EventDataType p2, EventDataType p3, EventDataType t = 0.5);
|
extern EventDataType CatmullRomSpline(EventDataType p0, EventDataType p1, EventDataType p2, EventDataType p3, EventDataType t = 0.5);
|
||||||
@ -3314,463 +3191,6 @@ void PRS1DataChunk::ParseHumidifierSetting60Series(unsigned char humid1, unsigne
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// XX XX = F3V3 Humidifier bytes
|
|
||||||
// 43 15 = heated tube temp 5, humidity 2
|
|
||||||
// 43 14 = heated tube temp 4, humidity 2
|
|
||||||
// 63 13 = heated tube temp 3, humidity 3
|
|
||||||
// 63 11 = heated tube temp 1, humidity 3
|
|
||||||
// 45 08 = system one 5
|
|
||||||
// 44 08 = system one 4
|
|
||||||
// 43 08 = system one 3
|
|
||||||
// 42 08 = system one 2
|
|
||||||
// 41 08 = system one 1
|
|
||||||
// 40 08 = system one 0 (off)
|
|
||||||
// 40 60 = system one 3, no data
|
|
||||||
// 40 20 = system one 3, no data
|
|
||||||
// 40 90 = heated tube, tube off, data=tube t=0,h=0
|
|
||||||
// 45 80 = classic 5
|
|
||||||
// 44 80 = classic 4
|
|
||||||
// 43 80 = classic 3
|
|
||||||
// 42 80 = classic 2
|
|
||||||
|
|
||||||
// 40 80 = classic 0 (off)
|
|
||||||
//
|
|
||||||
// 7 = humidity level without tube
|
|
||||||
// 8 = ? (never seen)
|
|
||||||
// 1 = ? (never seen)
|
|
||||||
// 6 = heated tube humidity level (when tube present, 0x40 all other times? including when tube is off?)
|
|
||||||
// 8 = ? (never seen)
|
|
||||||
// 7 = tube temp
|
|
||||||
// 8 = "System One" mode
|
|
||||||
// 1 = tube present
|
|
||||||
// 6 = no data, seems to show system one 3 in settings
|
|
||||||
// 8 = (classic mode; also seen when heated tube present but off, possibly ignored in that case)
|
|
||||||
//
|
|
||||||
// Note that, while containing similar fields as ParseHumidifierSetting60Series, the bit arrangement is different for F3V3!
|
|
||||||
|
|
||||||
void PRS1DataChunk::ParseHumidifierSettingF3V3(unsigned char humid1, unsigned char humid2, bool add_setting)
|
|
||||||
{
|
|
||||||
if (false) qWarning() << this->sessionid << "humid" << hex(humid1) << hex(humid2) << add_setting;
|
|
||||||
|
|
||||||
int humidlevel = humid1 & 7; // Ignored when heated tube is present: humidifier setting on tube disconnect is always reported as 3
|
|
||||||
if (humidlevel > 5) UNEXPECTED_VALUE(humidlevel, "<= 5");
|
|
||||||
CHECK_VALUE(humid1 & 0x40, 0x40); // seems always set, even without heated tube
|
|
||||||
CHECK_VALUE(humid1 & 0x98, 0); // never seen
|
|
||||||
int tubehumidlevel = (humid1 >> 5) & 7; // This mask is a best guess based on other masks.
|
|
||||||
if (tubehumidlevel > 5) UNEXPECTED_VALUE(tubehumidlevel, "<= 5");
|
|
||||||
CHECK_VALUE(tubehumidlevel & 4, 0); // never seen, but would clarify whether above mask is correct
|
|
||||||
|
|
||||||
int tubetemp = humid2 & 7;
|
|
||||||
if (tubetemp > 5) UNEXPECTED_VALUE(tubetemp, "<= 5");
|
|
||||||
|
|
||||||
if (humid2 & 0x60) {
|
|
||||||
CHECK_VALUES(humid2 & 0x60, 0x20, 0x60); // no humidifier data on chart
|
|
||||||
}
|
|
||||||
bool humidclassic = (humid2 & 0x80) != 0; // Set on classic mode reports; evidently ignored (sometimes set!) when tube is present
|
|
||||||
//bool no_tube? = (humid2 & 0x20) != 0; // Something tube related: whenever it is set, tube is never present (inverse is not true)
|
|
||||||
bool no_data = (humid2 & 0x60) != 0; // As described in chart, settings still show up
|
|
||||||
int tubepresent = (humid2 & 0x10) != 0;
|
|
||||||
bool humidsystemone = (humid2 & 0x08) != 0; // Set on "System One" humidification mode reports when tubepresent is false
|
|
||||||
|
|
||||||
if (humidsystemone + tubepresent + no_data == 0) CHECK_VALUE(humidclassic, true); // Always set when everything else is off in F0V4
|
|
||||||
if (humidsystemone + tubepresent /*+ no_data*/ > 1) UNEXPECTED_VALUE(humid2, "one bit set"); // Only one of these ever seems to be set at a time
|
|
||||||
//if (tubepresent && tubetemp == 0) CHECK_VALUE(tubehumidlevel, 0); // When the heated tube is off, tube humidity seems to be 0 in F0V4, but not F3V3
|
|
||||||
|
|
||||||
if (tubepresent) humidclassic = false; // Classic mode bit is evidently ignored when tube is present
|
|
||||||
|
|
||||||
//qWarning() << this->sessionid << (humidclassic ? "C" : ".") << (humid2 & 0x20 ? "?" : ".") << (tubepresent ? "T" : ".") << (no_data ? "X" : ".") << (humidsystemone ? "1" : ".");
|
|
||||||
/*
|
|
||||||
if (tubepresent) {
|
|
||||||
if (tubetemp) {
|
|
||||||
qWarning() << this->sessionid << "tube temp" << tubetemp << "tube humidity" << tubehumidlevel << (humidclassic ? "classic" : "systemone") << "humidity" << humidlevel;
|
|
||||||
} else {
|
|
||||||
qWarning() << this->sessionid << "heated tube off" << (humidclassic ? "classic" : "systemone") << "humidity" << humidlevel;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
qWarning() << this->sessionid << (humidclassic ? "classic" : "systemone") << "humidity" << humidlevel;
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
HumidMode humidmode = HUMID_Fixed;
|
|
||||||
if (tubepresent) {
|
|
||||||
humidmode = HUMID_HeatedTube;
|
|
||||||
} else {
|
|
||||||
if (humidsystemone + humidclassic > 1) UNEXPECTED_VALUE(humid2, "fixed or adaptive");
|
|
||||||
if (humidsystemone) humidmode = HUMID_Adaptive;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (add_setting) {
|
|
||||||
bool humidifier_present = (no_data == 0);
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HUMID_STATUS, humidifier_present));
|
|
||||||
if (humidifier_present) {
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HUMID_MODE, humidmode));
|
|
||||||
if (humidmode == HUMID_HeatedTube) {
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HEATED_TUBE_TEMP, tubetemp));
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HUMID_LEVEL, tubehumidlevel));
|
|
||||||
} else {
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HUMID_LEVEL, humidlevel));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Check for previously unseen data that we expect to be normal:
|
|
||||||
if (humidclassic && humidlevel == 1) UNEXPECTED_VALUE(humidlevel, "!= 1");
|
|
||||||
if (tubepresent) {
|
|
||||||
if (tubetemp) CHECK_VALUES(tubehumidlevel, 2, 3);
|
|
||||||
if (tubetemp == 2) UNEXPECTED_VALUE(tubetemp, "!= 2");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
// Support for 1061, 1061T, 1160P
|
|
||||||
// logic largely borrowed from ParseSettingsF3V6, values based on sample data
|
|
||||||
bool PRS1DataChunk::ParseSettingsF3V03(const unsigned char* data, int /*size*/)
|
|
||||||
{
|
|
||||||
PRS1Mode cpapmode = PRS1_MODE_UNKNOWN;
|
|
||||||
FlexMode flexmode = FLEX_Unknown;
|
|
||||||
|
|
||||||
// data[0] is the event code
|
|
||||||
// data[1] is checked in the calling function
|
|
||||||
|
|
||||||
switch (data[2]) {
|
|
||||||
case 0: cpapmode = PRS1_MODE_CPAP; break; // "CPAP" mode
|
|
||||||
case 1: cpapmode = PRS1_MODE_S; break; // "S" mode
|
|
||||||
case 2: cpapmode = PRS1_MODE_ST; break; // "S/T" mode; pressure seems variable?
|
|
||||||
case 4: cpapmode = PRS1_MODE_PC; break; // "PC" mode? Usually "PC - AVAPS", see setting 1 below
|
|
||||||
default:
|
|
||||||
UNEXPECTED_VALUE(data[2], "known device mode");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
switch (data[3]) {
|
|
||||||
case 0: // 0 = None
|
|
||||||
switch (cpapmode) {
|
|
||||||
case PRS1_MODE_CPAP: flexmode = FLEX_None; break;
|
|
||||||
case PRS1_MODE_S: flexmode = FLEX_RiseTime; break; // reports say "None" but then list a rise time setting
|
|
||||||
case PRS1_MODE_ST: flexmode = FLEX_RiseTime; break; // reports say "None" but then list a rise time setting
|
|
||||||
default:
|
|
||||||
UNEXPECTED_VALUE(cpapmode, "CPAP, S, or S/T");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case 1: // 1 = Bi-Flex, only seen with "S - Bi-Flex"
|
|
||||||
flexmode = FLEX_BiFlex;
|
|
||||||
CHECK_VALUE(cpapmode, PRS1_MODE_S);
|
|
||||||
break;
|
|
||||||
case 2: // 2 = AVAPS: usually "PC - AVAPS", sometimes "S/T - AVAPS"
|
|
||||||
switch (cpapmode) {
|
|
||||||
case PRS1_MODE_ST: cpapmode = PRS1_MODE_ST_AVAPS; break;
|
|
||||||
case PRS1_MODE_PC: cpapmode = PRS1_MODE_PC_AVAPS; break;
|
|
||||||
default:
|
|
||||||
UNEXPECTED_VALUE(cpapmode, "S/T or PC");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
flexmode = FLEX_RiseTime; // reports say "AVAPS" but then list a rise time setting
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
UNEXPECTED_VALUE(data[3], "known flex mode");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
// Confirm F3V0 setting encoding
|
|
||||||
switch (cpapmode) {
|
|
||||||
case PRS1_MODE_CPAP: break; // CPAP has been confirmed
|
|
||||||
case PRS1_MODE_S: break; // S bi-flex and rise time have been confirmed
|
|
||||||
case PRS1_MODE_ST:
|
|
||||||
CHECK_VALUE(flexmode, FLEX_RiseTime); // only rise time has been confirmed
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
UNEXPECTED_VALUE(cpapmode, "tested modes");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_CPAP_MODE, (int) cpapmode));
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_FLEX_MODE, (int) flexmode));
|
|
||||||
|
|
||||||
int epap = data[4] + (data[5] << 8); // 0x82 = EPAP 13 cmH2O; 0x78 = EPAP 12 cmH2O; 0x50 = EPAP 8 cmH2O
|
|
||||||
int min_ipap = data[6] + (data[7] << 8); // 0xA0 = IPAP 16 cmH2O; 0xBE = 19 cmH2O min IPAP (in AVAPS); 0x78 = IPAP 12 cmH2O
|
|
||||||
int max_ipap = data[8] + (data[9] << 8); // 0xAA = ???; 0x12C = 30 cmH2O max IPAP (in AVAPS); 0x78 = ???
|
|
||||||
switch (cpapmode) {
|
|
||||||
case PRS1_MODE_CPAP:
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_PRESSURE, epap));
|
|
||||||
CHECK_VALUE(min_ipap, 0);
|
|
||||||
CHECK_VALUE(max_ipap, 0);
|
|
||||||
break;
|
|
||||||
case PRS1_MODE_S:
|
|
||||||
case PRS1_MODE_ST:
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_EPAP, epap));
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_IPAP, min_ipap));
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_PS, min_ipap - epap));
|
|
||||||
//CHECK_VALUES(max_ipap, 170, 300);
|
|
||||||
break;
|
|
||||||
case PRS1_MODE_ST_AVAPS:
|
|
||||||
case PRS1_MODE_PC_AVAPS:
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_EPAP, epap));
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_IPAP_MIN, min_ipap));
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_IPAP_MAX, max_ipap));
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_PS_MIN, min_ipap - epap));
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_PS_MAX, max_ipap - epap));
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
UNEXPECTED_VALUE(cpapmode, "expected mode");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (cpapmode == PRS1_MODE_CPAP) {
|
|
||||||
CHECK_VALUE(flexmode, FLEX_None);
|
|
||||||
CHECK_VALUE(data[0xa], 0);
|
|
||||||
CHECK_VALUE(data[0xb], 0);
|
|
||||||
CHECK_VALUE(data[0xc], 0);
|
|
||||||
CHECK_VALUE(data[0xd], 0);
|
|
||||||
}
|
|
||||||
if (flexmode == FLEX_RiseTime) {
|
|
||||||
int rise_time = data[0xa]; // 1 = Rise Time Setting 1, 2 = Rise Time Setting 2, 3 = Rise Time Setting 3
|
|
||||||
if (rise_time < 1 || rise_time > 6) UNEXPECTED_VALUE(rise_time, "1-6"); // TODO: what is 0?
|
|
||||||
CHECK_VALUES(data[0xb], 0, 1); // 1 = Rise Time Lock (in "None" and AVAPS flex mode)
|
|
||||||
CHECK_VALUE(data[0xc], 0);
|
|
||||||
CHECK_VALUES(data[0xd], 0, 1); // TODO: What is this? It's usually 0.
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_RISE_TIME, rise_time));
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_RISE_TIME_LOCK, data[0xb] == 1));
|
|
||||||
} else if (flexmode == FLEX_BiFlex) {
|
|
||||||
CHECK_VALUES(data[0xa], 2, 3); // TODO: May also be Bi-Flex level? But how is this different from [0xc] below?
|
|
||||||
CHECK_VALUES(data[0xb], 0, 1); // TODO: What is this? It doesn't always match [0xd].
|
|
||||||
CHECK_VALUES(data[0xc], 2, 3);
|
|
||||||
CHECK_VALUE(data[0x0a], data[0xc]);
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_FLEX_LEVEL, data[0xc])); // 3 = Bi-Flex 3, 2 = Bi-Flex 2 (in bi-flex mode)
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_FLEX_LOCK, data[0xd] == 1));
|
|
||||||
}
|
|
||||||
|
|
||||||
if (flexmode == FLEX_None) CHECK_VALUE(data[0xe], 0);
|
|
||||||
if (cpapmode == PRS1_MODE_ST_AVAPS || cpapmode == PRS1_MODE_PC_AVAPS) {
|
|
||||||
if (data[0xe] < 24 || data[0xe] > 65) UNEXPECTED_VALUE(data[0xe], "24-65");
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_TIDAL_VOLUME, data[0xe] * 10.0));
|
|
||||||
} else if (flexmode == FLEX_BiFlex || flexmode == FLEX_RiseTime) {
|
|
||||||
CHECK_VALUE(data[0xe], 0x14); // 0x14 = ???
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
int breath_rate = data[0xf];
|
|
||||||
int timed_inspiration = data[0x10];
|
|
||||||
bool backup = false;
|
|
||||||
switch (cpapmode) {
|
|
||||||
case PRS1_MODE_CPAP:
|
|
||||||
CHECK_VALUE(breath_rate, 0);
|
|
||||||
CHECK_VALUE(timed_inspiration, 0);
|
|
||||||
break;
|
|
||||||
case PRS1_MODE_S:
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
CHECK_VALUE(breath_rate, 10);
|
|
||||||
CHECK_VALUE(timed_inspiration, 10);
|
|
||||||
} else {
|
|
||||||
CHECK_VALUE(breath_rate, 0);
|
|
||||||
CHECK_VALUE(timed_inspiration, 0);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case PRS1_MODE_PC_AVAPS:
|
|
||||||
CHECK_VALUE(breath_rate, 0); // only ever seen 0 on reports so far
|
|
||||||
CHECK_VALUE(timed_inspiration, 30);
|
|
||||||
backup = true;
|
|
||||||
break;
|
|
||||||
case PRS1_MODE_ST_AVAPS:
|
|
||||||
if (breath_rate) { // can be 0 on reports
|
|
||||||
CHECK_VALUES(breath_rate, 9, 10);
|
|
||||||
}
|
|
||||||
if (timed_inspiration < 10 || timed_inspiration > 30) UNEXPECTED_VALUE(timed_inspiration, "10-30");
|
|
||||||
backup = true;
|
|
||||||
break;
|
|
||||||
case PRS1_MODE_ST:
|
|
||||||
if (breath_rate < 8 || breath_rate > 18) UNEXPECTED_VALUE(breath_rate, "8-18"); // can this be 0?
|
|
||||||
if (timed_inspiration < 10 || timed_inspiration > 20) UNEXPECTED_VALUE(timed_inspiration, "10-20"); // 16 = 1.6s
|
|
||||||
backup = true;
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
UNEXPECTED_VALUE(cpapmode, "CPAP, S, S/T, or PC");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
if (backup) {
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_BACKUP_BREATH_MODE, PRS1Backup_Fixed));
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_BACKUP_BREATH_RATE, breath_rate));
|
|
||||||
this->AddEvent(new PRS1ScaledSettingEvent(PRS1_SETTING_BACKUP_TIMED_INSPIRATION, timed_inspiration, 0.1));
|
|
||||||
}
|
|
||||||
|
|
||||||
CHECK_VALUE(data[0x11], 0);
|
|
||||||
|
|
||||||
//CHECK_VALUE(data[0x12], 0x1E, 0x0F); // 0x1E = ramp time 30 minutes, 0x0F = ramp time 15 minutes
|
|
||||||
//CHECK_VALUE(data[0x13], 0x3C, 0x5A, 0x28); // 0x3C = ramp pressure 6 cmH2O, 0x28 = ramp pressure 4 cmH2O, 0x5A = ramp pressure 9 cmH2O
|
|
||||||
CHECK_VALUE(data[0x14], 0); // the ramp pressure is probably a 16-bit value like the ones above are
|
|
||||||
int ramp_time = data[0x12];
|
|
||||||
int ramp_pressure = data[0x13];
|
|
||||||
if (ramp_time > 0) {
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_RAMP_TIME, ramp_time));
|
|
||||||
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_RAMP_PRESSURE, ramp_pressure));
|
|
||||||
}
|
|
||||||
|
|
||||||
int pos;
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
ParseHumidifierSetting50Series(data[0x15], true);
|
|
||||||
pos = 0x16;
|
|
||||||
} else {
|
|
||||||
this->ParseHumidifierSettingF3V3(data[0x15], data[0x16], true);
|
|
||||||
|
|
||||||
// Menu options?
|
|
||||||
CHECK_VALUES(data[0x17], 0x10, 0x90); // 0x10 = resist 1; 0x90 = resist 1, resist lock
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_MASK_RESIST_LOCK, (data[0x17] & 0x80) != 0));
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_MASK_RESIST_SETTING, 1)); // only value seen so far, CHECK_VALUES above will flag any others
|
|
||||||
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_TUBING_LOCK, (data[0x18] & 0x80) != 0));
|
|
||||||
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HOSE_DIAMETER, (data[0x18] & 0x7f)));
|
|
||||||
CHECK_VALUES(data[0x18] & 0x7f, 22, 15); // 0x16 = tubing 22; 0x0F = tubing 15, 0x96 = tubing 22 with lock
|
|
||||||
pos = 0x19;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Alarms?
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
if (data[pos] != 0) {
|
|
||||||
CHECK_VALUES(data[pos], 10, 30); // Apnea alarm on F3V0
|
|
||||||
}
|
|
||||||
CHECK_VALUES(data[pos+1], 0, 15); // Disconnect alarm on F3V0
|
|
||||||
CHECK_VALUES(data[pos+2], 0, 17); // Low MV alarm on F3V0
|
|
||||||
} else {
|
|
||||||
CHECK_VALUE(data[pos], 0);
|
|
||||||
CHECK_VALUE(data[pos+1], 0);
|
|
||||||
CHECK_VALUE(data[pos+2], 0);
|
|
||||||
}
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
// borrowed largely from ParseSummaryF5V012
|
|
||||||
bool PRS1DataChunk::ParseSummaryF3V03(void)
|
|
||||||
{
|
|
||||||
if (this->family != 3 || (this->familyVersion > 3)) {
|
|
||||||
qWarning() << "ParseSummaryF3V03 called with family" << this->family << "familyVersion" << this->familyVersion;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
const unsigned char * data = (unsigned char *)this->m_data.constData();
|
|
||||||
int chunk_size = this->m_data.size();
|
|
||||||
QVector<int> minimum_sizes;
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
minimum_sizes = { 0x19, 3, 3, 9 };
|
|
||||||
} else {
|
|
||||||
minimum_sizes = { 0x1b, 3, 5, 9 };
|
|
||||||
}
|
|
||||||
// NOTE: These are fixed sizes, but are called minimum to more closely match the F0V6 parser.
|
|
||||||
|
|
||||||
bool ok = true;
|
|
||||||
int pos = 0;
|
|
||||||
int code, size;
|
|
||||||
int tt = 0;
|
|
||||||
while (ok && pos < chunk_size) {
|
|
||||||
code = data[pos++];
|
|
||||||
// There is no hblock prior to F3V6.
|
|
||||||
size = 0;
|
|
||||||
if (code < minimum_sizes.length()) {
|
|
||||||
// make sure the handlers below don't go past the end of the buffer
|
|
||||||
size = minimum_sizes[code];
|
|
||||||
} // else if it's past ncodes, we'll log its information below (rather than handle it)
|
|
||||||
if (pos + size > chunk_size) {
|
|
||||||
qWarning() << this->sessionid << "slice" << code << "@" << pos << "longer than remaining chunk";
|
|
||||||
ok = false;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
// NOTE: F3V3 doesn't use 16-bit time deltas in its summary events, it uses absolute timestamps!
|
|
||||||
// It's possible that these are 24-bit, but haven't yet seen a timestamp that large.
|
|
||||||
|
|
||||||
const unsigned char * ondata = data;
|
|
||||||
switch (code) {
|
|
||||||
case 0: // Equipment On
|
|
||||||
CHECK_VALUE(pos, 1); // Always first
|
|
||||||
if (this->familyVersion == 0) {
|
|
||||||
// F3V0 inserts an extra byte in front
|
|
||||||
CHECK_VALUE(data[pos], 1);
|
|
||||||
ondata = ondata + 1;
|
|
||||||
}
|
|
||||||
CHECK_VALUE(ondata[pos], 0);
|
|
||||||
/*
|
|
||||||
CHECK_VALUE(data[pos] & 0xF0, 0); // TODO: what are these?
|
|
||||||
if ((data[pos] & 0x0F) != 1) { // This is the most frequent value.
|
|
||||||
//CHECK_VALUES(data[pos] & 0x0F, 3, 5); // TODO: what are these? 0 seems to be related to errors.
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
// F3V3 doesn't have a separate settings record like F3V6 does, the settings just follow the EquipmentOn data.
|
|
||||||
ok = this->ParseSettingsF3V03(ondata, size);
|
|
||||||
break;
|
|
||||||
case 2: // Mask On
|
|
||||||
tt = data[pos] | (data[pos+1] << 8);
|
|
||||||
this->AddEvent(new PRS1ParsedSliceEvent(tt, MaskOn));
|
|
||||||
CHECK_VALUE(data[pos+2], 0); // may be high byte of timestamp
|
|
||||||
if (size > 3) { // F3V3 records the humidifier setting at each mask-on, F3V0 only records the initial setting.
|
|
||||||
this->ParseHumidifierSettingF3V3(data[pos+3], data[pos+4]);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case 3: // Mask Off
|
|
||||||
tt = data[pos] | (data[pos+1] << 8);
|
|
||||||
this->AddEvent(new PRS1ParsedSliceEvent(tt, MaskOff));
|
|
||||||
// F3V3 doesn't have a separate stats record like F3V6 does, the stats just follow the MaskOff data.
|
|
||||||
CHECK_VALUE(data[pos+0x2], 0); // may be high byte of timestamp
|
|
||||||
//CHECK_VALUES(data[pos+0x3], 0, 1); // OA count, probably 16-bit
|
|
||||||
CHECK_VALUE(data[pos+0x4], 0);
|
|
||||||
//CHECK_VALUE(data[pos+0x5], 0); // CA count, probably 16-bit
|
|
||||||
CHECK_VALUE(data[pos+0x6], 0);
|
|
||||||
//CHECK_VALUE(data[pos+0x7], 0); // H count, probably 16-bit
|
|
||||||
CHECK_VALUE(data[pos+0x8], 0);
|
|
||||||
break;
|
|
||||||
case 1: // Equipment Off
|
|
||||||
tt = data[pos] | (data[pos+1] << 8);
|
|
||||||
this->AddEvent(new PRS1ParsedSliceEvent(tt, EquipmentOff));
|
|
||||||
CHECK_VALUE(data[pos+2], 0); // may be high byte of timestamp
|
|
||||||
break;
|
|
||||||
/*
|
|
||||||
case 5: // Clock adjustment? See ParseSummaryF0V4.
|
|
||||||
CHECK_VALUE(pos, 1); // Always first
|
|
||||||
CHECK_VALUE(chunk_size, 5); // and the only record in the session.
|
|
||||||
if (false) {
|
|
||||||
long value = data[pos] | data[pos+1]<<8 | data[pos+2]<<16 | data[pos+3]<<24;
|
|
||||||
qDebug() << this->sessionid << "clock changing from" << ts(value * 1000L)
|
|
||||||
<< "to" << ts(this->timestamp * 1000L)
|
|
||||||
<< "delta:" << (this->timestamp - value);
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case 6: // Cleared?
|
|
||||||
// Appears in the very first session when that session number is > 1.
|
|
||||||
// Presumably previous sessions were cleared out.
|
|
||||||
// TODO: add an internal event for this.
|
|
||||||
CHECK_VALUE(pos, 1); // Always first
|
|
||||||
CHECK_VALUE(chunk_size, 1); // and the only record in the session.
|
|
||||||
if (this->sessionid == 1) UNEXPECTED_VALUE(this->sessionid, ">1");
|
|
||||||
break;
|
|
||||||
case 7: // ???
|
|
||||||
tt += data[pos] | (data[pos+1] << 8); // This adds to the total duration (otherwise it won't match report)
|
|
||||||
break;
|
|
||||||
case 8: // ???
|
|
||||||
tt += data[pos] | (data[pos+1] << 8); // Since 7 and 8 seem to occur near each other, let's assume 8 also has a timestamp
|
|
||||||
CHECK_VALUE(pos, 1);
|
|
||||||
CHECK_VALUE(chunk_size, 3);
|
|
||||||
CHECK_VALUE(data[pos], 0); // and alert us if the timestamp is nonzero
|
|
||||||
CHECK_VALUE(data[pos+1], 0);
|
|
||||||
break;
|
|
||||||
case 9: // Humidifier setting change
|
|
||||||
tt += data[pos] | (data[pos+1] << 8); // This adds to the total duration (otherwise it won't match report)
|
|
||||||
this->ParseHumidifierSetting60Series(data[pos+2], data[pos+3]);
|
|
||||||
break;
|
|
||||||
*/
|
|
||||||
default:
|
|
||||||
UNEXPECTED_VALUE(code, "known slice code");
|
|
||||||
ok = false; // unlike F0V6, we don't know the size of unknown slices, so we can't recover
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
pos += size;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (ok && pos != chunk_size) {
|
|
||||||
qWarning() << this->sessionid << (this->size() - pos) << "trailing bytes";
|
|
||||||
}
|
|
||||||
|
|
||||||
this->duration = tt;
|
|
||||||
|
|
||||||
return ok;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
bool PRS1DataChunk::ParseSettingsF5V012(const unsigned char* data, int /*size*/)
|
bool PRS1DataChunk::ParseSettingsF5V012(const unsigned char* data, int /*size*/)
|
||||||
{
|
{
|
||||||
PRS1Mode cpapmode = PRS1_MODE_UNKNOWN;
|
PRS1Mode cpapmode = PRS1_MODE_UNKNOWN;
|
||||||
|
|||||||
@ -10,6 +10,591 @@
|
|||||||
#include "prs1_parser.h"
|
#include "prs1_parser.h"
|
||||||
#include "prs1_loader.h"
|
#include "prs1_loader.h"
|
||||||
|
|
||||||
|
static QString hex(int i)
|
||||||
|
{
|
||||||
|
return QString("0x") + QString::number(i, 16).toUpper();
|
||||||
|
}
|
||||||
|
|
||||||
|
// borrowed largely from ParseSummaryF5V012
|
||||||
|
bool PRS1DataChunk::ParseSummaryF3V03(void)
|
||||||
|
{
|
||||||
|
if (this->family != 3 || (this->familyVersion > 3)) {
|
||||||
|
qWarning() << "ParseSummaryF3V03 called with family" << this->family << "familyVersion" << this->familyVersion;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
const unsigned char * data = (unsigned char *)this->m_data.constData();
|
||||||
|
int chunk_size = this->m_data.size();
|
||||||
|
QVector<int> minimum_sizes;
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
minimum_sizes = { 0x19, 3, 3, 9 };
|
||||||
|
} else {
|
||||||
|
minimum_sizes = { 0x1b, 3, 5, 9 };
|
||||||
|
}
|
||||||
|
// NOTE: These are fixed sizes, but are called minimum to more closely match the F0V6 parser.
|
||||||
|
|
||||||
|
bool ok = true;
|
||||||
|
int pos = 0;
|
||||||
|
int code, size;
|
||||||
|
int tt = 0;
|
||||||
|
while (ok && pos < chunk_size) {
|
||||||
|
code = data[pos++];
|
||||||
|
// There is no hblock prior to F3V6.
|
||||||
|
size = 0;
|
||||||
|
if (code < minimum_sizes.length()) {
|
||||||
|
// make sure the handlers below don't go past the end of the buffer
|
||||||
|
size = minimum_sizes[code];
|
||||||
|
} // else if it's past ncodes, we'll log its information below (rather than handle it)
|
||||||
|
if (pos + size > chunk_size) {
|
||||||
|
qWarning() << this->sessionid << "slice" << code << "@" << pos << "longer than remaining chunk";
|
||||||
|
ok = false;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
// NOTE: F3V3 doesn't use 16-bit time deltas in its summary events, it uses absolute timestamps!
|
||||||
|
// It's possible that these are 24-bit, but haven't yet seen a timestamp that large.
|
||||||
|
|
||||||
|
const unsigned char * ondata = data;
|
||||||
|
switch (code) {
|
||||||
|
case 0: // Equipment On
|
||||||
|
CHECK_VALUE(pos, 1); // Always first
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
// F3V0 inserts an extra byte in front
|
||||||
|
CHECK_VALUE(data[pos], 1);
|
||||||
|
ondata = ondata + 1;
|
||||||
|
}
|
||||||
|
CHECK_VALUE(ondata[pos], 0);
|
||||||
|
/*
|
||||||
|
CHECK_VALUE(data[pos] & 0xF0, 0); // TODO: what are these?
|
||||||
|
if ((data[pos] & 0x0F) != 1) { // This is the most frequent value.
|
||||||
|
//CHECK_VALUES(data[pos] & 0x0F, 3, 5); // TODO: what are these? 0 seems to be related to errors.
|
||||||
|
}
|
||||||
|
*/
|
||||||
|
// F3V3 doesn't have a separate settings record like F3V6 does, the settings just follow the EquipmentOn data.
|
||||||
|
ok = this->ParseSettingsF3V03(ondata, size);
|
||||||
|
break;
|
||||||
|
case 2: // Mask On
|
||||||
|
tt = data[pos] | (data[pos+1] << 8);
|
||||||
|
this->AddEvent(new PRS1ParsedSliceEvent(tt, MaskOn));
|
||||||
|
CHECK_VALUE(data[pos+2], 0); // may be high byte of timestamp
|
||||||
|
if (size > 3) { // F3V3 records the humidifier setting at each mask-on, F3V0 only records the initial setting.
|
||||||
|
this->ParseHumidifierSettingF3V3(data[pos+3], data[pos+4]);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 3: // Mask Off
|
||||||
|
tt = data[pos] | (data[pos+1] << 8);
|
||||||
|
this->AddEvent(new PRS1ParsedSliceEvent(tt, MaskOff));
|
||||||
|
// F3V3 doesn't have a separate stats record like F3V6 does, the stats just follow the MaskOff data.
|
||||||
|
CHECK_VALUE(data[pos+0x2], 0); // may be high byte of timestamp
|
||||||
|
//CHECK_VALUES(data[pos+0x3], 0, 1); // OA count, probably 16-bit
|
||||||
|
CHECK_VALUE(data[pos+0x4], 0);
|
||||||
|
//CHECK_VALUE(data[pos+0x5], 0); // CA count, probably 16-bit
|
||||||
|
CHECK_VALUE(data[pos+0x6], 0);
|
||||||
|
//CHECK_VALUE(data[pos+0x7], 0); // H count, probably 16-bit
|
||||||
|
CHECK_VALUE(data[pos+0x8], 0);
|
||||||
|
break;
|
||||||
|
case 1: // Equipment Off
|
||||||
|
tt = data[pos] | (data[pos+1] << 8);
|
||||||
|
this->AddEvent(new PRS1ParsedSliceEvent(tt, EquipmentOff));
|
||||||
|
CHECK_VALUE(data[pos+2], 0); // may be high byte of timestamp
|
||||||
|
break;
|
||||||
|
/*
|
||||||
|
case 5: // Clock adjustment? See ParseSummaryF0V4.
|
||||||
|
CHECK_VALUE(pos, 1); // Always first
|
||||||
|
CHECK_VALUE(chunk_size, 5); // and the only record in the session.
|
||||||
|
if (false) {
|
||||||
|
long value = data[pos] | data[pos+1]<<8 | data[pos+2]<<16 | data[pos+3]<<24;
|
||||||
|
qDebug() << this->sessionid << "clock changing from" << ts(value * 1000L)
|
||||||
|
<< "to" << ts(this->timestamp * 1000L)
|
||||||
|
<< "delta:" << (this->timestamp - value);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 6: // Cleared?
|
||||||
|
// Appears in the very first session when that session number is > 1.
|
||||||
|
// Presumably previous sessions were cleared out.
|
||||||
|
// TODO: add an internal event for this.
|
||||||
|
CHECK_VALUE(pos, 1); // Always first
|
||||||
|
CHECK_VALUE(chunk_size, 1); // and the only record in the session.
|
||||||
|
if (this->sessionid == 1) UNEXPECTED_VALUE(this->sessionid, ">1");
|
||||||
|
break;
|
||||||
|
case 7: // ???
|
||||||
|
tt += data[pos] | (data[pos+1] << 8); // This adds to the total duration (otherwise it won't match report)
|
||||||
|
break;
|
||||||
|
case 8: // ???
|
||||||
|
tt += data[pos] | (data[pos+1] << 8); // Since 7 and 8 seem to occur near each other, let's assume 8 also has a timestamp
|
||||||
|
CHECK_VALUE(pos, 1);
|
||||||
|
CHECK_VALUE(chunk_size, 3);
|
||||||
|
CHECK_VALUE(data[pos], 0); // and alert us if the timestamp is nonzero
|
||||||
|
CHECK_VALUE(data[pos+1], 0);
|
||||||
|
break;
|
||||||
|
case 9: // Humidifier setting change
|
||||||
|
tt += data[pos] | (data[pos+1] << 8); // This adds to the total duration (otherwise it won't match report)
|
||||||
|
this->ParseHumidifierSetting60Series(data[pos+2], data[pos+3]);
|
||||||
|
break;
|
||||||
|
*/
|
||||||
|
default:
|
||||||
|
UNEXPECTED_VALUE(code, "known slice code");
|
||||||
|
ok = false; // unlike F0V6, we don't know the size of unknown slices, so we can't recover
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
pos += size;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (ok && pos != chunk_size) {
|
||||||
|
qWarning() << this->sessionid << (this->size() - pos) << "trailing bytes";
|
||||||
|
}
|
||||||
|
|
||||||
|
this->duration = tt;
|
||||||
|
|
||||||
|
return ok;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// Support for 1061, 1061T, 1160P
|
||||||
|
// logic largely borrowed from ParseSettingsF3V6, values based on sample data
|
||||||
|
bool PRS1DataChunk::ParseSettingsF3V03(const unsigned char* data, int /*size*/)
|
||||||
|
{
|
||||||
|
PRS1Mode cpapmode = PRS1_MODE_UNKNOWN;
|
||||||
|
FlexMode flexmode = FLEX_Unknown;
|
||||||
|
|
||||||
|
// data[0] is the event code
|
||||||
|
// data[1] is checked in the calling function
|
||||||
|
|
||||||
|
switch (data[2]) {
|
||||||
|
case 0: cpapmode = PRS1_MODE_CPAP; break; // "CPAP" mode
|
||||||
|
case 1: cpapmode = PRS1_MODE_S; break; // "S" mode
|
||||||
|
case 2: cpapmode = PRS1_MODE_ST; break; // "S/T" mode; pressure seems variable?
|
||||||
|
case 4: cpapmode = PRS1_MODE_PC; break; // "PC" mode? Usually "PC - AVAPS", see setting 1 below
|
||||||
|
default:
|
||||||
|
UNEXPECTED_VALUE(data[2], "known device mode");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
switch (data[3]) {
|
||||||
|
case 0: // 0 = None
|
||||||
|
switch (cpapmode) {
|
||||||
|
case PRS1_MODE_CPAP: flexmode = FLEX_None; break;
|
||||||
|
case PRS1_MODE_S: flexmode = FLEX_RiseTime; break; // reports say "None" but then list a rise time setting
|
||||||
|
case PRS1_MODE_ST: flexmode = FLEX_RiseTime; break; // reports say "None" but then list a rise time setting
|
||||||
|
default:
|
||||||
|
UNEXPECTED_VALUE(cpapmode, "CPAP, S, or S/T");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 1: // 1 = Bi-Flex, only seen with "S - Bi-Flex"
|
||||||
|
flexmode = FLEX_BiFlex;
|
||||||
|
CHECK_VALUE(cpapmode, PRS1_MODE_S);
|
||||||
|
break;
|
||||||
|
case 2: // 2 = AVAPS: usually "PC - AVAPS", sometimes "S/T - AVAPS"
|
||||||
|
switch (cpapmode) {
|
||||||
|
case PRS1_MODE_ST: cpapmode = PRS1_MODE_ST_AVAPS; break;
|
||||||
|
case PRS1_MODE_PC: cpapmode = PRS1_MODE_PC_AVAPS; break;
|
||||||
|
default:
|
||||||
|
UNEXPECTED_VALUE(cpapmode, "S/T or PC");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
flexmode = FLEX_RiseTime; // reports say "AVAPS" but then list a rise time setting
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
UNEXPECTED_VALUE(data[3], "known flex mode");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
// Confirm F3V0 setting encoding
|
||||||
|
switch (cpapmode) {
|
||||||
|
case PRS1_MODE_CPAP: break; // CPAP has been confirmed
|
||||||
|
case PRS1_MODE_S: break; // S bi-flex and rise time have been confirmed
|
||||||
|
case PRS1_MODE_ST:
|
||||||
|
CHECK_VALUE(flexmode, FLEX_RiseTime); // only rise time has been confirmed
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
UNEXPECTED_VALUE(cpapmode, "tested modes");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_CPAP_MODE, (int) cpapmode));
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_FLEX_MODE, (int) flexmode));
|
||||||
|
|
||||||
|
int epap = data[4] + (data[5] << 8); // 0x82 = EPAP 13 cmH2O; 0x78 = EPAP 12 cmH2O; 0x50 = EPAP 8 cmH2O
|
||||||
|
int min_ipap = data[6] + (data[7] << 8); // 0xA0 = IPAP 16 cmH2O; 0xBE = 19 cmH2O min IPAP (in AVAPS); 0x78 = IPAP 12 cmH2O
|
||||||
|
int max_ipap = data[8] + (data[9] << 8); // 0xAA = ???; 0x12C = 30 cmH2O max IPAP (in AVAPS); 0x78 = ???
|
||||||
|
switch (cpapmode) {
|
||||||
|
case PRS1_MODE_CPAP:
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_PRESSURE, epap));
|
||||||
|
CHECK_VALUE(min_ipap, 0);
|
||||||
|
CHECK_VALUE(max_ipap, 0);
|
||||||
|
break;
|
||||||
|
case PRS1_MODE_S:
|
||||||
|
case PRS1_MODE_ST:
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_EPAP, epap));
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_IPAP, min_ipap));
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_PS, min_ipap - epap));
|
||||||
|
//CHECK_VALUES(max_ipap, 170, 300);
|
||||||
|
break;
|
||||||
|
case PRS1_MODE_ST_AVAPS:
|
||||||
|
case PRS1_MODE_PC_AVAPS:
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_EPAP, epap));
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_IPAP_MIN, min_ipap));
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_IPAP_MAX, max_ipap));
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_PS_MIN, min_ipap - epap));
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_PS_MAX, max_ipap - epap));
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
UNEXPECTED_VALUE(cpapmode, "expected mode");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (cpapmode == PRS1_MODE_CPAP) {
|
||||||
|
CHECK_VALUE(flexmode, FLEX_None);
|
||||||
|
CHECK_VALUE(data[0xa], 0);
|
||||||
|
CHECK_VALUE(data[0xb], 0);
|
||||||
|
CHECK_VALUE(data[0xc], 0);
|
||||||
|
CHECK_VALUE(data[0xd], 0);
|
||||||
|
}
|
||||||
|
if (flexmode == FLEX_RiseTime) {
|
||||||
|
int rise_time = data[0xa]; // 1 = Rise Time Setting 1, 2 = Rise Time Setting 2, 3 = Rise Time Setting 3
|
||||||
|
if (rise_time < 1 || rise_time > 6) UNEXPECTED_VALUE(rise_time, "1-6"); // TODO: what is 0?
|
||||||
|
CHECK_VALUES(data[0xb], 0, 1); // 1 = Rise Time Lock (in "None" and AVAPS flex mode)
|
||||||
|
CHECK_VALUE(data[0xc], 0);
|
||||||
|
CHECK_VALUES(data[0xd], 0, 1); // TODO: What is this? It's usually 0.
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_RISE_TIME, rise_time));
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_RISE_TIME_LOCK, data[0xb] == 1));
|
||||||
|
} else if (flexmode == FLEX_BiFlex) {
|
||||||
|
CHECK_VALUES(data[0xa], 2, 3); // TODO: May also be Bi-Flex level? But how is this different from [0xc] below?
|
||||||
|
CHECK_VALUES(data[0xb], 0, 1); // TODO: What is this? It doesn't always match [0xd].
|
||||||
|
CHECK_VALUES(data[0xc], 2, 3);
|
||||||
|
CHECK_VALUE(data[0x0a], data[0xc]);
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_FLEX_LEVEL, data[0xc])); // 3 = Bi-Flex 3, 2 = Bi-Flex 2 (in bi-flex mode)
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_FLEX_LOCK, data[0xd] == 1));
|
||||||
|
}
|
||||||
|
|
||||||
|
if (flexmode == FLEX_None) CHECK_VALUE(data[0xe], 0);
|
||||||
|
if (cpapmode == PRS1_MODE_ST_AVAPS || cpapmode == PRS1_MODE_PC_AVAPS) {
|
||||||
|
if (data[0xe] < 24 || data[0xe] > 65) UNEXPECTED_VALUE(data[0xe], "24-65");
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_TIDAL_VOLUME, data[0xe] * 10.0));
|
||||||
|
} else if (flexmode == FLEX_BiFlex || flexmode == FLEX_RiseTime) {
|
||||||
|
CHECK_VALUE(data[0xe], 0x14); // 0x14 = ???
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
int breath_rate = data[0xf];
|
||||||
|
int timed_inspiration = data[0x10];
|
||||||
|
bool backup = false;
|
||||||
|
switch (cpapmode) {
|
||||||
|
case PRS1_MODE_CPAP:
|
||||||
|
CHECK_VALUE(breath_rate, 0);
|
||||||
|
CHECK_VALUE(timed_inspiration, 0);
|
||||||
|
break;
|
||||||
|
case PRS1_MODE_S:
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
CHECK_VALUE(breath_rate, 10);
|
||||||
|
CHECK_VALUE(timed_inspiration, 10);
|
||||||
|
} else {
|
||||||
|
CHECK_VALUE(breath_rate, 0);
|
||||||
|
CHECK_VALUE(timed_inspiration, 0);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case PRS1_MODE_PC_AVAPS:
|
||||||
|
CHECK_VALUE(breath_rate, 0); // only ever seen 0 on reports so far
|
||||||
|
CHECK_VALUE(timed_inspiration, 30);
|
||||||
|
backup = true;
|
||||||
|
break;
|
||||||
|
case PRS1_MODE_ST_AVAPS:
|
||||||
|
if (breath_rate) { // can be 0 on reports
|
||||||
|
CHECK_VALUES(breath_rate, 9, 10);
|
||||||
|
}
|
||||||
|
if (timed_inspiration < 10 || timed_inspiration > 30) UNEXPECTED_VALUE(timed_inspiration, "10-30");
|
||||||
|
backup = true;
|
||||||
|
break;
|
||||||
|
case PRS1_MODE_ST:
|
||||||
|
if (breath_rate < 8 || breath_rate > 18) UNEXPECTED_VALUE(breath_rate, "8-18"); // can this be 0?
|
||||||
|
if (timed_inspiration < 10 || timed_inspiration > 20) UNEXPECTED_VALUE(timed_inspiration, "10-20"); // 16 = 1.6s
|
||||||
|
backup = true;
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
UNEXPECTED_VALUE(cpapmode, "CPAP, S, S/T, or PC");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
if (backup) {
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_BACKUP_BREATH_MODE, PRS1Backup_Fixed));
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_BACKUP_BREATH_RATE, breath_rate));
|
||||||
|
this->AddEvent(new PRS1ScaledSettingEvent(PRS1_SETTING_BACKUP_TIMED_INSPIRATION, timed_inspiration, 0.1));
|
||||||
|
}
|
||||||
|
|
||||||
|
CHECK_VALUE(data[0x11], 0);
|
||||||
|
|
||||||
|
//CHECK_VALUE(data[0x12], 0x1E, 0x0F); // 0x1E = ramp time 30 minutes, 0x0F = ramp time 15 minutes
|
||||||
|
//CHECK_VALUE(data[0x13], 0x3C, 0x5A, 0x28); // 0x3C = ramp pressure 6 cmH2O, 0x28 = ramp pressure 4 cmH2O, 0x5A = ramp pressure 9 cmH2O
|
||||||
|
CHECK_VALUE(data[0x14], 0); // the ramp pressure is probably a 16-bit value like the ones above are
|
||||||
|
int ramp_time = data[0x12];
|
||||||
|
int ramp_pressure = data[0x13];
|
||||||
|
if (ramp_time > 0) {
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_RAMP_TIME, ramp_time));
|
||||||
|
this->AddEvent(new PRS1PressureSettingEvent(PRS1_SETTING_RAMP_PRESSURE, ramp_pressure));
|
||||||
|
}
|
||||||
|
|
||||||
|
int pos;
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
ParseHumidifierSetting50Series(data[0x15], true);
|
||||||
|
pos = 0x16;
|
||||||
|
} else {
|
||||||
|
this->ParseHumidifierSettingF3V3(data[0x15], data[0x16], true);
|
||||||
|
|
||||||
|
// Menu options?
|
||||||
|
CHECK_VALUES(data[0x17], 0x10, 0x90); // 0x10 = resist 1; 0x90 = resist 1, resist lock
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_MASK_RESIST_LOCK, (data[0x17] & 0x80) != 0));
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_MASK_RESIST_SETTING, 1)); // only value seen so far, CHECK_VALUES above will flag any others
|
||||||
|
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_TUBING_LOCK, (data[0x18] & 0x80) != 0));
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HOSE_DIAMETER, (data[0x18] & 0x7f)));
|
||||||
|
CHECK_VALUES(data[0x18] & 0x7f, 22, 15); // 0x16 = tubing 22; 0x0F = tubing 15, 0x96 = tubing 22 with lock
|
||||||
|
pos = 0x19;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Alarms?
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
if (data[pos] != 0) {
|
||||||
|
CHECK_VALUES(data[pos], 10, 30); // Apnea alarm on F3V0
|
||||||
|
}
|
||||||
|
CHECK_VALUES(data[pos+1], 0, 15); // Disconnect alarm on F3V0
|
||||||
|
CHECK_VALUES(data[pos+2], 0, 17); // Low MV alarm on F3V0
|
||||||
|
} else {
|
||||||
|
CHECK_VALUE(data[pos], 0);
|
||||||
|
CHECK_VALUE(data[pos+1], 0);
|
||||||
|
CHECK_VALUE(data[pos+2], 0);
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// XX XX = F3V3 Humidifier bytes
|
||||||
|
// 43 15 = heated tube temp 5, humidity 2
|
||||||
|
// 43 14 = heated tube temp 4, humidity 2
|
||||||
|
// 63 13 = heated tube temp 3, humidity 3
|
||||||
|
// 63 11 = heated tube temp 1, humidity 3
|
||||||
|
// 45 08 = system one 5
|
||||||
|
// 44 08 = system one 4
|
||||||
|
// 43 08 = system one 3
|
||||||
|
// 42 08 = system one 2
|
||||||
|
// 41 08 = system one 1
|
||||||
|
// 40 08 = system one 0 (off)
|
||||||
|
// 40 60 = system one 3, no data
|
||||||
|
// 40 20 = system one 3, no data
|
||||||
|
// 40 90 = heated tube, tube off, data=tube t=0,h=0
|
||||||
|
// 45 80 = classic 5
|
||||||
|
// 44 80 = classic 4
|
||||||
|
// 43 80 = classic 3
|
||||||
|
// 42 80 = classic 2
|
||||||
|
|
||||||
|
// 40 80 = classic 0 (off)
|
||||||
|
//
|
||||||
|
// 7 = humidity level without tube
|
||||||
|
// 8 = ? (never seen)
|
||||||
|
// 1 = ? (never seen)
|
||||||
|
// 6 = heated tube humidity level (when tube present, 0x40 all other times? including when tube is off?)
|
||||||
|
// 8 = ? (never seen)
|
||||||
|
// 7 = tube temp
|
||||||
|
// 8 = "System One" mode
|
||||||
|
// 1 = tube present
|
||||||
|
// 6 = no data, seems to show system one 3 in settings
|
||||||
|
// 8 = (classic mode; also seen when heated tube present but off, possibly ignored in that case)
|
||||||
|
//
|
||||||
|
// Note that, while containing similar fields as ParseHumidifierSetting60Series, the bit arrangement is different for F3V3!
|
||||||
|
|
||||||
|
void PRS1DataChunk::ParseHumidifierSettingF3V3(unsigned char humid1, unsigned char humid2, bool add_setting)
|
||||||
|
{
|
||||||
|
if (false) qWarning() << this->sessionid << "humid" << hex(humid1) << hex(humid2) << add_setting;
|
||||||
|
|
||||||
|
int humidlevel = humid1 & 7; // Ignored when heated tube is present: humidifier setting on tube disconnect is always reported as 3
|
||||||
|
if (humidlevel > 5) UNEXPECTED_VALUE(humidlevel, "<= 5");
|
||||||
|
CHECK_VALUE(humid1 & 0x40, 0x40); // seems always set, even without heated tube
|
||||||
|
CHECK_VALUE(humid1 & 0x98, 0); // never seen
|
||||||
|
int tubehumidlevel = (humid1 >> 5) & 7; // This mask is a best guess based on other masks.
|
||||||
|
if (tubehumidlevel > 5) UNEXPECTED_VALUE(tubehumidlevel, "<= 5");
|
||||||
|
CHECK_VALUE(tubehumidlevel & 4, 0); // never seen, but would clarify whether above mask is correct
|
||||||
|
|
||||||
|
int tubetemp = humid2 & 7;
|
||||||
|
if (tubetemp > 5) UNEXPECTED_VALUE(tubetemp, "<= 5");
|
||||||
|
|
||||||
|
if (humid2 & 0x60) {
|
||||||
|
CHECK_VALUES(humid2 & 0x60, 0x20, 0x60); // no humidifier data on chart
|
||||||
|
}
|
||||||
|
bool humidclassic = (humid2 & 0x80) != 0; // Set on classic mode reports; evidently ignored (sometimes set!) when tube is present
|
||||||
|
//bool no_tube? = (humid2 & 0x20) != 0; // Something tube related: whenever it is set, tube is never present (inverse is not true)
|
||||||
|
bool no_data = (humid2 & 0x60) != 0; // As described in chart, settings still show up
|
||||||
|
int tubepresent = (humid2 & 0x10) != 0;
|
||||||
|
bool humidsystemone = (humid2 & 0x08) != 0; // Set on "System One" humidification mode reports when tubepresent is false
|
||||||
|
|
||||||
|
if (humidsystemone + tubepresent + no_data == 0) CHECK_VALUE(humidclassic, true); // Always set when everything else is off in F0V4
|
||||||
|
if (humidsystemone + tubepresent /*+ no_data*/ > 1) UNEXPECTED_VALUE(humid2, "one bit set"); // Only one of these ever seems to be set at a time
|
||||||
|
//if (tubepresent && tubetemp == 0) CHECK_VALUE(tubehumidlevel, 0); // When the heated tube is off, tube humidity seems to be 0 in F0V4, but not F3V3
|
||||||
|
|
||||||
|
if (tubepresent) humidclassic = false; // Classic mode bit is evidently ignored when tube is present
|
||||||
|
|
||||||
|
//qWarning() << this->sessionid << (humidclassic ? "C" : ".") << (humid2 & 0x20 ? "?" : ".") << (tubepresent ? "T" : ".") << (no_data ? "X" : ".") << (humidsystemone ? "1" : ".");
|
||||||
|
/*
|
||||||
|
if (tubepresent) {
|
||||||
|
if (tubetemp) {
|
||||||
|
qWarning() << this->sessionid << "tube temp" << tubetemp << "tube humidity" << tubehumidlevel << (humidclassic ? "classic" : "systemone") << "humidity" << humidlevel;
|
||||||
|
} else {
|
||||||
|
qWarning() << this->sessionid << "heated tube off" << (humidclassic ? "classic" : "systemone") << "humidity" << humidlevel;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
qWarning() << this->sessionid << (humidclassic ? "classic" : "systemone") << "humidity" << humidlevel;
|
||||||
|
}
|
||||||
|
*/
|
||||||
|
HumidMode humidmode = HUMID_Fixed;
|
||||||
|
if (tubepresent) {
|
||||||
|
humidmode = HUMID_HeatedTube;
|
||||||
|
} else {
|
||||||
|
if (humidsystemone + humidclassic > 1) UNEXPECTED_VALUE(humid2, "fixed or adaptive");
|
||||||
|
if (humidsystemone) humidmode = HUMID_Adaptive;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (add_setting) {
|
||||||
|
bool humidifier_present = (no_data == 0);
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HUMID_STATUS, humidifier_present));
|
||||||
|
if (humidifier_present) {
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HUMID_MODE, humidmode));
|
||||||
|
if (humidmode == HUMID_HeatedTube) {
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HEATED_TUBE_TEMP, tubetemp));
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HUMID_LEVEL, tubehumidlevel));
|
||||||
|
} else {
|
||||||
|
this->AddEvent(new PRS1ParsedSettingEvent(PRS1_SETTING_HUMID_LEVEL, humidlevel));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check for previously unseen data that we expect to be normal:
|
||||||
|
if (humidclassic && humidlevel == 1) UNEXPECTED_VALUE(humidlevel, "!= 1");
|
||||||
|
if (tubepresent) {
|
||||||
|
if (tubetemp) CHECK_VALUES(tubehumidlevel, 2, 3);
|
||||||
|
if (tubetemp == 2) UNEXPECTED_VALUE(tubetemp, "!= 2");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
const QVector<PRS1ParsedEventType> ParsedEventsF3V0 = {
|
||||||
|
PRS1IPAPAverageEvent::TYPE,
|
||||||
|
PRS1EPAPAverageEvent::TYPE,
|
||||||
|
PRS1TotalLeakEvent::TYPE,
|
||||||
|
PRS1TidalVolumeEvent::TYPE,
|
||||||
|
PRS1FlowRateEvent::TYPE,
|
||||||
|
PRS1PatientTriggeredBreathsEvent::TYPE,
|
||||||
|
PRS1RespiratoryRateEvent::TYPE,
|
||||||
|
PRS1MinuteVentilationEvent::TYPE,
|
||||||
|
// No LEAK, unlike F3V3
|
||||||
|
PRS1HypopneaCount::TYPE,
|
||||||
|
PRS1ClearAirwayCount::TYPE, // TODO
|
||||||
|
PRS1ObstructiveApneaCount::TYPE, // TODO
|
||||||
|
// No PP, FL, VS, RERA, PB, LL
|
||||||
|
// No TB
|
||||||
|
};
|
||||||
|
|
||||||
|
const QVector<PRS1ParsedEventType> ParsedEventsF3V3 = {
|
||||||
|
PRS1IPAPAverageEvent::TYPE,
|
||||||
|
PRS1EPAPAverageEvent::TYPE,
|
||||||
|
PRS1TotalLeakEvent::TYPE,
|
||||||
|
PRS1TidalVolumeEvent::TYPE,
|
||||||
|
PRS1FlowRateEvent::TYPE,
|
||||||
|
PRS1PatientTriggeredBreathsEvent::TYPE,
|
||||||
|
PRS1RespiratoryRateEvent::TYPE,
|
||||||
|
PRS1MinuteVentilationEvent::TYPE,
|
||||||
|
PRS1LeakEvent::TYPE,
|
||||||
|
PRS1HypopneaCount::TYPE,
|
||||||
|
PRS1ClearAirwayCount::TYPE,
|
||||||
|
PRS1ObstructiveApneaCount::TYPE,
|
||||||
|
// No PP, FL, VS, RERA, PB, LL
|
||||||
|
// No TB
|
||||||
|
};
|
||||||
|
|
||||||
|
// 1061, 1061T, 1160P series
|
||||||
|
bool PRS1DataChunk::ParseEventsF3V03(void)
|
||||||
|
{
|
||||||
|
// NOTE: Older ventilators (BiPAP S/T and AVAPS) machines don't use timestamped events like everything else.
|
||||||
|
// Instead, they use a fixed interval format like waveforms do (see PRS1_HTYPE_INTERVAL).
|
||||||
|
|
||||||
|
if (this->family != 3 || (this->familyVersion != 0 && this->familyVersion != 3)) {
|
||||||
|
qWarning() << "ParseEventsF3V03 called with family" << this->family << "familyVersion" << this->familyVersion;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if (this->fileVersion == 3) {
|
||||||
|
// NOTE: The original comment in the header for ParseF3EventsV3 said there was a 1060P with fileVersion 3.
|
||||||
|
// We've never seen that, so warn if it ever shows up.
|
||||||
|
qWarning() << "F3V3 event file with fileVersion 3?";
|
||||||
|
}
|
||||||
|
|
||||||
|
int t = 0;
|
||||||
|
static const int record_size = 0x10;
|
||||||
|
int size = this->m_data.size()/record_size;
|
||||||
|
CHECK_VALUE(this->m_data.size() % record_size, 0);
|
||||||
|
unsigned char * h = (unsigned char *)this->m_data.data();
|
||||||
|
|
||||||
|
static const qint64 block_duration = 120;
|
||||||
|
|
||||||
|
// Make sure the assumptions here agree with the header
|
||||||
|
CHECK_VALUE(this->htype, PRS1_HTYPE_INTERVAL);
|
||||||
|
CHECK_VALUE(this->interval_count, size);
|
||||||
|
CHECK_VALUE(this->interval_seconds, block_duration);
|
||||||
|
for (auto & channel : this->waveformInfo) {
|
||||||
|
CHECK_VALUE(channel.interleave, 1);
|
||||||
|
}
|
||||||
|
|
||||||
|
for (int x=0; x < size; x++) {
|
||||||
|
// Use the timestamp of the end of this interval, to be consistent with other parsers,
|
||||||
|
// but see note below regarding the duration of the final interval.
|
||||||
|
t += block_duration;
|
||||||
|
|
||||||
|
// TODO: The duration of the final interval isn't clearly defined in this format:
|
||||||
|
// there appears to be no way (apart from looking at the summary or waveform data)
|
||||||
|
// to determine the end time, which may truncate the last interval.
|
||||||
|
//
|
||||||
|
// TODO: What if there are multiple "final" intervals in a session due to multiple
|
||||||
|
// mask-on slices?
|
||||||
|
this->AddEvent(new PRS1IPAPAverageEvent(t, h[0] | (h[1] << 8)));
|
||||||
|
this->AddEvent(new PRS1EPAPAverageEvent(t, h[2] | (h[3] << 8)));
|
||||||
|
this->AddEvent(new PRS1TotalLeakEvent(t, h[4]));
|
||||||
|
this->AddEvent(new PRS1TidalVolumeEvent(t, h[5]));
|
||||||
|
this->AddEvent(new PRS1FlowRateEvent(t, h[6]));
|
||||||
|
this->AddEvent(new PRS1PatientTriggeredBreathsEvent(t, h[7]));
|
||||||
|
this->AddEvent(new PRS1RespiratoryRateEvent(t, h[8]));
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
if (h[9] < 4 || h[9] > 65) UNEXPECTED_VALUE(h[9], "4-65");
|
||||||
|
} else {
|
||||||
|
if (h[9] < 4 || h[9] > 84) UNEXPECTED_VALUE(h[9], "5-84"); // not sure what this is.. encore doesn't graph it.
|
||||||
|
}
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
// 1 shows as Apnea (AP) alarm
|
||||||
|
// 2 shows as a Patient Disconnect (PD) alarm
|
||||||
|
// 4 shows as a Low Minute Vent (LMV) alarm
|
||||||
|
// 8 shows as a Low Pressure (LP) alarm
|
||||||
|
// 10 shows as PD + LP in the same interval
|
||||||
|
if (h[10] & ~(0x01 | 0x02 | 0x04 | 0x08)) UNEXPECTED_VALUE(h[10], "known bits");
|
||||||
|
} else {
|
||||||
|
// This is probably the same as F3V0, but we don't yet have the sample data to confirm.
|
||||||
|
CHECK_VALUES(h[10], 0, 8); // 8 shows as a Low Pressure (LP) alarm
|
||||||
|
}
|
||||||
|
this->AddEvent(new PRS1MinuteVentilationEvent(t, h[11]));
|
||||||
|
if (this->familyVersion == 0) {
|
||||||
|
CHECK_VALUE(h[12], 0);
|
||||||
|
this->AddEvent(new PRS1HypopneaCount(t, h[13])); // count of hypopnea events
|
||||||
|
this->AddEvent(new PRS1ClearAirwayCount(t, h[14])); // count of clear airway events
|
||||||
|
this->AddEvent(new PRS1ObstructiveApneaCount(t, h[15])); // count of obstructive events
|
||||||
|
} else {
|
||||||
|
this->AddEvent(new PRS1HypopneaCount(t, h[12])); // count of hypopnea events
|
||||||
|
this->AddEvent(new PRS1ClearAirwayCount(t, h[13])); // count of clear airway events
|
||||||
|
this->AddEvent(new PRS1ObstructiveApneaCount(t, h[14])); // count of obstructive events
|
||||||
|
this->AddEvent(new PRS1LeakEvent(t, h[15]));
|
||||||
|
}
|
||||||
|
this->AddEvent(new PRS1IntervalBoundaryEvent(t));
|
||||||
|
|
||||||
|
h += record_size;
|
||||||
|
}
|
||||||
|
|
||||||
|
this->duration = t;
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
// Originally based on ParseSummaryF5V3, with changes observed in ventilator sample data
|
// Originally based on ParseSummaryF5V3, with changes observed in ventilator sample data
|
||||||
//
|
//
|
||||||
// TODO: surely there will be a way to merge ParseSummary (FV3) loops and abstract the machine-specific
|
// TODO: surely there will be a way to merge ParseSummary (FV3) loops and abstract the machine-specific
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user