chris/OSCAR-code
1
0
Fork 0
mirror of https://gitlab.com/pholy/OSCAR-code.git synced 2025-04-06 11:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix DV64 L.BIN and add E.BIN parser

Browse Source
This commit is contained in:
Mark Watkins 2018-06-09 22:08:31 +10:00
parent 94d9091e4b
commit 274768f9db
2 changed files with 120 additions and 60 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

157
sleepyhead/SleepLib/loader_plugins/intellipap_loader.cpp
View File

@ -629,12 +629,6 @@ struct DV6_S_Record
//42-48 unknown //42-48 unknown
EventDataType pressureSetMin; //49 EventDataType pressureSetMin; //49
EventDataType pressureSetMax; //50 EventDataType pressureSetMax; //50
}; };
int IntellipapLoader::OpenDV6(const QString & path) int IntellipapLoader::OpenDV6(const QString & path)
@ -793,7 +787,7 @@ int IntellipapLoader::OpenDV6(const QString & path)
const int DV6_L_RecLength = 45; const int DV6_L_RecLength = 45;
const int DV6_E_RecLength = 0x18; const int DV6_E_RecLength = 25;
const int DV6_S_RecLength = 55; const int DV6_S_RecLength = 55;
unsigned int ts1,ts2; unsigned int ts1,ts2;
@ -805,7 +799,6 @@ int IntellipapLoader::OpenDV6(const QString & path)
f.setFileName(newpath+"/S.BIN"); f.setFileName(newpath+"/S.BIN");
if (f.open(QIODevice::ReadOnly)) { if (f.open(QIODevice::ReadOnly)) {
// Settings is just a binary packed 0 terminated string list
dataBA = f.readAll(); dataBA = f.readAll();
f.close(); f.close();
@ -1311,6 +1304,12 @@ int IntellipapLoader::OpenDV6(const QString & path)
EventList *leak = NULL; EventList *leak = NULL;
EventList *maxleak = NULL; EventList *maxleak = NULL;
EventList * RR = NULL;
EventList * Pressure = NULL;
EventList * TV = NULL;
EventList * MV = NULL;
sess = NULL; sess = NULL;
const int DV6_L_HeaderSize = 55; const int DV6_L_HeaderSize = 55;
// Need to parse L.bin minute table to get graphs // Need to parse L.bin minute table to get graphs
@ -1326,34 +1325,24 @@ int IntellipapLoader::OpenDV6(const QString & path)
int numLrecs = (dataBA.size()-DV6_L_HeaderSize) / DV6_L_RecLength; int numLrecs = (dataBA.size()-DV6_L_HeaderSize) / DV6_L_RecLength;
SR = summaryList.begin(); SR = summaryList.begin();
DV6_S_Record *R = &SR.value();
for (int r=0; r<numLrecs; ++r) { for (int r=0; r<numLrecs; ++r) {
ts1 = ((data[4] << 24) | (data[3] << 16) | (data[2] << 8) | data[1])+ep; // session start time ts1 = ((data[4] << 24) | (data[3] << 16) | (data[2] << 8) | data[1])+ep; // session start time
if (SR == summaryList.end())
break;
DV6_S_Record *R = &SR.value();
while (ts1 > R->stop_time) { while (ts1 > R->stop_time) {
if (leak && sess) { if (leak && sess) {
// Close the open session and update the min and max // Close the open session and update the min and max
EventDataType min = leak->Min();
EventDataType max = leak->Max();
sess->setMin(CPAP_Leak, min);
sess->setMax(CPAP_Leak, max);
sess->setPhysMax(CPAP_Leak, min);
sess->setPhysMin(CPAP_Leak, max);
min = maxleak->Min();
max = maxleak->Max();
sess->setMin(CPAP_MaxLeak, min);
sess->setMax(CPAP_MaxLeak, max);
sess->setPhysMax(CPAP_MaxLeak, min);
sess->setPhysMin(CPAP_MaxLeak, max);
sess->set_last(maxleak->last()); sess->set_last(maxleak->last());
sess = NULL; sess = nullptr;
leak = NULL; leak = nullptr;
maxleak = nullptr;
MV = TV = RR = nullptr;
Pressure = nullptr;
} }
SR++; SR++;
if (SR == summaryList.end()) break; if (SR == summaryList.end()) break;
@ -1365,42 +1354,39 @@ int IntellipapLoader::OpenDV6(const QString & path)
if (ts1 >= R->start_time) { if (ts1 >= R->start_time) {
if (!leak && R->sess) { if (!leak && R->sess) {
qDebug() << "Adding Leak data for session" << R->sess->session() << "starting at" << ts1; qDebug() << "Adding Leak data for session" << R->sess->session() << "starting at" << ts1;
leak = R->sess->AddEventList(CPAP_Leak, EVL_Waveform, 1.0, 0.0, 0.0, 0.0, double(60000) / double(1)); leak = R->sess->AddEventList(CPAP_Leak, EVL_Event); // , 1.0, 0.0, 0.0, 0.0, double(60000) / double(1));
maxleak = R->sess->AddEventList(CPAP_MaxLeak, EVL_Waveform, 1.0, 0.0, 0.0, 0.0, double(60000) / double(1)); maxleak = R->sess->AddEventList(CPAP_MaxLeak, EVL_Event);// , 1.0, 0.0, 0.0, 0.0, double(60000) / double(1));
} RR = R->sess->AddEventList(CPAP_RespRate, EVL_Event);
} else { MV = R->sess->AddEventList(CPAP_MinuteVent, EVL_Event);
//SR TV = R->sess->AddEventList(CPAP_TidalVolume, EVL_Event);
Pressure = R->sess->AddEventList(CPAP_Pressure, EVL_Event);
} }
if (leak) { if (leak) {
sess = R->sess; sess = R->sess;
qint64 ti = qint64(ts1) * 1000; qint64 ti = qint64(ts1) * 1000L;
maxleak->AddEvent(ti, data[5]); maxleak->AddEvent(ti, data[5]);
leak->AddEvent(ti, data[6]); leak->AddEvent(ti, data[6]);
RR->AddEvent(ti, data[9]);
Pressure->AddEvent(ti, data[11] / 10.0f);
unsigned tv = data[7] | data[8] << 8;
MV->AddEvent(ti, data[10] );
TV->AddEvent(ti, tv);
if (!sess->channelExists(CPAP_FlowRate)) { if (!sess->channelExists(CPAP_FlowRate)) {
// No flow rate, so lets grab this data... // No flow rate, so lets grab this data...
} }
} }
} else {
//SR
}
data += DV6_L_RecLength; data += DV6_L_RecLength;
} // for } // for
if (sess && leak) { if (sess && leak) {
EventDataType min = leak->Min();
EventDataType max = leak->Max();
sess->setMin(CPAP_Leak, min);
sess->setMax(CPAP_Leak, max);
sess->setPhysMax(CPAP_Leak, min);
sess->setPhysMin(CPAP_Leak, max);
min = maxleak->Min();
max = maxleak->Max();
sess->setMin(CPAP_MaxLeak, min);
sess->setMax(CPAP_MaxLeak, max);
sess->setPhysMax(CPAP_MaxLeak, min);
sess->setPhysMin(CPAP_MaxLeak, max);
sess->set_last(maxleak->last()); sess->set_last(maxleak->last());
} }
@ -1413,18 +1399,91 @@ int IntellipapLoader::OpenDV6(const QString & path)
// Now sessionList is populated with summary data, lets parse the Events list in E.BIN // Now sessionList is populated with summary data, lets parse the Events list in E.BIN
EventList * OA = nullptr;
EventList * CA = nullptr;
EventList * H = nullptr;
EventList * RE = nullptr;
f.setFileName(newpath+"/E.BIN"); f.setFileName(newpath+"/E.BIN");
const int DV6_E_HeaderSize = 55;
if (f.open(QIODevice::ReadOnly)) { if (f.open(QIODevice::ReadOnly)) {
dataBA = f.readAll(); dataBA = f.readAll();
if (dataBA.size() == 0) { if (dataBA.size() == 0) {
return -1; return -1;
} }
f.close(); f.close();
data = (unsigned char *)dataBA.data(); data = (unsigned char *)dataBA.data()+DV6_E_HeaderSize;
int numErecs = (dataBA.size()-DV6_E_HeaderSize) / DV6_E_RecLength;
SR = summaryList.begin();
for (int r=0; r<numErecs; ++r, data += DV6_E_RecLength) {
ts1 = ((data[4] << 24) | (data[3] << 16) | (data[2] << 8) | data[1])+ep; // start time
ts2 = ((data[8] << 24) | (data[7] << 16) | (data[6] << 8) | data[5])+ep; // end
if (SR == summaryList.end())
break;
DV6_S_Record *R = &SR.value();
while (ts1 > R->stop_time) {
if (OA && sess) {
// Close the open session and update the min and max
sess->set_last(OA->last());
sess->set_last(CA->last());
sess->set_last(H->last());
sess->set_last(RE->last());
sess = nullptr;
H = CA = RE = OA = nullptr;
}
SR++;
if (SR == summaryList.end()) break;
R = &SR.value();
}
if (SR == summaryList.end())
break;
if (ts1 >= R->start_time) {
if (!OA && R->sess) {
qDebug() << "Adding Event data for session" << R->sess->session() << "starting at" << ts1;
OA = R->sess->AddEventList(CPAP_Obstructive, EVL_Event);
H = R->sess->AddEventList(CPAP_Hypopnea, EVL_Event);
RE = R->sess->AddEventList(CPAP_RERA, EVL_Event);
CA = R->sess->AddEventList(CPAP_ClearAirway, EVL_Event);
}
if (OA) {
sess = R->sess;
qint64 ti = qint64(ts1) * 1000L;
int code = data[13];
switch (code) {
case 1:
CA->AddEvent(ti, data[17]);
break;
case 2:
OA->AddEvent(ti, data[17]);
break;
case 4:
H->AddEvent(ti, data[17]);
break;
case 5:
RE->AddEvent(ti, data[17]);
break;
default:
break;
}
}
} // for
}
if (sess && OA) {
sess->set_last(OA->last());
sess->set_last(CA->last());
sess->set_last(H->last());
sess->set_last(RE->last());
}
} else { // if (f.open(...) } else { // if (f.open(...)
// E.BIN open failed // E.BIN open failed
return -1; return -1;

7
sleepyhead/SleepLib/machine.cpp
View File

@ -257,7 +257,7 @@ bool Machine::AddSession(Session *s)
if (locksessions) { if (locksessions) {
split_time = s->summaryOnly() ? QTime(12,0,0) : profile->session->daySplitTime(); split_time = s->summaryOnly() ? QTime(12,0,0) : profile->session->daySplitTime();
combine_sessions = s->summaryOnly() ? 0 : p_profile->session->combineCloseSessions(); combine_sessions = s->summaryOnly() ? 0 : profile->session->combineCloseSessions();
} else { } else {
split_time = profile->session->daySplitTime(); split_time = profile->session->daySplitTime();
combine_sessions = profile->session->combineCloseSessions(); combine_sessions = profile->session->combineCloseSessions();
@ -544,9 +544,10 @@ void Machine::setInfo(MachineInfo inf)
const QString Machine::getDataPath() const QString Machine::getDataPath()
{ {
if (m_dataPath.isEmpty()) {
//if (m_dataPath.isEmpty()) {
m_dataPath = profile->Get("{" + STR_GEN_DataFolder + "}/" + info.loadername + "_" + (info.serial.isEmpty() ? hexid() : info.serial)) + "/"; m_dataPath = profile->Get("{" + STR_GEN_DataFolder + "}/" + info.loadername + "_" + (info.serial.isEmpty() ? hexid() : info.serial)) + "/";
} // }
return m_dataPath; return m_dataPath;
} }
const QString Machine::getSummariesPath() const QString Machine::getSummariesPath()