t.mettler/giesCANne
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
780e2fb1a241de5c98104cae89cccbef94c072fb
giesCANne/framefileio.cpp
T
Collin Kidder 780e2fb1a2 Several changes suggested in draft pull requests from llange. Fix some 
ambiguous places, fix warnings, fix errors when trying to compile with
QT6
2023-04-11 21:15:34 -04:00

4993 lines
165 KiB
C++
Raw Blame History

#include "framefileio.h"
#include <QMessageBox>
#include <QProgressDialog>
#include <QDateTime>
#include <QRegularExpression>
#include <QtEndian>
#include <QSettings>
#include <iostream>
#include <memory>
#include "pcaplite.h"
#include "utility.h"
#include "blfhandler.h"
QFile FrameFileIO::continuousFile;
struct TeslaAPCANRecord
{
#pragma pack(push, 1)
int64_t sec;
int32_t nano;
int32_t padding1;
uint16_t id;
uint8_t ctr;
uint8_t data[8];
uint8_t padding2;
#pragma pack(pop)
};
FrameFileIO::FrameFileIO()
{
}
bool FrameFileIO::saveFrameFile(QString &fileName, const QVector<CANFrame>* frameCache)
{
QString filename;
QFileDialog dialog(qApp->activeWindow());
QSettings settings;
bool result = false;
QStringList filters;
filters.append(QString(tr("GVRET Logs (*.csv *.CSV)")));
filters.append(QString(tr("CRTD Logs (*.crt *.crtd *.CRT *.CRTD)")));
filters.append(QString(tr("Generic ID/Data CSV (*.csv *.CSV)")));
filters.append(QString(tr("BusMaster Log (*.log *.LOG)")));
filters.append(QString(tr("Microchip Log (*.can *.CAN *.log *.LOG)")));
filters.append(QString(tr("Vector Trace Files (*.trace *.TRACE)")));
filters.append(QString(tr("IXXAT MiniLog (*.csv *.CSV)")));
filters.append(QString(tr("CAN-DO Log (*.can *.avc *.evc *.qcc *.CAN *.AVC *.EVC *.QCC)")));
filters.append(QString(tr("Vehicle Spy (*.csv *.CSV)")));
filters.append(QString(tr("Candump/Kayak (*.log)")));
filters.append(QString(tr("Cabana Log (*.csv *.CSV)")));
filters.append(QString(tr("CANalyzer Ascii Log (*.asc *.ASC)")));
filters.append(QString(tr("CARBUS Analyzer (*.trc *.TRC)")));
dialog.setDirectory(settings.value("FileIO/LoadSaveDirectory", dialog.directory().path()).toString());
dialog.setFileMode(QFileDialog::AnyFile);
dialog.setNameFilters(filters);
dialog.setViewMode(QFileDialog::Detail);
dialog.setAcceptMode(QFileDialog::AcceptSave);
if (dialog.exec() == QDialog::Accepted)
{
filename = dialog.selectedFiles()[0];
QProgressDialog progress(qApp->activeWindow());
progress.setWindowModality(Qt::WindowModal);
progress.setLabelText("Saving file...");
progress.setCancelButton(nullptr);
progress.setRange(0,0);
progress.setMinimumDuration(0);
progress.show();
qApp->processEvents();
if (dialog.selectedNameFilter() == filters[0])
{
if (!filename.contains('.')) filename += ".csv";
result = saveNativeCSVFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[1])
{
if (!filename.contains('.')) filename += ".txt";
result = saveCRTDFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[2])
{
if (!filename.contains('.')) filename += ".csv";
result = saveGenericCSVFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[3])
{
if (!filename.contains('.')) filename += ".log";
result = saveLogFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[4])
{
if (!filename.contains('.')) filename += ".log";
result = saveMicrochipFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[5])
{
if (!filename.contains('.')) filename += ".trace";
result = saveTraceFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[6])
{
if (!filename.contains('.')) filename += ".csv";
result = saveIXXATFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[7])
{
if (!filename.contains('.')) filename += ".can";
result = saveCANDOFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[8])
{
if (!filename.contains('.')) filename += ".csv";
result = saveVehicleSpyFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[9])
{
if (!filename.contains('.')) filename += ".log";
saveCanDumpFile(filename,frameCache);
}
if (dialog.selectedNameFilter() == filters[10])
{
if (!filename.contains('.')) filename += ".csv";
result = saveCabanaFile(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[11])
{
if (!filename.contains('.')) filename += ".asc";
result = saveCanalyzerASC(filename, frameCache);
}
if (dialog.selectedNameFilter() == filters[12])
{
if (!filename.contains('.')) filename += ".trc";
result = saveCARBUSAnalzyer(filename, frameCache);
}
progress.cancel();
if (result)
{
QStringList fileList = filename.split('/');
fileName = fileList[fileList.length() - 1];
settings.setValue("FileIO/LoadSaveDirectory", dialog.directory().path());
return true;
}
return false;
}
return false;
}
bool FrameFileIO::loadFrameFile(QString &fileName, QVector<CANFrame>* frameCache)
{
QString filename;
QFileDialog dialog;
QSettings settings;
bool result = false;
QStringList filters;
filters.append(QString(tr("Autodetect File Type (*.*)")));
filters.append(QString(tr("GVRET Logs (*.csv *.CSV)")));
filters.append(QString(tr("CRTD Logs (*.crt *.crtd *.CRT *.CRTD)")));
filters.append(QString(tr("BusMaster Log (*.log *.LOG)")));
filters.append(QString(tr("Microchip Log (*.can *.CAN *.log *.LOG)")));
filters.append(QString(tr("Vector trace files (*.trace *.TRACE)")));
filters.append(QString(tr("IXXAT MiniLog (*.csv *.CSV)")));
filters.append(QString(tr("CAN-DO Log (*.avc *.can *.evc *.qcc *.AVC *.CAN *.EVC *.QCC)")));
filters.append(QString(tr("Vehicle Spy (*.csv *.CSV)")));
filters.append(QString(tr("Candump/Kayak (*.log *.LOG)")));
filters.append(QString(tr("CANDump Lawicel (*.txt *.TXT *.LOG *.log)")));
filters.append(QString(tr("PCAN Viewer (*.trc *.TRC)")));
filters.append(QString(tr("Kvaser Log Decimal (*.txt *.TXT)")));
filters.append(QString(tr("Kvaser Log Hex (*.txt *.TXT)")));
filters.append(QString(tr("CANalyzer Ascii Log (*.asc *.ASC)")));
filters.append(QString(tr("CANalyzer Binary Log Files (*.blf *.BLF)")));
filters.append(QString(tr("CARBUS Analyzer Trace Files (*.trc *.TRC)")));
filters.append(QString(tr("CANHacker Trace Files (*.trc *.TRC)")));
filters.append(QString(tr("Generic ID/Data CSV (*.csv *.CSV)")));
filters.append(QString(tr("Cabana Log (*.csv *.CSV)")));
filters.append(QString(tr("CANOpen Magic (*.csv *.CSV)")));
filters.append(QString(tr("Tesla Autopilot Snapshot (*.CAN *.can)")));
filters.append(QString(tr("CLX000 (*.txt *.TXT)")));
filters.append(QString(tr("CANServer Binary Log (*.log *.LOG)")));
filters.append(QString(tr("Wireshark (*.pcap *.PCAP *.pcapng *.PCAPNG)")));
dialog.setDirectory(settings.value("FileIO/LoadSaveDirectory", dialog.directory().path()).toString());
dialog.setFileMode(QFileDialog::ExistingFile);
dialog.setNameFilters(filters);
dialog.setViewMode(QFileDialog::Detail);
if (dialog.exec() == QDialog::Accepted)
{
filename = dialog.selectedFiles()[0];
QString selectedNameFilter = dialog.selectedNameFilter();
QProgressDialog progress(qApp->activeWindow());
progress.setWindowModality(Qt::WindowModal);
progress.setLabelText("Loading file...");
progress.setCancelButton(nullptr);
progress.setRange(0,0);
progress.setMinimumDuration(0);
progress.show();
qApp->processEvents();
if (selectedNameFilter == filters[0]) result = autoDetectLoadFile(filename, frameCache);
if (selectedNameFilter == filters[1]) result = loadNativeCSVFile(filename, frameCache);
if (selectedNameFilter == filters[2]) result = loadCRTDFile(filename, frameCache);
if (selectedNameFilter == filters[3]) result = loadLogFile(filename, frameCache);
if (selectedNameFilter == filters[4]) result = loadMicrochipFile(filename, frameCache);
if (selectedNameFilter == filters[5]) result = loadTraceFile(filename, frameCache);
if (selectedNameFilter == filters[6]) result = loadIXXATFile(filename, frameCache);
if (selectedNameFilter == filters[7]) result = loadCANDOFile(filename, frameCache);
if (selectedNameFilter == filters[8]) result = loadVehicleSpyFile(filename, frameCache);
if (selectedNameFilter == filters[9]) result = loadCanDumpFile(filename, frameCache);
if (selectedNameFilter == filters[10]) result = loadLawicelFile(filename, frameCache);
if (selectedNameFilter == filters[11]) result = loadPCANFile(filename, frameCache);
if (selectedNameFilter == filters[12]) result = loadKvaserFile(filename, frameCache, false);
if (selectedNameFilter == filters[13]) result = loadKvaserFile(filename, frameCache, true);
if (selectedNameFilter == filters[14]) result = loadCanalyzerASC(filename, frameCache);
if (selectedNameFilter == filters[15]) result = loadCanalyzerBLF(filename, frameCache);
if (selectedNameFilter == filters[16]) result = loadCARBUSAnalyzerFile(filename, frameCache);
if (selectedNameFilter == filters[17]) result = loadCANHackerFile(filename, frameCache);
if (selectedNameFilter == filters[18]) result = loadGenericCSVFile(filename, frameCache);
if (selectedNameFilter == filters[19]) result = loadCabanaFile(filename, frameCache);
if (selectedNameFilter == filters[20]) result = loadCANOpenFile(filename, frameCache);
if (selectedNameFilter == filters[21]) result = loadTeslaAPFile(filename, frameCache);
if (selectedNameFilter == filters[22]) result = loadCLX000File(filename, frameCache);
if (selectedNameFilter == filters[23]) result = loadCANServerFile(filename, frameCache);
if (selectedNameFilter == filters[24]) result = loadWiresharkFile(filename, frameCache);
progress.cancel();
if (result)
{
QStringList fileList = filename.split('/');
fileName = fileList[fileList.length() - 1];
settings.setValue("FileIO/LoadSaveDirectory", dialog.directory().path());
return true;
}
else
{
if (dialog.selectedNameFilter() != filters[0])
{
QMessageBox msgBox;
msgBox.setText("File load completed with errors.\r\nPerhaps you selected the wrong file type?");
msgBox.exec();
}
return false;
}
}
return false;
}
//Try every format by first using the "is" functions which try to detect whether a given file is a good match to that
//file format or not. Those functions are much less tolerant than the load functions and so should help to discriminate
//whether a file could be loaded or not by a given loader. The loader return is still used in case the guess was wrong.
bool FrameFileIO::autoDetectLoadFile(QString filename, QVector<CANFrame>* frames)
{
qDebug() << "Attempting Canalyzer BLF";
if (isCanalyzerBLF(filename))
{
if (loadCanalyzerBLF(filename, frames))
{
qDebug() << "Loaded as Canalyzer BLF successfully!";
return true;
}
}
qDebug() << "Attempting native CSV";
if (isNativeCSVFile(filename))
{
if (loadNativeCSVFile(filename, frames))
{
qDebug() << "Loaded as native CSV successfully!";
return true;
}
}
qDebug() << "Attempting Tesla AP Snapshot";
if (isTeslaAPFile(filename))
{
if (loadTeslaAPFile(filename, frames))
{
qDebug() << "Loaded as Tesla AP Snapshot successfully!";
return true;
}
}
qDebug() << "Attempting CANServer Binary Log";
if (isCANServerFile(filename))
{
if (loadCANServerFile(filename, frames))
{
qDebug() << "Loaded as CANServer Binary Log successfully!";
return true;
}
}
qDebug() << "Attempting Wireshark Log";
if (isWiresharkFile(filename))
{
if (loadWiresharkFile(filename, frames))
{
qDebug() << "Loaded as Wireshark Log successfully!";
return true;
}
}
qDebug() << "Attempting canalyzer ASC";
if (isCanalyzerASC(filename))
{
if (loadCanalyzerASC(filename, frames))
{
qDebug() << "Loaded as Canalyzer ASC successfully!";
return true;
}
}
qDebug() << "Attempting CRTD";
if (isCRTDFile(filename))
{
if (loadCRTDFile(filename, frames))
{
qDebug() << "Loaded as CRTD successfully!";
return true;
}
}
qDebug() << "Attempting trace file";
if (isTraceFile(filename))
{
if (loadTraceFile(filename, frames))
{
qDebug() << "Loaded as trace successfully!";
return true;
}
}
qDebug() << "Attempting vehicle spy";
if (isVehicleSpyFile(filename))
{
if (loadVehicleSpyFile(filename, frames))
{
qDebug() << "Loaded as vehicle spy successfully!";
return true;
}
}
qDebug() << "Attempting candump";
if (isCanDumpFile(filename))
{
if (loadCanDumpFile(filename, frames))
{
qDebug() << "Loaded as candump successfully!";
return true;
}
}
qDebug() << "Attempting lawicel";
if (isLawicelFile(filename))
{
if (loadLawicelFile(filename, frames))
{
qDebug() << "Loaded as lawicel successfully!";
return true;
}
}
qDebug() << "Attempting 'CARBUS Analyzer'";
if (isCARBUSAnalyzerFile(filename))
{
if (loadCARBUSAnalyzerFile(filename, frames))
{
qDebug() << "Loaded as 'CARBUS Analyzer' successfully!";
return true;
}
}
qDebug() << "Attempting canhacker";
if (isCANHackerFile(filename))
{
if (loadCANHackerFile(filename, frames))
{
qDebug() << "Loaded as CANHacker successfully!";
return true;
}
}
qDebug() << "Attempting cabana";
if (isCabanaFile(filename))
{
if (loadCabanaFile(filename, frames))
{
qDebug() << "Loaded as Cabana successfully!";
return true;
}
}
qDebug() << "Attempting canopen";
if (isCANOpenFile(filename))
{
if (loadCANOpenFile(filename, frames))
{
qDebug() << "Loaded as CANOpen Magic successfully!";
return true;
}
}
qDebug() << "Attempting busmaster log";
if (isLogFile(filename))
{
if (loadLogFile(filename, frames))
{
qDebug() << "Loaded as Busmaster Log successfully!";
return true;
}
}
qDebug() << "Attempting pcan";
if (isPCANFile(filename))
{
if (loadPCANFile(filename, frames))
{
qDebug() << "Loaded as PCAN successfully!";
return true;
}
}
qDebug() << "Attempting ixxat";
if (isIXXATFile(filename))
{
if (loadIXXATFile(filename, frames))
{
qDebug() << "Loaded as IXXAT successfully!";
return true;
}
}
qDebug() << "Attempting microchip";
if (isMicrochipFile(filename))
{
if (loadMicrochipFile(filename, frames))
{
qDebug() << "Loaded as microchip successfully!";
return true;
}
}
qDebug() << "Attempting CANDo";
if (isCANDOFile(filename))
{
if (loadCANDOFile(filename, frames))
{
qDebug() << "Loaded as CANDO successfully!";
return true;
}
}
qDebug() << "Attempting kvaser";
if (isKvaserFile(filename))
{
if (loadKvaserFile(filename, frames,true))
{
qDebug() << "Loaded as Kvaser HEX successfully!";
return true;
}
if (loadKvaserFile(filename, frames,false))
{
qDebug() << "Loaded as KVaser Decimal successfully!";
return true;
}
}
qDebug() << "Attempting CLX000";
if (isCLX000File(filename))
{
if (loadCLX000File(filename, frames))
{
qDebug() << "Loaded as CLX000 successfully!";
return true;
}
}
qDebug() << "Attempting generic CSV";
if (isGenericCSVFile(filename))
{
if (loadGenericCSVFile(filename, frames))
{
qDebug() << "Loaded as generic CSV successfully!";
return true;
}
}
QMessageBox msgBox;
msgBox.setText("Could not autodetect the file type.\rPlease try to manually select the file format.");
msgBox.exec();
qDebug() << "Nothing worked... sorry...";
return false;
}
bool FrameFileIO::isVehicleSpyFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
bool foundProbableHeader = false;
bool isMatch = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try {
for (int i = 0; i < 10; i++)
{
if (!inFile->atEnd())
{
line = inFile->readLine().simplified().toUpper();
if (line.startsWith("LINE") && line.contains("TIME") && line.contains("B1"))
{
foundProbableHeader = true;
}
}
}
if (foundProbableHeader)
{
if (!inFile->atEnd())
{
line = inFile->readLine().simplified().toUpper();
inFile->close();
QList<QByteArray> tokens = line.split(',');
if (tokens.length() > 20)
{
if (tokens[9].toInt(nullptr, 16) > 0) isMatch = true;
}
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
return isMatch;
}
//2,2550.368293675,0.003818174999651092,67371008,F,F,HS CAN $119,HS CAN,,119,F,F,00,00,00,00,00,00,0D,8B,,,
//Line,Abs Time(Sec),Rel Time (Sec),Status,Er,Tx,Description,Network,Node,Arb ID,Remote,Xtd,B1,B2,B3,B4,B5,B6,B7,B8,Value,Trigger,Signals
// 0 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
bool FrameFileIO::loadVehicleSpyFile(QString filename, QVector<CANFrame> *frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int lineCounter = 0;
bool pastHeader = false;
bool foundErrors = false;
QDateTime now = QDateTime::currentDateTime();
QDateTime tempTime;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
while (!inFile->atEnd() && !pastHeader)
{
line = inFile->readLine().simplified().toUpper();
if (line.startsWith("LINE")) lineCounter++;
if (lineCounter == 2) pastHeader = true;
}
if (inFile->atEnd()) foundErrors = true;
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().simplified().toUpper();
QList<QByteArray> tokens = line.split(',');
if (tokens.length() > 20)
{
thisFrame.bus = 0;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
tempTime = now;
tempTime = tempTime.addMSecs(static_cast<int64_t>(tokens[1].toDouble() * 1000.0));
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<uint64_t>(tempTime.toMSecsSinceEpoch() * 1000)));
if (tokens[5].startsWith("T")) thisFrame.isReceived = false;
else thisFrame.isReceived = true;
thisFrame.setFrameId(static_cast<uint32_t>(tokens[9].toInt(nullptr, 16)));
if (tokens[11].startsWith("T")) thisFrame.setExtendedFrameFormat(true);
else thisFrame.setExtendedFrameFormat(false);
QByteArray bytes;
for (int i = 0; i < 8; i++)
{
if (tokens[12 + i].length() > 0)
{
bytes.append(static_cast<char>(tokens[12 + i].toInt(nullptr, 16)));
}
else break;
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveVehicleSpyFile(QString filename, const QVector<CANFrame> *frames)
{
Q_UNUSED(filename);
Q_UNUSED(frames);
return true;
}
bool FrameFileIO::isCRTDFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int lineCounter = 0;
bool isMatch = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine().toUpper(); //read out the header first and discard it.
while (!inFile->atEnd() && lineCounter < 100) {
lineCounter++;
line = inFile->readLine().simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(' ');
if (tokens.length() > 2)
{
char firstChar = tokens[1].left(1)[0];
if (firstChar >= '1' && firstChar <= '9')
{
tokens[1].remove(0,1); // Remove leading digit (bus number)
firstChar = tokens[1].left(1)[0];
}
if (firstChar == 'R' || firstChar == 'T')
{
if (tokens[1] == "R29" || tokens[1] == "T29") isMatch = true;
if (tokens[1] == "R11" || tokens[1] == "T11") isMatch = true;
}
}
else isMatch = false;
}
if (lineCounter > 10) break;
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//CRTD format from Mark Webb-Johnson / OVMS project
// Specification at: https://docs.openvehicles.com/en/latest/crtd/
/*
Sample data in CRTD format
Timestamp appears to be seconds since the epoch
1320745424.000 CXX OVMS Tesla Roadster cando2crtd converted log
1320745424.000 CXX OVMS Tesla roadster log: charge.20111108.csv
1320745424.002 R11 402 FA 01 C3 A0 96 00 07 01
1320745424.015 R11 400 02 9E 01 80 AB 80 55 00
1320745424.066 R11 400 01 01 00 00 00 00 4C 1D
1320745424.105 R11 100 A4 53 46 5A 52 45 38 42
1320745424.106 R11 100 A5 31 35 42 33 30 30 30
1320745424.106 R11 100 A6 35 36 39
1320745424.106 CEV Open charge port door
1320745424.106 R11 100 9B 97 A6 31 03 15 05 06
1320745424.107 R11 100 07 64
123.431 2R11 27E 00 00 00 00 00 00 00 00
123.441 2R11 7C8 00 00 00 00 00 00 00 00
123.451 2R11 402 FD 04 04 0F 10 00 00 07
123.461 2R11 318 92 08 33 0D 07 00 00 00
tokens:
0 = timestamp
1 = line type
2 = ID
3-x = The data bytes
*/
bool FrameFileIO::loadCRTDFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int lineCounter = 0;
bool foundErrors = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
line = inFile->readLine().toUpper(); //read out the header first and discard it.
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(' ');
int multiplier;
if (tokens.length() > 2)
{
int idxOfDecimal = tokens[0].indexOf('.');
if (idxOfDecimal > -1) {
//int decimalPlaces = tokens[0].length() - tokens[0].indexOf('.') - 1;
//the result of the above is the # of digits after the decimal.
//This program deals in microsecond so turn the value into microseconds
multiplier = 1000000; //turn the decimal into full microseconds
}
else
{
multiplier = 1; //special case. Assume no decimal means microseconds
}
//qDebug() << "decimal places " << decimalPlaces;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<int64_t>((tokens[0].toDouble() * multiplier))));
thisFrame.bus = 0;
char firstChar = tokens[1].left(1)[0];
if (firstChar >= '1' && firstChar <= '9')
{
thisFrame.bus = tokens[1].left(1)[0] - '1';
tokens[1].remove(0,1); // Remove leading digit (bus number)
firstChar = tokens[1].left(1)[0];
}
if (firstChar == 'R' || firstChar == 'T')
{
thisFrame.setFrameId(static_cast<uint32_t>(tokens[2].toInt(nullptr, 16)));
if (tokens[1] == "R29" || tokens[1] == "T29") thisFrame.setExtendedFrameFormat(true);
else thisFrame.setExtendedFrameFormat(false);
if (firstChar == 'T') thisFrame.isReceived = false;
else thisFrame.isReceived = true;
QByteArray bytes(tokens.length() - 3, 0);
thisFrame.setFrameType(QCanBusFrame::DataFrame);
for (int d = 0; d < bytes.length(); d++)
{
if (tokens[d + 3] != "")
{
bytes[d] = static_cast<char>(tokens[d + 3].toInt(nullptr, 16));
}
else bytes[d] = 0;
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
}
else foundErrors = true;
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::isCARBUSAnalyzerFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
bool isMatch = false;
// not Text mode because file contains `\r` new lines
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
try
{
//read header
line = inFile->readLine().toUpper();
if (line.startsWith("@ TEXT @")) return true;
} catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
// CARBUS Analayzer trace format https://canhacker.ru/can-trace-format/ :
// header
//@ TEXT @ 2 @ 64 @ 0 @ 591 @ 38782 @ 00:00:38.782 @
// 2 - format version
//14,687 1 0004 4E0 8 24 00 00 00 00 00 00 00 00000000 $
// timestamp: sec,ms - for version 2
// sec,us - for version 3
bool FrameFileIO::loadCARBUSAnalyzerFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
CANFrame thisFrame;
QString line;
int lineCounter = 0;
bool foundErrors = false;
// readLine() works only with "\n" and "\r\n"
QString localReadAll = inFile->readAll().replace("\r", "\r\n");
QTextStream txt(&localReadAll);
line = txt.readLine().toUpper(); //read out the header
int version = 3; // current default
QRegularExpression re("@ TEXT @ (?<version>\\d) @.*");
QRegularExpressionMatch match = re.match(line);
if (match.hasMatch()) {
version = match.captured("version").toInt();
}
while (!txt.atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = txt.readLine().simplified();
if (line.length() > 2)
{
QList<QString> tokens = line.split(QRegularExpression("\\s+"));
if (tokens.length() > 3)
{
QString time = tokens[0].replace(",", "");
int64_t timeStamp = time.toInt();
if (version == 2) {
timeStamp *= 1000; // ms -> us
}
thisFrame.isReceived = true;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<int64_t>(timeStamp)));
thisFrame.bus = tokens[1].toInt();
thisFrame.setFrameId(static_cast<uint32_t>(tokens[3].toInt(nullptr, 16)));
thisFrame.setExtendedFrameFormat(thisFrame.frameId() > 0x7FF);
int numBytes = tokens[4].toInt(nullptr, 16);
QByteArray bytes(numBytes , 0);
for (int d = 0; d < numBytes; d++)
{
if (tokens[d + 5] != "")
{
bytes[d] = static_cast<unsigned char>(tokens[d + 5].toInt(nullptr, 16));
}
else bytes[d] = 0;
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else
{
foundErrors = true;
}
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveCARBUSAnalzyer(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
QTextStream outTextStream(outFile);
int lineCounter = 0;
qint64 minTime = frames->at(0).timeStamp().microSeconds();
qint64 maxTime = minTime;
for (int c = 0; c < frames->count(); c++)
{
if (frames->at(c).timeStamp().microSeconds() < minTime) minTime = frames->at(c).timeStamp().microSeconds();
if (frames->at(c).timeStamp().microSeconds() > maxTime) maxTime = frames->at(c).timeStamp().microSeconds();
}
qint64 totalTime = maxTime - minTime;
// looks like a bug in CARBUS format for 3 version. time is in ms, while packets in us.
totalTime /= 1000;
QTime someTime(0,0,0);
someTime = someTime.addMSecs(totalTime);
// header:
// @see #loadCARBUSAnalyzer()
// 14012 = number of packets
// 15688 = max time - start time in ms
//
// "@ TEXT @ 3 @ 64 @ 0 @ 14012 @ 15688 @ 00:00:15.688 @"
// saving in version format 3 with microseconds in packets time
outTextStream << "@ TEXT @ 3 @ 64 @ 0 @ " << frames->count() << " @ " << totalTime
<<" @ " << someTime.toString("hh:mm:ss.zzz") <<" @\r";
const unsigned char *data;
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
auto frame = frames->at(c);
uint64_t timeStamp = frame.timeStamp().microSeconds();
QString canId = QString::number(frame.frameId(), 16).toUpper().rightJustified(3, '0').toUtf8();
QString canDlc = QString::number(frame.payload().length()).toUtf8();
QString ascii = "";
QString finalCanData;
data = reinterpret_cast<const unsigned char *>(frame.payload().constData());
for (int d = 0; d < frame.payload().length(); d++)
{
auto octet = data[d];
finalCanData.append(QString::number(octet, 16).toUpper().rightJustified(2, '0').toUtf8());
finalCanData.append(" ");
QString strCode = QString::number(octet, 16);
bool conv;
uint symbolCode = strCode.toInt(&conv, 16);
if ((symbolCode >= 32 && symbolCode < 126)) {
QChar localQChar = QChar(symbolCode);
if (localQChar.toLatin1() != 0) {
ascii += QString::fromLocal8Bit(QByteArray::fromHex(strCode.toLatin1()));
}
} else {
ascii += " ";
}
}
finalCanData = finalCanData.trimmed().leftJustified(23, ' ');
ascii = ascii.leftJustified(8, ' ');
auto seconds = QString::number(timeStamp / 1000000);
auto uSeconds = QString::number(timeStamp % 1000000);
QString localArg = "";
localArg.append(seconds).append(",").append(uSeconds).append("\t")
.append(QString::number(frame.bus)).append("\t") // bus channel
.append("0004").append("\t") // it's CAN frame
.append(canId).append("\t")
.append(canDlc).append("\t")
.append(finalCanData).append("\t")
.append("00000000").append("\t")
.append(ascii).append("\t")
.append("\r");
qDebug() << localArg;
outTextStream << localArg;
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isCANHackerFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int lineCounter = 0;
bool isMatch = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine().toUpper(); //read out the header first and discard it.
if (line.contains("CANHACKER")) return true;
while (!inFile->atEnd()) {
lineCounter++;
line = inFile->readLine().simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(' ');
if (tokens.length() > 3)
{
if (tokens[1].toInt(nullptr, 16) > 0)
{
int len = tokens[2].toInt();
if (len > -1 && len < 9)
{
isMatch = true;
}
}
}
else isMatch = false;
}
if (lineCounter > 10) break;
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
// CANHacker trace format
// Time ID DLC Data Comment
// 00.000 00004000 8 36 47 19 43 01 00 00 80
bool FrameFileIO::loadCANHackerFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int lineCounter = 0;
bool foundErrors = false;
int addendumTime = 0;
double previousTime = 0;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
line = inFile->readLine().toUpper(); //read out the header first and discard it.
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(' ');
int multiplier;
if (tokens.length() > 3)
{
int idxOfDecimal = tokens[0].indexOf('.');
if (idxOfDecimal > -1) {
//int decimalPlaces = tokens[0].length() - tokens[0].indexOf('.') - 1;
//the result of the above is the # of digits after the decimal.
//This program deals in microsecond so turn the value into microseconds
multiplier = 1000000; //turn the decimal into full microseconds
}
else
{
multiplier = 1; //special case. Assume no decimal means microseconds
}
//qDebug() << "decimal places " << decimalPlaces;
if (previousTime > tokens[0].toDouble()) {
addendumTime += 60;
}
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<uint64_t>((tokens[0].toDouble() + addendumTime) * multiplier)));
previousTime = tokens[0].toDouble();
thisFrame.setFrameId( static_cast<uint32_t>(tokens[1].toInt(nullptr, 16)) );
thisFrame.setExtendedFrameFormat((thisFrame.frameId() > 0x7FF));
thisFrame.isReceived = true;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
thisFrame.bus = 0;
int numBytes = tokens[2].toInt(nullptr, 16);
QByteArray bytes( numBytes, 0);
for (int d = 0; d < numBytes; d++)
{
if (tokens[d + 3] != "")
{
bytes[d] = static_cast<char>(tokens[d + 3].toInt(nullptr, 16));
}
else bytes[d] = 0;
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::isCANOpenFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int lineCounter = 0;
bool isMatch = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine().toUpper();
if (!line.contains("CANOPEN MAGIC")) return false;
line = inFile->readLine();
line = inFile->readLine();
line = inFile->readLine();
line = inFile->readLine();
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 10)
{
break;
}
line = inFile->readLine().replace('\"', ' ').simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(',');
if (tokens.length() > 11)
{
if (Utility::ParseStringToNum(tokens[5].simplified()) > 0)
{
QList<QByteArray> dataTok = tokens[11].simplified().split(' ');
if ( dataTok.length() > -1 && dataTok.length() < 9) isMatch = true;
}
}
else isMatch = false;
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//"Message Number","Time (ms)","Time","Excel Time","Count","ID","Flags","Message Type","Node","Details","Process Data","Data (Hex)","Data (Text)","Data (Decimal)","Length","Raw Message"
//"0","0.000","8:09:42:48.7953090'",43447.7100146116,"","0x2E1","","Default: PDO","","Default: TPDO 2 of Node 0x61 (97)","","10 21 04 00 00 00 00 00 ",". ! . . . . . . ","U:0 S:0","8","10 21 04 00 00 00 00 00"
bool FrameFileIO::loadCANOpenFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int lineCounter = 0;
bool foundErrors = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
qDebug() << "Could not open the file!";
return false;
}
line = inFile->readLine(); //read out the header first and discard it.
line = inFile->readLine();
line = inFile->readLine();
line = inFile->readLine();
line = inFile->readLine();
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().replace('\"', ' ').simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(',');
if (tokens.length() > 11)
{
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<uint64_t>(tokens[1].simplified().toDouble() * 1000.0)));
thisFrame.setFrameId(static_cast<uint32_t>(Utility::ParseStringToNum(tokens[5].simplified())));
thisFrame.setExtendedFrameFormat( (thisFrame.frameId() > 0x7FF) );
thisFrame.isReceived = true;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
thisFrame.bus = 0;
QList<QByteArray> dataTok = tokens[11].simplified().split(' ');
QByteArray bytes(dataTok.length(), 0);
for (int d = 0; d < dataTok.length(); d++)
{
if (dataTok[d] != "")
{
bytes[d] = static_cast<char>(dataTok[d].simplified().toInt(nullptr, 16));
}
else bytes[d] = 0;
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveCRTDFile(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
int lineCounter = 0;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
//write in float format with 6 digits after the decimal point
outFile->write(QString::number(frames->at(0).timeStamp().microSeconds() / 1000000.0, 'f', 6).toUtf8() + tr(" CXX GVRET-PC Reverse Engineering Tool Output V").toUtf8() + QString::number(VERSION).toUtf8());
outFile->write("\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
outFile->write(QString::number(frame->timeStamp().microSeconds() / 1000000.0, 'f', 6).toUtf8());
outFile->putChar(' ');
outFile->write(QString::number(frame->bus + 1).toUtf8());
if (frame->isReceived) outFile->putChar('R');
else outFile->putChar('T');
if (frame->hasExtendedFrameFormat())
{
outFile->write("29 ");
}
else outFile->write("11 ");
outFile->write(QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8());
outFile->putChar(' ');
for (int temp = 0; temp < dataLen; temp++)
{
outFile->write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
outFile->putChar(' ');
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isPCANFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int lineCounter = 0;
bool hasFileVer = false;
bool isMatch = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 25)
{
break;
}
line = inFile->readLine();
if (line.startsWith(";$FILEVERSION=")) hasFileVer = true;
if (line.toUpper().contains("PCAN") && hasFileVer) isMatch = true;
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
/*Fixed length lines
Version 1.1
//; Message Number
//; | Time Offset (ms)
//; | | Type
//; | | | ID (hex)
//; | | | | Data Length Code
//; | | | | | Data Bytes (hex) ...
//; | | | | | |
//;---+-- ----+---- --+-- ----+--- + -+ -- -- -- -- -- -- --
// 0-6 10-18 21-25 28-35 38 41-? two chars each + space
// Version 1.3
//; Message Time Bus Type ID Reserved
//; Number Offset | | [hex] | Data Length Code
//; | [ms] | | | | | Data [hex] ...
//; | | | | | | | |
//;---+-- ------+------ +- --+-- ---+---- +- -+-- -+ -- -- -- -- -- -- --
// 0-6 8-20 22 25-26 38 41-? two chars each + space
// 1) 1004.898 1 Tx 079B - 8 02 21 04 00 00 00 00 00
Version 2.0
; Message Time Type ID Rx/Tx
; Number Offset | [hex] | Data Length
; | [ms] | | | | Data [hex] ...
; | | | | | | |
;---+-- ------+------ +- --+----- +- +- +- +- -- -- -- -- -- -- --
0-6 8-20 22-23 25-32 34-35 37-38 40-? two chars each + space
Both versions are supported now but rather lazily. Very many aspects of the file are ignored.
It seems as if Version 2 files might be able to store other protocols like ISO-TP or J1939
*/
bool FrameFileIO::loadPCANFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int lineCounter = 0;
int fileVersion = 11;
bool foundErrors = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine();
if (line.startsWith(";$FILEVERSION=2.0")) fileVersion = 20;
if (line.startsWith(";$FILEVERSION=1.3")) fileVersion = 13;
if (line.startsWith(";$FILEVERSION=1.1")) fileVersion = 11;
if (line.startsWith(';')) continue;
if (line.length() > 41)
{
line = line.simplified();
QList<QByteArray> tokens = line.split(' ');
if (fileVersion == 11)
{
if (tokens.length() > 4)
{
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, (uint64_t)(tokens[1].toDouble() * 1000.0)));
thisFrame.setFrameId(tokens[3].toUInt(nullptr, 16));
if (thisFrame.frameId() < 0x1FFFFFFF)
{
int numBytes = tokens[4].toInt();
QByteArray bytes(numBytes, 0);
thisFrame.isReceived = true;
thisFrame.bus = 0;
if (thisFrame.frameId() > 0x10000000)
{
thisFrame.setExtendedFrameFormat(true);
}
else
{
thisFrame.setExtendedFrameFormat(false);
}
if (tokens[5] == "R")
{
thisFrame.setFrameType(QCanBusFrame::RemoteRequestFrame);
}
else
{
thisFrame.setFrameType(QCanBusFrame::DataFrame);
for (int d = 0; d < numBytes; d++)
{
if (tokens[d + 5] != "")
{
bytes[d] = static_cast<char>(tokens[d + 5].toInt(nullptr, 16));
}
else bytes[d] = 0;
}
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
}
}
// Version 1.3
//; Message Time Bus Type ID Reserved
//; Number Offset | | [hex] | Data Length Code
//; | [ms] | | | | | Data [hex] ...
//; | | | | | | | |
//;---+-- ------+------ +- --+-- ---+---- +- -+-- -+ -- -- -- -- -- -- --
// 0-6 8-20 22 25-26 38 41-? two chars each + space
// 1) 1004.898 1 Tx 1fff079B - 8 02 21 04 00 00 00 00 00
// 0 1 2 3 4 5 6 7-?
else if (fileVersion == 13)
{
if (tokens.length() > 6)
{
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<uint64_t>(tokens[1].toDouble() * 1000.0)));
thisFrame.setFrameId(tokens[3].toUInt(nullptr, 16));
if (thisFrame.frameId() < 0x1FFFFFFF)
{
int numBytes = tokens[6].toInt();
QByteArray bytes(numBytes, 0);
//qDebug() << thisFrame.payload().length();
thisFrame.isReceived = true;
thisFrame.bus = tokens[2].toInt();
if (thisFrame.frameId() > 0x10000000)
{
thisFrame.setExtendedFrameFormat(true);
}
else
{
thisFrame.setExtendedFrameFormat(false);
}
if (tokens[7] == "R")
{
thisFrame.setFrameType(QCanBusFrame::RemoteRequestFrame);
}
else
{
thisFrame.setFrameType(QCanBusFrame::DataFrame);
for (int d = 0; d < numBytes; d++)
{
if (tokens[d + 7] != "")
{
bytes[d] = static_cast<char>(tokens[d + 7].toInt(nullptr, 16));
}
else bytes[d] = 0;
}
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
}
}
else if (fileVersion == 20)
{
if (tokens.length() > 5)
{
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<uint64_t>(tokens[1].toDouble() * 1000.0)));
thisFrame.setFrameId(tokens[3].toUInt(nullptr, 16));
if (thisFrame.frameId() < 0x1FFFFFFF)
{
int numBytes = tokens[5].toInt();
QByteArray bytes(numBytes, 0);
//qDebug() << thisFrame.payload().length();
thisFrame.isReceived = true;
thisFrame.bus = 0;
if (thisFrame.frameId() > 0x10000000)
{
thisFrame.setExtendedFrameFormat(true);
}
else
{
thisFrame.setExtendedFrameFormat(false);
}
if (tokens[6] == "R")
{
thisFrame.setFrameType(QCanBusFrame::RemoteRequestFrame);
}
else
{
thisFrame.setFrameType(QCanBusFrame::DataFrame);
for (int d = 0; d < numBytes; d++)
{
if (tokens[d + 6] != "")
{
bytes[d] = static_cast<char>(tokens[d + 6].toInt(nullptr, 16));
}
else bytes[d] = 0;
}
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
}
}
}
//else foundErrors = true;
}
inFile->close();
delete inFile;
return !foundErrors;
}
//supporting two styles now and they have very different line layouts. Just checking for the header for now. That should still match only ASC files.
bool FrameFileIO::isCanalyzerASC(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
//int lineCounter = 0;
//bool inHeader = true;
bool isMatch = true;
QList<QByteArray> tokens;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
if (!inFile->atEnd())
{
line = inFile->readLine();
if (!line.startsWith("date")) isMatch = false;
}
if (!inFile->atEnd() && isMatch)
{
line = inFile->readLine();
if (!line.startsWith("base")) isMatch = false;
}
if (!inFile->atEnd() && isMatch)
{
line = inFile->readLine();
if (!line.contains("logged")) isMatch = false;
}
if (!inFile->atEnd() && isMatch)
{
line = inFile->readLine();
if (!line.contains("version")) isMatch = false;
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//There tends to be four lines of header first. The last of which starts with // so first burn off lines
//until a line starting with // is seen, then the rest are formatted like this:
//Version 8.0:
//47.971842 2 248 Rx d 8 FF FF FF FF FF FF FF FF
//version 8.1
//47244640.194244 CANFD 1 Rx 122 0 0 6 6 00 00 18 12 D2 00 0 0 200000 0 0 0 0 0
//Version 9.0
//0.001371 CANFD 1 Rx 171 A0066_Unknown 0 0 8 8 00 00 07 76 23 00 00 00 230199 119 220000 62e7 46500250 460a0250 20011736 20010205
//Version 16.0.0
//0.008600 1 358 Rx d 8 04 03 50 01 F0 40 54 2C Length = 233910 BitCount = 121 ID = 856
//Time bus id dir ? len databytes (Ver 8.0)
//Time type bus dir ID ? ? length length bytes then many values of unknown type (ver 8.1)
//Time type bus dir ID SignalName ? ? length length bytes then many values of unknown type (ver 9.0)
//Time bus id dir ? len databytes additional crap (ver 16.0)
//So it seems the file format is not entirely different based on version but rather on some other
//settings... Fun!
bool FrameFileIO::loadCanalyzerASC(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int lineCounter = 0;
bool foundErrors = false;
bool inHeader = true;
int verMajor;
int verMinor;
int verRevision;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
QList<QByteArray> tokens;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine();
if (inHeader)
{
if (line.startsWith("//"))
{
line = line.right(line.length() - 11);
QList<QByteArray> versionTokens = line.split('.');
if (versionTokens.length() > 2)
{
verMajor = versionTokens[0].toInt();
verMinor = versionTokens[1].toInt();
verRevision = versionTokens[2].toInt();
qDebug() << "Major: " << verMajor << " Minor:" << verMinor << " Rev:" << verRevision;
}
}
if (line.startsWith("//") || lineCounter > 4)
{
inHeader = false;
continue;
}
}
if (inHeader) continue;
if (line.length() > 2)
{
tokens = line.simplified().split(' ');
if (tokens[0].contains("Begin")) continue; //probably begin triggerblock but we're ignoring that.
//try to do some investigating to see if this line is a CAN frame or not. The file format has many other potential line types it seems...
if (tokens.length() > 5)
{
if (tokens[3].toUpper().startsWith("RX") || tokens[3].toUpper().startsWith("TX"))
{
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<uint64_t>(tokens[0].toDouble() * 1000000.0)));
if (tokens[1].contains("CAN")) //the different format I haven't seen a whole lot of, seems to support CANFD in this format
{
if (tokens[4].endsWith('x'))
{
QByteArray copied_id = tokens[4];
copied_id.chop(1);
thisFrame.setFrameId(copied_id.toUInt(nullptr, 16));
thisFrame.setExtendedFrameFormat(true);
}
else
{
thisFrame.setFrameId(tokens[4].toUInt(nullptr, 16));
thisFrame.setExtendedFrameFormat(thisFrame.frameId() > 0x7FF); //some .asc files have extended IDs without 'x'
}
int payloadLen = tokens[8].toInt();
qDebug() << "PayloadLen: " << payloadLen << " Tokens: " << tokens;
QByteArray bytes(payloadLen, 0);
if (payloadLen > 8)
{
qDebug() << "Payload length too long. Original line: " << line;
return false;
}
if (payloadLen < 0)
{
qDebug() << "Payload length negative! Original line: " << line;
return false;
}
thisFrame.isReceived = tokens[3].toUpper().contains("RX");
thisFrame.bus = tokens[2].toInt();
if (tokens[5].at(0) >= '0' && tokens[5].at(0) <= '9')
{
for (int d = 9; d < (9 + payloadLen); d++)
{
if (tokens.count() > d)
{
bytes[d - 9] = static_cast<char>(tokens[d].toInt(nullptr, 16));
}
else //expected byte wasn't there to read. Set it zero and set error flag
{
bytes[d - 9] = 0;
foundErrors = true;
qDebug() << "D:" << d << " Count:" << tokens.count();
qDebug() << "Expected byte missing! Original line: " << line;
}
}
thisFrame.setPayload(bytes);
}
else
{
for (int d = 10; d < (10 + payloadLen); d++)
{
if (tokens.count() > d)
{
bytes[d - 10] = static_cast<char>(tokens[d].toInt(nullptr, 16));
}
else //expected byte wasn't there to read. Set it zero and set error flag
{
bytes[d - 10] = 0;
foundErrors = true;
qDebug() << "D:" << d << " Count:" << tokens.count();
qDebug() << "Expected byte missing! Original line: " << line;
}
}
thisFrame.setPayload(bytes);
}
}
else
{
int payloadLen = tokens[5].toInt();
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<uint64_t>(tokens[0].toDouble() * 1000000.0)));
if (tokens[2].endsWith('x'))
{
QByteArray copied_id = tokens[2];
copied_id.chop(1);
thisFrame.setFrameId(copied_id.toUInt(nullptr, 16));
thisFrame.setExtendedFrameFormat(true);
}
else
{
thisFrame.setFrameId(tokens[2].toUInt(nullptr, 16));
thisFrame.setExtendedFrameFormat(thisFrame.frameId() > 0x7FF); //some .asc files have extended IDs without 'x'
}
QByteArray bytes(payloadLen, 0);
if (payloadLen > 8)
{
qDebug() << "Payload length too long. Original line: " << line;
return false;
}
if (payloadLen < 0)
{
qDebug() << "Payload length negative! Original line: " << line;
return false;
}
thisFrame.isReceived = tokens[3].toUpper().contains("RX");
thisFrame.bus = tokens[1].toInt();
if (tokens[4] == "r") thisFrame.setFrameType(QCanBusFrame::RemoteRequestFrame);
for (int d = 6; d < (6 + payloadLen); d++)
{
if (tokens.count() > d)
{
bytes[d - 6] = static_cast<char>(tokens[d].toInt(nullptr, 16));
}
else //expected byte wasn't there to read. Set it zero and set error flag
{
bytes[d - 6] = 0;
foundErrors = true;
qDebug() << "D:" << d << " Count:" << tokens.count();
qDebug() << "Expected byte missing! Original line: " << line;
}
}
thisFrame.setPayload(bytes);
}
frames->append(thisFrame);
}
}
}
//else foundErrors = true;
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveCanalyzerASC(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
int lineCounter = 0;
int64_t offsetTime = frames->at(0).timeStamp().microSeconds();
const unsigned char *data;
int dataLen;
const CANFrame *frame;
for (int c = 0; c < frames->count(); c++)
{
if (frames->at(c).timeStamp().microSeconds() < offsetTime) offsetTime = frames->at(c).timeStamp().microSeconds();
}
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
QDateTime now;
now = QDateTime::currentDateTime();
if (offsetTime > 10000000000) //chances are the input file had times as system time so load it
{
now.setMSecsSinceEpoch(offsetTime / 1000); //offsetTime was in microseconds
}
outFile->write("date " + now.toString("ddd MMM dd h:mm:ss.zzz a yyyy").toUtf8());
outFile->write("\nbase hex timestamps absolute\n");
outFile->write("no internal event logging\n");
outFile->write("// version 11.0.0\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
uint64_t timeStamp = (frame->timeStamp().microSeconds() - offsetTime) / 1000000ull;
int tsLen = QString::number(timeStamp).length();
int precision = 6;
//vector seems to keep 10 bytes at the start of the line for the timestamp. It should never exceed this
//and there should never be a precision over 6 digits after the decimal
if (tsLen > 3) precision = 9 - tsLen;
outFile->write(QString::number((frame->timeStamp().microSeconds() - offsetTime) / 1000000.0, 'f', precision).rightJustified(10, ' ').toUtf8());
outFile->putChar(' ');
outFile->write(QString::number(frame->bus + 1).toUtf8());
outFile->write(" ");
if (frames->at(c).hasExtendedFrameFormat())
{
outFile->write(QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8());
outFile->write("x");
}
else
{
outFile->write(QString::number(frame->frameId(), 16).toUpper().rightJustified(3, '0').toUtf8());
outFile->write(" ");
}
outFile->write(" ");
if (frames->at(c).isReceived) outFile->write("Rx ");
else outFile->write("Tx ");
if (frames->at(c).frameType() == QCanBusFrame::RemoteRequestFrame) outFile->write("r ");
else outFile->write("d ");
outFile->write(QString::number(dataLen).toUtf8());
outFile->write(" ");
for (int temp = 0; temp < dataLen; temp++)
{
outFile->write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
outFile->write(" ");
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isCanalyzerBLF(QString filename)
{
BLF_FILE_HEADER header;
QFile *inFile = new QFile(filename);
bool isMatch = false;
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
inFile->read(reinterpret_cast<char *>(&header), sizeof(header));
if (qFromLittleEndian(header.sig) == 0x47474F4C)
{
qDebug() << "Proper BLF file header token";
isMatch = true;
}
else isMatch = false;
inFile->close();
delete inFile;
return isMatch;
}
//this one is pretty complicated and handled by it's own class
bool FrameFileIO::loadCanalyzerBLF(QString filename, QVector<CANFrame> *frames)
{
BLFHandler blf;
return blf.loadBLF(filename, frames);
}
bool FrameFileIO::isNativeCSVFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int fileVersion = 1;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine().toUpper(); //read out the header first and discard it.
if (line.length() < 23) isMatch = false;
else if (line.at(23) == 'D') fileVersion = 2; //Dir is found starting at position 23 if this is a V2 file
if (!line.contains("TIME STAMP")) isMatch = false;
if (!line.contains("EXTENDED")) isMatch = false;
if (!line.contains("D1")) isMatch = false;
if (!inFile->atEnd()) {
line = inFile->readLine().simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(',');
if (tokens.length() >= 5)
{
if (fileVersion == 1)
{
if (tokens[4].toUInt() > 8) isMatch = false;
}
else if (fileVersion == 2)
{
if ( tokens[5].toUInt() > 8) isMatch = false;
}
}
else isMatch = false;
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//The "native" file format for this program
//Time Stamp,ID,Extended,Dir,Bus,LEN,D1,D2,D3,D4,D5,D6,D7,D8
//39747828,000005EB,false,Rx,0,8,E8,45,85,4B,4A,28,36,69,
bool FrameFileIO::loadNativeCSVFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int fileVersion = 1;
uint64_t timeStamp = Utility::GetTimeMS();
int lineCounter = 0;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
line = inFile->readLine().toUpper(); //read out the header first and discard it.
if (line.at(23) == 'D') fileVersion = 2; //Dir is found starting at position 23 if this is a V2 file
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(',');
if (tokens.length() >= 5)
{
if (tokens[0].length() > 3)
{
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, tokens[0].toULongLong()));
}
else
{
timeStamp += 5;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, timeStamp));
}
thisFrame.setFrameId(tokens[1].toUInt(nullptr, 16));
if (tokens[2].toUpper().contains("TRUE")) thisFrame.setExtendedFrameFormat(true);
else thisFrame.setExtendedFrameFormat(false);
//fix for faulty files that fail to set the extended flag when they should
if (thisFrame.frameId() > 0x7FF) thisFrame.setExtendedFrameFormat(true);
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (fileVersion == 1)
{
thisFrame.isReceived = true;
thisFrame.bus = tokens[3].toInt();
int lng = tokens[4].toInt();
if (lng > 8) lng = 8;
if (lng < 0) lng = 0;
if (lng + 5 > tokens.length()) lng = tokens.length() - 5;
QByteArray bytes(lng, 0);
for (int c = 0; c < lng; c++) bytes[c] = 0;
for (int d = 0; d < lng; d++)
bytes[d] = static_cast<char>(tokens[5 + d].toInt(nullptr, 16));
thisFrame.setPayload(bytes);
}
else if (fileVersion == 2)
{
if (tokens[3].at(0) == 'R') thisFrame.isReceived = true;
else thisFrame.isReceived = false;
thisFrame.bus = tokens[4].toInt();
int lng = tokens[5].toInt();
if (lng > 8) lng = 8;
if (lng < 0) lng = 0;
if (lng + 6 > tokens.length()) lng = tokens.length() - 6;
QByteArray bytes(lng, 0);
for (int c = 0; c < lng; c++) bytes[c] = 0;
for (int d = 0; d < lng; d++)
bytes[d] = static_cast<char>(tokens[6 + d].toInt(nullptr, 16));
thisFrame.setPayload(bytes);
}
frames->append(thisFrame);
}
else foundErrors = true;
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveNativeCSVFile(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
int lineCounter = 0;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
outFile->write("Time Stamp,ID,Extended,Dir,Bus,LEN,D1,D2,D3,D4,D5,D6,D7,D8");
outFile->write("\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
outFile->write(QString::number(frame->timeStamp().microSeconds()).toUtf8());
outFile->putChar(44);
outFile->write(QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8());
outFile->putChar(44);
if (frame->hasExtendedFrameFormat()) outFile->write("true,");
else outFile->write("false,");
if (frame->isReceived) outFile->write("Rx,");
else outFile->write("Tx,");
outFile->write(QString::number(frame->bus).toUtf8());
outFile->putChar(44);
outFile->write(QString::number(dataLen).toUtf8());
outFile->putChar(44);
for (int temp = 0; temp < 8; temp++)
{
if (temp < dataLen)
outFile->write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
else
outFile->write("00");
outFile->putChar(44);
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::openContinuousNative()
{
QString filename;
QFileDialog dialog(qApp->activeWindow());
QSettings settings;
QStringList filters;
filters.append(QString(tr("GVRET Logs (*.csv *.CSV)")));
dialog.setDirectory(settings.value("FileIO/LoadSaveDirectory", dialog.directory().path()).toString());
dialog.setFileMode(QFileDialog::AnyFile);
dialog.setNameFilters(filters);
dialog.setViewMode(QFileDialog::Detail);
dialog.setAcceptMode(QFileDialog::AcceptSave);
if (dialog.exec() == QDialog::Accepted)
{
filename = dialog.selectedFiles()[0];
continuousFile.setFileName(filename);
if (!continuousFile.open(QIODevice::WriteOnly | QIODevice::Text))
{
return false;
}
continuousFile.write("Time Stamp,ID,Extended,Dir,Bus,LEN,D1,D2,D3,D4,D5,D6,D7,D8");
continuousFile.write("\n");
settings.setValue("FileIO/LoadSaveDirectory", dialog.directory().path());
return true;
}
return false;
}
bool FrameFileIO::closeContinuousNative()
{
if (continuousFile.isOpen())
{
continuousFile.close();
return true;
}
return false;
}
bool FrameFileIO::writeContinuousNative(const QVector<CANFrame>* frames, int beginningFrame)
{
const unsigned char *data;
int dataLen;
const CANFrame *frame;
if (!continuousFile.isOpen()) return false;
qDebug() << "Bgn: " << beginningFrame << " Count: " << frames->count();
for (int c = beginningFrame; c < frames->count(); c++)
{
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
continuousFile.write(QString::number(frame->timeStamp().microSeconds()).toUtf8());
continuousFile.putChar(44);
continuousFile.write(QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8());
continuousFile.putChar(44);
if (frame->hasExtendedFrameFormat()) continuousFile.write("true,");
else continuousFile.write("false,");
if (frame->isReceived) continuousFile.write("Rx,");
else continuousFile.write("Tx,");
continuousFile.write(QString::number(frame->bus).toUtf8());
continuousFile.putChar(44);
continuousFile.write(QString::number(dataLen).toUtf8());
continuousFile.putChar(44);
for (int temp = 0; temp < 8; temp++)
{
if (temp < dataLen)
continuousFile.write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
else
continuousFile.write("00");
continuousFile.putChar(44);
}
continuousFile.write("\n");
}
return true;
}
bool FrameFileIO::flushContinuousNative()
{
if (continuousFile.isOpen())
{
return continuousFile.flush();
}
return false;
}
bool FrameFileIO::isGenericCSVFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine(); //read out the header first and discard it.
if (!inFile->atEnd()) {
line = inFile->readLine();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(',');
int ID = tokens[0].toInt(nullptr, 16);
if (ID < 1 || ID > 0x1FFFFFFF) isMatch = false;
if (tokens.count() < 2)
{
isMatch = false;
}
if (isMatch)
{
QList<QByteArray> dataTok = tokens[1].split(' ');
int len = dataTok.length();
if (len > 8) isMatch = false;
if (len < 2) isMatch = false;
}
}
else isMatch = false;
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
bool FrameFileIO::loadGenericCSVFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
uint64_t timeStamp = Utility::GetTimeMS();
int lineCounter = 0;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
line = inFile->readLine(); //read out the header first and discard it.
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(',');
timeStamp += 5000;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, timeStamp));
thisFrame.setFrameId(tokens[0].toUInt(nullptr, 16));
if (thisFrame.frameId() > 0x7FF) thisFrame.setExtendedFrameFormat(true);
else thisFrame.setExtendedFrameFormat(false);
thisFrame.bus = 0;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (tokens.length() > 1)
{
QList<QByteArray> dataTok = tokens[1].split(' ');
int dLen = dataTok.length();
if (dLen > 8) dLen = 8;
QByteArray bytes(dLen, 0);
for (int d = 0; d < dLen; d++) bytes[d] = static_cast<char>(dataTok[d].toInt(nullptr, 16));
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
}
else foundErrors = true;
}
inFile->close();
delete inFile;
return !foundErrors;
}
//4f5,ff 34 23 45 24 e4
bool FrameFileIO::saveGenericCSVFile(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
int lineCounter = 0;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
outFile->write("ID,Data Bytes");
outFile->write("\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
outFile->write(QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8());
outFile->putChar(44);
for (int temp = 0; temp < dataLen; temp++)
{
outFile->write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
outFile->putChar(' ');
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isLogFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine().toUpper();
if (!line.contains("BUSMASTER")) isMatch = false;
while (!inFile->atEnd() && line.startsWith("***")) {
line = inFile->readLine().toUpper();
}
if (!inFile->atEnd())
{
line = inFile->readLine().toUpper();
if (line.length() > 1)
{
QList<QByteArray> tokens = line.split(' ');
if (tokens.length() >= 6)
{
QList<QByteArray> timeToks = tokens[0].split(':');
if (timeToks.count() != 4) isMatch = false;
int ID = tokens[3].right(tokens[3].length() - 2).toInt(nullptr, 16);
if (ID < 1 || ID > 0x1FFFFFFF) isMatch = false;
if (tokens[4] != "S" && tokens[4] != "X" && tokens[4] != "SR" && tokens[4] != "XR") isMatch = false;
int len = tokens[5].toInt();
if (len > 8) isMatch = false;
}
else isMatch = false;
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//busmaster log file
/*
tokens:
0 = timestamp
1 = Transmission direction
2 = Channel
3 = ID
4 = Type (s = standard, x = extended, sr = standard remote, xr = extended remote)
5 = Data byte length
6-x = The data bytes
Sample chunk of a busmaster log:
***BUSMASTER Ver 2.4.0***
***PROTOCOL CAN***
***NOTE: PLEASE DO NOT EDIT THIS DOCUMENT***
***[START LOGGING SESSION]***
***START DATE AND TIME 8:8:2014 11:49:7:965***
***HEX***
***SYSTEM MODE***
***START CHANNEL BAUD RATE***
***CHANNEL 1 - Kvaser - Kvaser Leaf Light HS #0 (Channel 0), Serial Number- 0, Firmware- 0x00000037 0x00020000 - 500000 bps***
***END CHANNEL BAUD RATE***
***START DATABASE FILES (DBF/DBC)***
***END OF DATABASE FILES (DBF/DBC)***
***<Time><Tx/Rx><Channel><CAN ID><Type><DLC><DataBytes>***
11:49:12:9420 Rx 1 0x023 s 1 40
11:49:12:9440 Rx 1 0x460 s 8 03 E0 00 00 C0 00 00 00
11:49:12:9530 Rx 1 0x023 s 1 40
11:49:12:9680 Rx 1 0x408 s 8 0F 02 00 30 00 00 7F 00
11:49:12:9680 Rx 1 0x40B s 8 00 00 00 00 00 10 60 00
11:49:12:9690 Rx 1 0x045 s 8 40 00 00 00 00 00 00 00
*/
bool FrameFileIO::loadLogFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
uint64_t timeStamp = Utility::GetTimeMS();
int lineCounter = 0;
bool foundErrors = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
line = inFile->readLine(); //read out the header first and discard it.
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().toUpper();
if (line.startsWith("***")) continue;
if (line.length() > 1)
{
QList<QByteArray> tokens = line.split(' ');
if (tokens.length() >= 6)
{
QList<QByteArray> timeToks = tokens[0].split(':');
timeStamp = (timeToks[0].toUInt() * (1000ul * 1000ul * 60ul * 60ul)) + (timeToks[1].toUInt() * (1000ul * 1000ul * 60ul))
+ (timeToks[2].toUInt() * (1000ul * 1000ul)) + (timeToks[3].toUInt() * 100ul);
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, timeStamp));
if (tokens[1].at(0) == 'R') thisFrame.isReceived = true;
else thisFrame.isReceived = false;
thisFrame.setFrameId(tokens[3].right(tokens[3].length() - 2).toUInt(nullptr, 16));
if (tokens[4] == "S") {
thisFrame.setExtendedFrameFormat(false);
thisFrame.setFrameType(QCanBusFrame::DataFrame);
} else if (tokens[4] == "X") {
thisFrame.setExtendedFrameFormat(true);
thisFrame.setFrameType(QCanBusFrame::DataFrame);
} else if (tokens[4] == "SR") {
thisFrame.setExtendedFrameFormat(false);
thisFrame.setFrameType(QCanBusFrame::RemoteRequestFrame);
} else { // XR
thisFrame.setExtendedFrameFormat(true);
thisFrame.setFrameType(QCanBusFrame::RemoteRequestFrame);
}
thisFrame.bus = tokens[2].toInt();
int lng = tokens[5].toInt();
if (lng > 8) lng = 8;
if (lng < 0) lng = 0;
QByteArray bytes(lng, 0);
if (thisFrame.frameType() != QCanBusFrame::RemoteRequestFrame) {
for (int d = 0; d < lng; d++)
bytes[d] = static_cast<char>(tokens[d + 6].toInt(nullptr, 16));
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveLogFile(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
QDateTime timestamp, tempStamp;
int lineCounter = 0;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
//timestamp = QDateTime::currentDateTime();
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
outFile->write("***BUSMASTER Ver 3.2.0***\n");
outFile->write("***PROTOCOL CAN***\n");
outFile->write("***NOTE: PLEASE DO NOT EDIT THIS DOCUMENT***\n");
outFile->write("***[START LOGGING SESSION]***\n");
outFile->write("***START DATE AND TIME ");
outFile->write(timestamp.toString("d:M:yyyy h:m:s:z").toUtf8());
outFile->write("***\n");
outFile->write("***HEX***\n");
outFile->write("***SYSTEM MODE***\n");
outFile->write("***START CHANNEL BAUD RATE***\n");
outFile->write("***CHANNEL 1 - Kvaser - Kvaser Leaf Light HS #0 (Channel 0), Serial Number- 0, Firmware- 0x00000037 0x00020000 - 500000 bps***\n");
outFile->write("***END CHANNEL BAUD RATE***\n");
outFile->write("***START DATABASE FILES***\n");
outFile->write("***END OF DATABASE FILES***\n");
outFile->write("***<Time><Tx/Rx><Channel><CAN ID><Type><DLC><DataBytes>***\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
tempStamp = QDateTime::fromMSecsSinceEpoch(frame->timeStamp().microSeconds() / 1000);
outFile->write(tempStamp.toString("hh:mm:ss:zzz").toUtf8());
if (frame->isReceived) outFile->write(" Rx ");
else outFile->write(" Tx ");
// busmaster channel start at 1
outFile->write(QString::number(frame->bus + 1).toUtf8() + " ");
outFile->write("0x");
if (frame->hasExtendedFrameFormat() && frame->frameId() > 0x7FF) {
outFile->write(QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8());
} else {
outFile->write(QString::number(frame->frameId(), 16).toUpper().rightJustified(3, '0').toUtf8());
}
if (frame->hasExtendedFrameFormat()) outFile->write(" x");
else outFile->write(" s");
if (frame->frameType() == QCanBusFrame::RemoteRequestFrame) outFile->write("r ");
else outFile->write(" ");
outFile->write(QString::number(dataLen).toUtf8() + " ");
if (frame->frameType() != QCanBusFrame::RemoteRequestFrame) {
for (int temp = 0; temp < dataLen; temp++)
{
outFile->write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
outFile->putChar(' ');
}
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isIXXATFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine().toUpper();
if (!line.contains("IXXAT")) isMatch = false;
for (int i = 0; i < 6; i++)
{
if (!inFile->atEnd()) line = inFile->readLine().toUpper();
else isMatch = false;
}
if (!line.contains("FORMAT")) isMatch = false;
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//"00:01:03.03","223","Std","","00 00 00 00 49 00 00 01 "
bool FrameFileIO::loadIXXATFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
uint64_t timeStamp = Utility::GetTimeMS();
int lineCounter = 0;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
for (int i = 0; i < 7; i++) line = inFile->readLine(); //read out the header first and discard it.
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().toUpper();
if (line.length() > 1)
{
QList<QByteArray> tokens = line.split(',');
if (line.length() >= 5)
{
QString timePortion = Utility::unQuote(tokens[0]);
QStringList timeToks = timePortion.split(':');
if (timeToks.length() >= 3)
{
timeStamp = (timeToks[0].toUInt() * (1000ul * 1000ul * 60ul * 60ul)) + (timeToks[1].toUInt() * (1000ul * 1000ul * 60ul))
+ static_cast<uint64_t>(timeToks[2].toDouble() * (1000.0 * 1000.0));
}
else
{
timeStamp = 0;
foundErrors = true;
return false;
}
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, timeStamp));
thisFrame.setFrameId(Utility::unQuote(tokens[1]).toUInt(nullptr, 16));
QString tempStr = Utility::unQuote(tokens[2]).toUpper();
if (tempStr.length() > 0)
{
if (tempStr.at(0) == 'S') thisFrame.setExtendedFrameFormat(false);
else thisFrame.setExtendedFrameFormat(true);
}
else
{
thisFrame.setExtendedFrameFormat(false);
foundErrors = true;
return false;
}
thisFrame.isReceived = true;
thisFrame.bus = 0;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
QStringList dataToks = Utility::unQuote(tokens[4]).simplified().split(' ');
int numBytes = dataToks.length();
QByteArray bytes(numBytes, 0);
if (numBytes > 8) return false;
for (int d = 0; d < numBytes; d++) bytes[d] = static_cast<char>(dataToks[d].toInt(nullptr, 16));
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else return false;
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveIXXATFile(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
QDateTime timestamp, tempStamp;
int lineCounter = 0;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
timestamp = QDateTime::currentDateTime();
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
outFile->write("ASCII Trace IXXAT SavvyCAN V" + QString::number(VERSION).toUtf8() + "\n");
outFile->write("Date: " + timestamp.toString("d:M:yyyy").toUtf8() + "\n");
outFile->write("Start time: " + timestamp.toString("h:m:s").toUtf8() + "\n");
timestamp = timestamp.addMSecs((frames->last().timeStamp().microSeconds() - frames->first().timeStamp().microSeconds()) / 1000);
outFile->write("Stop time: " + timestamp.toString("h:m:s").toUtf8() + "\n");
outFile->write("Overruns: 0\n");
outFile->write("Baudrate: 500 kbit/s\n"); //could be a lie... this code has no way to know the baud rate (at the moment)
outFile->write("\"Time\",\"Identifier (hex)\",\"Format\",\"Flags\",\"Data (hex)\"\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
tempStamp = QDateTime::fromMSecsSinceEpoch(frame->timeStamp().microSeconds() / 1000);
outFile->write("\"" + tempStamp.toString("h:m:s.").toUtf8() + tempStamp.toString("z").rightJustified(3, '0').toUtf8() + "\"");
outFile->write(",\"" + QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8() + "\"");
if (frame->hasExtendedFrameFormat()) outFile->write(",\"Ext\"");
else outFile->write(",\"Std\"");
outFile->write(",\"\",\"");
for (int temp = 0; temp < dataLen; temp++)
{
outFile->write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
outFile->putChar(' ');
}
outFile->write("\"\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isCANDOFile(QString filename)
{
QFile *inFile = new QFile(filename);
int lineCounter = 0;
QByteArray data;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
//this file format is in static 12 byte blocks.
//Bytes 0 - 1 are a time stamp
//Bytes 2 - 3 are the data length (top 4 bits) then ID (bottom 11 bits)
//Bytes 4 - 11 are the data bytes (padded with FF for bytes not used)
try
{
while (!inFile->atEnd() && lineCounter < 200)
{
lineCounter++;
data = inFile->read(12);
int ID = ((data[3] & 0x0F) * 256 + data[2]);
int len = data[3] >> 4;
if (len <= 8 && ID <= 0x7FF)
{
if (len < 8)
{
if (data[4 + len] != static_cast<char>(0xFF)) isMatch = false;
}
}
else isMatch = false;
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
bool FrameFileIO::loadCANDOFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
int lineCounter = 0;
QByteArray data;
int timeOffset = 0;
int64_t lastTimeStamp = 0;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
//this file format is in static 12 byte blocks.
//Bytes 0 - 1 are a time stamp
//Bytes 2 - 3 are the data length (top 4 bits) then ID (bottom 11 bits)
//Bytes 4 - 11 are the data bytes (padded with FF for bytes not used)
while (!inFile->atEnd())
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
data = inFile->read(12);
const unsigned char *uData = reinterpret_cast<const unsigned char *>(data.constData());
thisFrame.bus = 0;
thisFrame.isReceived = true;
thisFrame.setExtendedFrameFormat(false); //format is incapable of extended frames
thisFrame.setFrameType(QCanBusFrame::DataFrame);
qint64 tempStamp;
tempStamp = 1000000ul * (uData[0] >> 2);
tempStamp += (((uData[0] & 3) << 8) + uData[1]) * 1000;
tempStamp += timeOffset;
if (tempStamp < lastTimeStamp)
{
timeOffset += 60000000ul;
}
lastTimeStamp = tempStamp;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, tempStamp));
thisFrame.setFrameId(((uData[3] & 0x0F) * 256 + uData[2]) & 0x7FF);
int numBytes = uData[3] >> 4;
QByteArray bytes(numBytes, 0);
if (numBytes <= 8 && thisFrame.frameId() <= 0x7FF)
{
for (int d = 0; d < numBytes; d++) bytes[d] = data[4 + d];
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveCANDOFile(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
int lineCounter = 0;
QByteArray data;
CANFrame thisFrame;
int id;
qint64 ms;
const unsigned char *inData;
int inDataLen;
const CANFrame *frame;
if (!outFile->open(QIODevice::WriteOnly))
{
delete outFile;
return false;
}
data.reserve(13);
//The initial frame in official files sets the global time but I don't care so it is set all zeros here.
thisFrame = frames->at(0);
ms = (thisFrame.timeStamp().microSeconds() / 1000);
data[0] = (((ms / 1000) % 60) << 2) + ((ms % 1000) >> 8);
data[1] = (char)(ms & 0xFF);
data[2] = (char)0xFF;
data[3] = (char)0xFF;
for (int l = 0; l < 8; l++) data[4 + l] = 0;
outFile->write(data);
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
inData = reinterpret_cast<const unsigned char *>(frame->payload().constData());
inDataLen = frame->payload().count();
for (int j = 0; j < 8; j++) data[4 + j] = (char)0xFF;
if (!frame->hasExtendedFrameFormat())
{
ms = (frame->timeStamp().microSeconds() / 1000);
id = frame->frameId() & 0x7FF;
data[0] = (((ms / 1000) % 60) << 2) + ((ms % 1000) >> 8);
data[1] = (char)(ms & 0xFF);
data[2] = (char)(id & 0xFF);
data[3] = (char)((id >> 8) + (inDataLen << 4));
for (int d = 0; d < inDataLen; d++) data[4 + d] = (char)inData[d];
outFile->write(data);
}
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isMicrochipFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
bool inComment = false;
int lineCounter = 0;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
while (!inFile->atEnd() && lineCounter < 100) {
lineCounter++;
line = inFile->readLine();
if (line.length() > 2)
{
if (line.startsWith("//"))
{
inComment = !inComment;
}
else
{
if (!inComment)
{
QList<QByteArray> tokens = line.split(';');
if (tokens.length() >= 4)
{
int ID = Utility::ParseStringToNum(tokens[2]);
if (ID < 1 || ID > 0x1FFFFFFF) isMatch = false;
int len = tokens[3].toInt();
if ( len > 8 || len < 0 ) isMatch = false;
if ( (len + 4) < tokens.length() ) isMatch = false;
}
else isMatch = false;
}
}
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//log file from microchip tool
/*
tokens:
0 = timestamp
1 = Transmission direction
2 = ID
3 = Data byte length
4-x = The data bytes
*/
bool FrameFileIO::loadMicrochipFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
bool inComment = false;
long long timeStamp;
int lineCounter = 0;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
//line = inFile->readLine(); //read out the header first and discard it.
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine();
if (line.length() > 2)
{
if (line.startsWith("//"))
{
inComment = !inComment;
}
else
{
if (!inComment)
{
QList<QByteArray> tokens = line.split(';');
if (tokens.length() >= 4)
{
timeStamp = tokens[0].toInt() * 1000;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, timeStamp));
if (tokens[1].at(0) == 'R') thisFrame.isReceived = true;
else thisFrame.isReceived = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
thisFrame.setFrameId(static_cast<quint32>( Utility::ParseStringToNum(tokens[2])) );
if (thisFrame.frameId() <= 0x7FF) thisFrame.setExtendedFrameFormat(false);
else thisFrame.setExtendedFrameFormat(true);
thisFrame.bus = 0;
int numBytes = tokens[3].toInt();
QByteArray bytes(numBytes, 0);
if (thisFrame.payload().length() > 8) thisFrame.payload().resize(8);
if (thisFrame.payload().length() + 4 > tokens.length()) thisFrame.payload().resize( tokens.length() - 4 );
for (int d = 0; d < numBytes; d++) bytes[d] = static_cast<char>( Utility::ParseStringToNum(tokens[4 + d]) );
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
}
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
/*
1247;RX;0xC2;8;0x5C;0x87;0x00;0x00;0x01;0x00;0x00;0x1C
1218;RX;0x236;1;0x00;0x00;0x00;0x00;0x00;0x00;0x00;0xF0
tokens:
0 = timestamp in ms
1 = direction (RX, TX)
2 = ID (in hex with 0x prefix)
3 = data length
4-x = data bytes in hex with 0x prefix
*/
bool FrameFileIO::saveMicrochipFile(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
QDateTime timestamp, tempStamp;
int lineCounter = 0;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
timestamp = QDateTime::currentDateTime();
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
outFile->write("//---------------------------------\n");
outFile->write("Microchip Technology Inc.\n");
outFile->write("CAN BUS Analyzer\n");
outFile->write("SavvyCAN Exporter\n");
outFile->write("Logging Started: ");
outFile->write(timestamp.toString("d/M/yyyy h:m:s").toUtf8());
outFile->write("\n");
outFile->write("//---------------------------------\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
outFile->write(QString::number((frame->timeStamp().microSeconds() / 1000)).toUtf8());
if (frame->isReceived) outFile->write(";RX;");
else outFile->write(";TX;");
outFile->write("0x" + QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8() + ";");
outFile->write(QString::number(dataLen).toUtf8() + ";");
for (int temp = 0; temp < dataLen; temp++)
{
outFile->write("0x" + QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
outFile->putChar(';');
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isTraceFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int lineCounter = 0;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
while (!inFile->atEnd() && lineCounter < 100) {
lineCounter++;
line = inFile->readLine();
line = line.trimmed();
if (line.length() > 2)
{
if (line.startsWith(";"))
{
// a comment. Ignore it.
}
else
{
QList<QByteArray> tokens = line.split('\t');
if (tokens.length() > 3)
{
QList<QByteArray> timestampToks = tokens[1].split(':');
if (timestampToks.count() != 4) isMatch = false;
long ID = tokens[2].toLong(nullptr, 16);
if (ID < 1 || ID > 0x1FFFFFFF) isMatch = false;
int len = tokens[3].toInt();
if (len > 8 || len < 0) isMatch = false;
QList<QByteArray> dataToks = tokens[4].split(' ');
if (len > dataToks.length()) isMatch = false;
}
else isMatch = false;
}
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
/*
; CAN Logger trace file
; Device Serial Number :
; Start Time : Tue, Nov 17, 2015 :: 11:19:59
;
; Column description :
; ~~~~~~~~~~~~~~~~~~~~~
;
; + Message Number
; |
; | + Time Stamp (ms)
; | |
; | | + Message ID (hex)
; | | |
; | | | + Data Length Code
; | | | |
; | | | | + Data Bytes (hex)
; | | | | |
;---+----- -----+------ ----+--- + -+ -- -- -- -- -- -- --
0 00:00:00:0008 00000268 8 55 00 84 03 A8 0D 38 00
1 00:00:00:0021 0000000E 8 1F D3 3F FF 08 FF E0 CB
It appears that all lines that start in a semicolon are comments
The rest of the lines need the whitespace stripped from beginning and end
and then it appears to be tab delimited. The first field is a sequence number
and irrelevant. The second field is a funky timestamp, then message id, etc as
shown in the file comments. The bytes seem to be space delimited and in hex
*/
bool FrameFileIO::loadTraceFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
long long timeStamp = 0;
int lineCounter = 0;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine();
line = line.trimmed();
if (line.length() > 2)
{
if (line.startsWith(";"))
{
// a comment. Ignore it.
}
else
{
QList<QByteArray> tokens = line.split('\t');
if (tokens.length() > 3)
{
QList<QByteArray> timestampToks = tokens[1].split(':');
timeStamp = timestampToks[0].toInt() * 1000000l * 60 * 60;
timeStamp += timestampToks[1].toInt() * 1000000l * 60;
timeStamp += timestampToks[2].toInt() * 1000000l;
timeStamp += timestampToks[3].toInt() * 100;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, static_cast<uint32_t>(timeStamp)));
thisFrame.setFrameId(static_cast<uint32_t>(tokens[2].toLong(nullptr, 16)));
if (thisFrame.frameId() <= 0x7FF) thisFrame.setExtendedFrameFormat(false);
else thisFrame.setExtendedFrameFormat(true);
thisFrame.bus = 0;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
int numBytes = tokens[3].toInt();
if (numBytes > 8) numBytes = 8;
QByteArray bytes(numBytes, 0);
QList<QByteArray> dataToks = tokens[4].split(' ');
//if (numBytes > dataToks.length()) thisFrame.payload().resize(dataToks.length());
for (int d = 0; d < numBytes; d++) bytes[d] = static_cast<char>(dataToks[d].toInt(nullptr, 16));
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveTraceFile(QString filename, const QVector<CANFrame> * frames)
{
QFile *outFile = new QFile(filename);
QDateTime timestamp;
int lineCounter = 0;
int64_t tempTime;
int tempTimePiece;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
timestamp = QDateTime::currentDateTime();
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
outFile->write("; SavvyCAN CAN Logger trace file\n");
outFile->write("; Device Serial Number : 0000 \n");
outFile->write("; Start Time : ");
outFile->write(timestamp.toString("ddd, MMM dd, yyyy :: h:m:s\n").toUtf8());
outFile->write(";\n");
outFile->write("; Column description :\n");
outFile->write("; ~~~~~~~~~~~~~~~~~~~~~\n");
outFile->write(";\n");
outFile->write("; + Message Number\n");
outFile->write("; |\n");
outFile->write("; | + Time Stamp (ms)\n");
outFile->write("; | |\n");
outFile->write("; | | + Message ID (hex)\n");
outFile->write("; | | |\n");
outFile->write("; | | | + Data Length Code\n");
outFile->write("; | | | |\n");
outFile->write("; | | | | + Data Bytes (hex)\n");
outFile->write("; | | | | |\n");
outFile->write(";---+----- -----+------ ----+--- + -+ -- -- -- -- -- -- --\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if ((lineCounter % 100) == 0)
{
qApp->processEvents();
//lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
//1F D3 3F FF 08 FF E0 CB
outFile->write(QString::number(lineCounter).rightJustified(10, ' ').toUtf8());
outFile->write("\t");
tempTime = frame->timeStamp().microSeconds();
tempTimePiece = static_cast<int>(tempTime / 1000000l / 60 / 60);
tempTime -= tempTimePiece * 1000000l * 60 * 60;
outFile->write(QString::number(tempTimePiece).rightJustified(2, '0').toUtf8());
outFile->write(":");
tempTimePiece = static_cast<int>(tempTime / 1000000l / 60);
tempTime -= tempTimePiece * 1000000l * 60;
outFile->write(QString::number(tempTimePiece).rightJustified(2, '0').toUtf8());
outFile->write(":");
tempTimePiece = static_cast<int>(tempTime / 1000000l);
tempTime -= tempTimePiece * 1000000l;
outFile->write(QString::number(tempTimePiece).rightJustified(2, '0').toUtf8());
outFile->write(":");
tempTimePiece = static_cast<int>(tempTime / 100);
outFile->write(QString::number(tempTimePiece).rightJustified(4, '0').toUtf8());
outFile->write("\t");
outFile->write(QString::number(frame->frameId(), 16).toUpper().rightJustified(8, '0').toUtf8() + "\t");
outFile->write(QString::number(dataLen).toUtf8() + "\t");
for (int temp = 0; temp < dataLen; temp++)
{
outFile->write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
outFile->putChar(' ');
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::saveCanDumpFile(QString filename, const QVector<CANFrame> * frames)
{
QFile *outFile = new QFile(filename);
QDateTime timestamp;
int lineCounter = 0;
double tempTime;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
timestamp = QDateTime::currentDateTime();
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if ((lineCounter % 100) == 0)
{
qApp->processEvents();
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
outFile->write("(");
tempTime = frame->timeStamp().microSeconds() / 1000000.0;
outFile->write(QString::number(tempTime,'f', 6).rightJustified(17, '0').toUtf8());
outFile->write(") vcan0 ");
if (frame->hasExtendedFrameFormat()) {
outFile->write(QString::number(frame->frameId(), 16).rightJustified(8,'0').toUpper().toUtf8());
} else {
outFile->write(QString::number(frame->frameId(), 16).rightJustified(3,'0').toUpper().toUtf8());
}
outFile->write("#");
if (frame->frameType() == QCanBusFrame::RemoteRequestFrame) {
outFile->write("R");
outFile->write(QString::number(dataLen).toUtf8());
} else {
for (int temp = 0; temp < dataLen; temp++)
{
outFile->write(QString::number(data[temp], 16).rightJustified(2,'0').toUpper().toUtf8());
}
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isCanDumpFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
QList<QByteArray> tokens;
QRegularExpression timeExp(QRegularExpression::anchoredPattern("^\\((\\S+)\\)$")); //anchored pattern causes exact match
QRegularExpression IdValExp(QRegularExpression::anchoredPattern("^(\\S+)#(\\S+)$"));
QRegularExpression valExp("(\\S{2})");
int lineCounter = 0;
int pos = 0;
bool isMatch = true;
bool ret;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
while (!inFile->atEnd() && lineCounter < 100) {
lineCounter++;
line = inFile->readLine().toUpper();
if (line.length() > 1)
{
/* tokenize */
tokens.clear();
tokens = line.simplified().split(' ');
if(tokens.count() < 3) isMatch = false;
/* timestamp */
QRegularExpressionMatch timeExpMatched = timeExp.match(tokens[0]);
if(!timeExpMatched.hasMatch()) {
isMatch = false;
}
/*uint64_t timestamp = (uint64_t)*/(timeExpMatched.captured(1).toDouble(&ret) /** (double)1000000.0*/);
if(!ret) isMatch = false;
if (line.contains('[')) //the expanded format
{
//(1551774790.942758) can1 7A8 [8] F4 DC D1 83 0E 02 00 00
// 0 1 2 3 4 5 6 7 8 9 10 11
if (tokens.count() < 4)
{
isMatch = false;
continue;
}
int ID = tokens[2].toULong(nullptr, 16);
if (ID > 0x1FFFFFFF || ID == 0) isMatch = false;
if (tokens[3].size() < 2) {
isMatch = false;
continue;
}
int len = tokens[3].at(1) - '0';
if (len < 0 || len > 8) isMatch = false;
}
else //the more concise format
{
/* ID & value */
//qDebug() << tokens[2];
if (tokens.count() < 3)
{
isMatch = false;
continue;
}
QRegularExpressionMatch IdValExpMatched = IdValExp.match(tokens[2]);
if(!IdValExpMatched.hasMatch())
{
isMatch = false;
continue;
}
/* ID */
/*int ID = */IdValExpMatched.captured(1).toInt(&ret, 16);
QString val= IdValExpMatched.captured(2);
pos = 0;
int len = 0;
if (val.startsWith("R") && val.at(1).isDigit()) {
len = val.at(1).toLatin1() - '0';
if (len < 0 || len > 8)
{
isMatch = false;
continue;
}
} else {
/* val byte per byte */
int lng = 0;
QRegularExpressionMatch valExpMatch;
QRegularExpressionMatchIterator i = valExp.globalMatch(val);
while (i.hasNext()) {
valExpMatch = i.next();
lng++;
if (lng > 8)
{
isMatch = false;
break;
}
/*int data = */valExpMatch.captured(1).toInt(&ret, 16);
if(!ret)
{
isMatch = false;
break;
}
}
}
}
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
/*
(0.003800) vcan0 164#0000c01aa8000013
or
(1551774790.942758) can1 7A8 [8] F4 DC D1 83 0E 02 00 00
*/
bool FrameFileIO::loadCanDumpFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
QList<QByteArray> tokens;
QRegularExpression timeExp(QRegularExpression::anchoredPattern("^\\((\\S+)\\)$")); //anchored pattern causes exact match
QRegularExpression IdValExp(QRegularExpression::anchoredPattern("^(\\S+)#(\\S+)$"));
QRegularExpression valExp("(\\S{2})");
int lineCounter = 0;
bool ret;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().toUpper();
if (line.length() > 1)
{
/* tokenize */
tokens.clear();
tokens = line.simplified().split(' ');
if(tokens.count()<3) continue;
/* timestamp */
QRegularExpressionMatch timeExpMatched = timeExp.match(tokens[0]);
if(!timeExpMatched.hasMatch()) continue;
//Sort out the bus
std::string busString = tokens[1].toStdString();
const char* busStringPtr = busString.c_str();
int busNum = 0;
//Search for where we have a bus number (skipping the can or vcan text)
for (unsigned int i = 0; i < busString.length(); i++)
{
if (busStringPtr[i] >= '0' && busStringPtr[i] <= '9')
{
//Found where the number starts
busNum = atoi(busStringPtr + i);
break;
}
}
thisFrame.bus = busNum;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, (uint64_t)(timeExpMatched.captured(1).toDouble(&ret) * (double)1000000.0)));
if(!ret) continue;
if (line.contains('[')) //the expanded format (second one from the above list)
{
//(1551774790.942758) can1 7A8 [8] F4 DC D1 83 0E 02 00 00
// 0 1 2 3 4 5 6 7 8 9 10 11
thisFrame.setFrameId(tokens[2].toLong(nullptr, 16));
if (thisFrame.frameId() > 0x7FF) thisFrame.setExtendedFrameFormat(true);
else thisFrame.setExtendedFrameFormat(false);
thisFrame.setFrameType(QCanBusFrame::DataFrame);
int numBytes = tokens[3].at(1) - '0';
QByteArray bytes(numBytes, 0);
for (int c = 0; c < numBytes; c++)
{
if ((4 + c) < tokens.size()) bytes[c] = static_cast<char>(tokens[4 + c].toInt(nullptr, 16));
}
thisFrame.setPayload(bytes);
}
else //the more concise format (first one from list above)
{
/* ID & value */
//qDebug() << tokens[2];
QRegularExpressionMatch IdValExpMatched = IdValExp.match(tokens[2]);
if(!IdValExpMatched.hasMatch())
{
qDebug() << "ID regex didn't match!";
continue;
}
/* ID */
thisFrame.setFrameId(static_cast<uint32_t>(IdValExpMatched.captured(1).toInt(&ret, 16)));
if (IdValExpMatched.captured(1).length() > 3)
{
thisFrame.setExtendedFrameFormat(true);
}
else
{
thisFrame.setExtendedFrameFormat(false);
}
QString val = IdValExpMatched.captured(2);
QByteArray bytes;
if (val.startsWith("R") && val.at(1).isDigit()) {
thisFrame.payload().resize( val.at(1).toLatin1() - '0' );
thisFrame.setFrameType(QCanBusFrame::RemoteRequestFrame);
} else {
thisFrame.setFrameType(QCanBusFrame::DataFrame);
/* val byte per byte */
QRegularExpressionMatch valExpMatch;
QRegularExpressionMatchIterator i = valExp.globalMatch(val);
while (i.hasNext())
{
valExpMatch = i.next();
bytes.append((char)valExpMatch.captured(1).toInt(&ret, 16));
if(!ret) continue;
}
}
thisFrame.setPayload(bytes);
}
/*NB: should we make sure len <= 8? */
thisFrame.isReceived = true;
}
frames->append(thisFrame);
}
inFile->close();
delete inFile;
return true;
}
bool FrameFileIO::isLawicelFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int lineCounter = 0;
bool isMatch = false;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
while (!inFile->atEnd() && lineCounter < 100) {
lineCounter++;
line = inFile->readLine().toUpper();
if (line.length() > 4 && !line.startsWith("S"))
{
int ID = line.mid(0, 3).toInt(nullptr, 16);
if (ID > 0 && ID < 0x800)
{
line.remove(0, 3);
int len = line.length() / 2;
if (len > -1 && len < 9) isMatch = true;
}
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
/*Example line:
1D5210000000000E0D7
The first three digits are the ID, all bytes are then two hex digits after that. So, the length is determined by line length
Skip all lines that start with an S
*/
bool FrameFileIO::loadLawicelFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int lineCounter = 0;
bool foundErrors = false;
quint64 timeStamp = 0;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().simplified();
if (line.length() > 4 && !line.startsWith("S"))
{
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, timeStamp += 100));
thisFrame.setFrameId( line.mid(0, 3).toInt(nullptr, 16) );
thisFrame.setExtendedFrameFormat(false);
thisFrame.isReceived = true;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
thisFrame.bus = 0;
line.remove(0, 3);
int numBytes = line.length() / 2;
QByteArray bytes(numBytes, 0);
for (int d = 0; d < numBytes; d++)
{
bytes[d] = static_cast<char>(line.mid(d * 2, 2).toInt(nullptr, 16));
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::isKvaserFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int lineCounter = 0;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine().simplified().toUpper();
if (!line.contains("CHN")) isMatch = false;
if (!line.contains("FLG")) isMatch = false;
if (!line.contains("D0")) isMatch = false;
if (inFile->atEnd()) isMatch = false;
while (!inFile->atEnd() && lineCounter < 10) {
lineCounter++;
line = inFile->readLine().toUpper();
if (line.length() > 70) {
//Chn Identifier Flg DLC D0...1...2...3...4...5...6..D7 Time Dir
// 0 000000AD 8 FF FF 00 00 00 00 00 00 154.266550 R
int len = line.mid(21, 3).simplified().toInt();
if (len > 8 || len < 0) isMatch = false;
}
else isMatch = false;
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//Chn Identifier Flg DLC D0...1...2...3...4...5...6..D7 Time Dir
// 0 000000AD 8 FF FF 00 00 00 00 00 00 154.266550 R
bool FrameFileIO::loadKvaserFile(QString filename, QVector<CANFrame> *frames, bool useHex)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
int lineCounter = 0;
int base = 10;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (useHex) base = 16;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
//ignore header
line = inFile->readLine().simplified().toUpper();
if (inFile->atEnd()) foundErrors = true;
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().toUpper();
qDebug() << line.length();
if (line.length() > 70) {
//Chn Identifier Flg DLC D0...1...2...3...4...5...6..D7 Time Dir
// 0 000000AD 8 FF FF 00 00 00 00 00 00 154.266550 R
thisFrame.bus = line.mid(0,3).simplified().toInt();
thisFrame.setFrameId(line.mid(4,10).simplified().toInt(nullptr, base));
if (thisFrame.frameId() > 0x7FF) thisFrame.setExtendedFrameFormat(true);
else thisFrame.setExtendedFrameFormat(false);
thisFrame.setFrameType(QCanBusFrame::DataFrame);
int numBytes = line.mid(21, 3).simplified().toInt();
QByteArray bytes(numBytes, 0);
for (int i = 0; i < numBytes; i++) {
bytes[i] = line.mid(25 + i * 4, 3).simplified().toInt(nullptr, base);
}
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, line.mid(57, 14).simplified().toDouble() * 1000000));
if (line.mid(72, 1).toUpper() == "R") thisFrame.isReceived = true;
else thisFrame.isReceived = false;
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
//else foundErrors = true;
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::isCabanaFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray line;
int lineCounter = 0;
bool isMatch = true;
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
try
{
line = inFile->readLine().toUpper(); //read out the header first and discard it.
if (!line.contains("TIME")) isMatch = false;
if (!line.contains("ADDR")) isMatch = false;
while (!inFile->atEnd() || lineCounter < 100) {
lineCounter++;
line = inFile->readLine().simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(',');
if (tokens.length() >= 3 && tokens.length() < 5)
{
int ID = tokens[1].toInt();
if (ID < 1 || ID > 0x1FFFFFFF) isMatch = false;
}
else isMatch = false;
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
//Cabana uses a CSV file with four columns
//time,addr,bus,data
//time is in seconds, with quite a bit of resolution after the decimal point. Does not start at 0, probably time-since-boot?
//addr is the arbitrarion ID in decimal, not hex
//bus is which CAN bus this was captured on
//data is the data in hex
//There also may or may not be some blank lines in between the csv column headers and the beginning of data.
bool FrameFileIO::loadCabanaFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray line;
bool timeStampBaseSet = false;
uint64_t timeStampBase = 0;
uint64_t lastTimeStamp = 0;
int lineCounter = 0;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
delete inFile;
return false;
}
line = inFile->readLine().toUpper(); //read out the header first and discard it.
while (!inFile->atEnd()) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
line = inFile->readLine().simplified();
if (line.length() > 2)
{
QList<QByteArray> tokens = line.split(',');
if (tokens.length() >= 3)
{
if (tokens[0].length() > 1)
{
double temp = tokens[0].toDouble();
temp = temp * 1000000;
if(!timeStampBaseSet)
{
timeStampBase = (uint64_t)(temp);
timeStampBaseSet = true;
}
if(timeStampBaseSet) {
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, ((uint64_t)(temp) - timeStampBase)));
lastTimeStamp = thisFrame.timeStamp().microSeconds();
} else {
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, (lastTimeStamp + 1)));
lastTimeStamp = thisFrame.timeStamp().microSeconds();
}
}
else
{
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, (lastTimeStamp + 1)));
lastTimeStamp = thisFrame.timeStamp().microSeconds();
}
thisFrame.setFrameId(tokens[1].toInt());
if (thisFrame.frameId() > 0x7ff) thisFrame.setExtendedFrameFormat(true);
else thisFrame.setExtendedFrameFormat(false);
thisFrame.setFrameType(QCanBusFrame::DataFrame);
thisFrame.isReceived = true;
thisFrame.bus = tokens[2].toInt();
QByteArray bytes(8,0);
{
unsigned long long int tempData = tokens[3].toULongLong(nullptr, 16);
bytes[0] = ((tempData >> 56) & 0xFF);
bytes[1] = ((tempData >> 48) & 0xFF);
bytes[2] = ((tempData >> 40) & 0xFF);
bytes[3] = ((tempData >> 32) & 0xFF);
bytes[4] = ((tempData >> 24) & 0xFF);
bytes[5] = ((tempData >> 16) & 0xFF);
bytes[6] = ((tempData >> 8) & 0xFF);
bytes[7] = (tempData & 0xFF);
}
// Shift the bytes back correctly so we have a frame that is the proper length
unsigned int framelength = tokens[3].length() / 2;
QByteArray finalbytes(framelength,0);
uint8_t bytes_shifted_by = 8 - framelength;
for (unsigned int j = 0; j < framelength; j++)
{
finalbytes[j] = bytes[j + bytes_shifted_by];
}
thisFrame.setPayload(finalbytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::saveCabanaFile(QString filename, const QVector<CANFrame>* frames)
{
QFile *outFile = new QFile(filename);
int lineCounter = 0;
const unsigned char *data;
int dataLen;
const CANFrame *frame;
if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
{
delete outFile;
return false;
}
outFile->write("time,addr,bus,data");
outFile->write("\n");
for (int c = 0; c < frames->count(); c++)
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();
double tempTimeStamp = frame->timeStamp().microSeconds();
tempTimeStamp /= 1000000;
outFile->write(QString::number(tempTimeStamp, 'f').toUtf8());
outFile->write(".0");
outFile->putChar(44);
outFile->write(QString::number(frame->frameId(), 10).toUpper().toUtf8());
outFile->putChar(44);
outFile->write(QString::number(frame->bus).toUtf8());
outFile->putChar(44);
for (int temp = 0; temp < 8; temp++)
{
if (temp < dataLen)
outFile->write(QString::number(data[temp], 16).toUpper().rightJustified(2, '0').toUtf8());
else
outFile->write("00");
}
outFile->write("\n");
}
outFile->close();
delete outFile;
return true;
}
bool FrameFileIO::isTeslaAPFile(QString filename)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
QByteArray data;
bool isValidFile = true;
TeslaAPCANRecord record;
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
while (!inFile->atEnd())
{
inFile->read((char *)&record, sizeof(TeslaAPCANRecord));
if (record.id > 0x7FF) isValidFile = false;
if ((record.ctr >> 4) > 8) isValidFile = false;
if ((record.ctr & 0xF) > 6) isValidFile = false;
}
inFile->close();
delete inFile;
return isValidFile;
}
bool FrameFileIO::loadTeslaAPFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
CANFrame thisFrame;
int lineCounter = 0;
QByteArray data;
//int timeOffset = 0;
//int64_t lastTimeStamp = 0;
bool foundErrors = false;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
TeslaAPCANRecord record;
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
while (!inFile->atEnd())
{
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
inFile->read((char *)&record, sizeof(TeslaAPCANRecord));
thisFrame.isReceived = true;
thisFrame.setExtendedFrameFormat(false); //format is incapable of extended frames
thisFrame.setFrameType(QCanBusFrame::DataFrame);
qint64 tempStamp;
tempStamp = record.sec * 1000000 + (record.nano/1000);
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, tempStamp));
thisFrame.setFrameId(record.id);
int numBytes = (record.ctr >> 4);
thisFrame.bus = (record.ctr & 0xF);
QByteArray bytes(numBytes, 0);
if (numBytes <= 8)
{
for (int d = 0; d < numBytes; d++) bytes[d] = record.data[d];
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
else foundErrors = true;
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::isCLX000File(QString filename) {
std::unique_ptr<QFile> inFile = std::unique_ptr<QFile>(new QFile(filename));
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
qDebug() << "Could not open the file!";
return false;
}
QTextStream fileStream(inFile.get());
//bool foundErrors = false;
// Contains 16 lines of header prior to (potential) data.
QString headerLine;
headerLine = fileStream.readLine();
if(!headerLine.startsWith("# Logger type: ")) {
qDebug() << "Not the correct first header line:" << headerLine;
return false;
}
// Skip to next usable field.
fileStream.readLine();
fileStream.readLine();
fileStream.readLine();
fileStream.readLine();
fileStream.readLine();
// Extract base time.
headerLine = fileStream.readLine();
if(!headerLine.startsWith("# Time: ")) {
qDebug() << "Not the correct start time:" << headerLine;
return false;
}
headerLine = headerLine.right(15);
QDateTime startDate = QDateTime::fromString(headerLine, "yyyyMMddThhmmss");
if(!startDate.isValid()) {
qDebug() << "Could not parse " << headerLine << "using \"yyyyMMddThhmmss\" as format string";
return false;
}
QString const validSeparators(" -~");
// Decode separators and format for later decoding.
headerLine = fileStream.readLine();
QString const valueSeparatorPattern = "# Value separator: \"(?<valueSeparator>[" + validSeparators + "])\"";
QRegularExpression valueSeparatorRegEx(valueSeparatorPattern);
auto matchValueSeparator = valueSeparatorRegEx.match(headerLine);
if(!matchValueSeparator.hasMatch()) {
qDebug() << "Could not decode value separator" << headerLine << "using pattern" << valueSeparatorPattern;
return false;
}
QChar valueSeparator = matchValueSeparator.captured("valueSeparator").front();
headerLine = fileStream.readLine();
QString const timeFormatPattern = "# Time format: (?<timeFormat>\\d)";
QRegularExpression timeFormatRegEx(timeFormatPattern);
auto matchTimeFormat = timeFormatRegEx.match(headerLine);
if(!matchTimeFormat.hasMatch()) {
qDebug() << "Could not decode time format" << headerLine << "using pattern" << timeFormatPattern;
return false;
}
//auto timeFormat = matchTimeFormat.captured("timeFormat").front().digitValue();
headerLine = fileStream.readLine();
QString const timeSeparatorPattern = "# Time separator: \"(?<timeSeparator>[" + validSeparators + "]?)\"";
QRegularExpression timeSeparatorRegEx(timeSeparatorPattern);
auto matchTimeSeparator = timeSeparatorRegEx.match(headerLine);
if( !matchTimeSeparator.hasMatch()) {
qDebug() << "Could not decode time format" << headerLine << "using pattern" << timeSeparatorPattern;
return false;
}
//QChar timeSeparator = matchTimeSeparator.captured("timeSeparator").front();
headerLine = fileStream.readLine();
QString const timeSeparatorMsPattern = "# Time separator ms: \"(?<timeSeparatorMs>[" + validSeparators + "]?)\"";
QRegularExpression timeSeparatorMsRegEx(timeSeparatorMsPattern);
auto matchTimeSeparatorMs = timeSeparatorMsRegEx.match(headerLine);
if( !matchTimeSeparatorMs.hasMatch()) {
qDebug() << "Could not decode time format ms" << headerLine << "using pattern" << timeSeparatorMsPattern;
return false;
}
//QChar timeSeparatorMs = matchTimeSeparatorMs.captured("timeSeparatorMs").front();
headerLine = fileStream.readLine();
QString const dateSeparatorPattern = "# Date separator: \"(?<dateSeparator>[" + validSeparators + "]?)\"";
QRegularExpression dateSeparatorRegEx(dateSeparatorPattern);
auto matchDateSeparator = dateSeparatorRegEx.match(headerLine);
if( !matchDateSeparator.hasMatch()) {
qDebug() << "Could not decode time format ms" << headerLine << "using pattern" << dateSeparatorPattern;
return false;
}
//QChar dateSeparator = matchDateSeparator.captured("dateSeparator").front();
headerLine = fileStream.readLine();
QString const timeDateSeparatorPattern = "# Time and date separator: \"(?<timeDateSeparator>[" + validSeparators + "]?)\"";
QRegularExpression timeDateSeparatorRegEx(timeDateSeparatorPattern);
auto matchTimeDateSeparator = timeDateSeparatorRegEx.match(headerLine);
if( !matchTimeDateSeparator.hasMatch()) {
qDebug() << "Could not decode time format ms" << headerLine << "using pattern" << timeDateSeparatorPattern;
return false;
}
//QChar timeDateSeparator = matchTimeDateSeparator.captured("timeDateSeparator").front();
// Skip remaining header lines.
fileStream.readLine();
fileStream.readLine();
fileStream.readLine();
// Decode which fields are present.
headerLine = fileStream.readLine();
auto const presentFields = headerLine.split(valueSeparator);
QStringList const validStrings = {"Timestamp", "Type", "ID", "Length", "Data"};
if(!std::all_of(
presentFields.cbegin(),
presentFields.cend(),
[&validStrings](QString const& entry){return validStrings.contains(entry);})
) {
return false;
}
return true;
}
bool FrameFileIO::loadCLX000File(QString filename, QVector<CANFrame>* frames) {
std::unique_ptr<QFile> inFile = std::unique_ptr<QFile>(new QFile(filename));
if (!inFile->open(QIODevice::ReadOnly | QIODevice::Text))
{
qDebug() << "Could not open the file!";
return false;
}
QTextStream fileStream(inFile.get());
bool foundErrors = false;
// Contains 16 lines of header prior to (potential) data.
QString headerLine;
headerLine = fileStream.readLine();
if(!headerLine.startsWith("# Logger type: ")) {
qDebug() << "Not the correct first header line:" << headerLine;
return false;
}
// Skip to next usable field.
fileStream.readLine();
fileStream.readLine();
fileStream.readLine();
fileStream.readLine();
fileStream.readLine();
// Extract base time.
headerLine = fileStream.readLine();
if(!headerLine.startsWith("# Time: ")) {
qDebug() << "Not the correct start time:" << headerLine;
return false;
}
headerLine = headerLine.right(15);
QDateTime startDate = QDateTime::fromString(headerLine, "yyyyMMddThhmmss");
if(!startDate.isValid()) {
qDebug() << "Could not parse " << headerLine << "using \"yyyyMMddThhmmss\" as format string";
return false;
}
QString const validSeparators(" -~;");
// Decode separators and format for later decoding.
headerLine = fileStream.readLine();
QString const valueSeparatorPattern = "# Value separator: \"(?<valueSeparator>[" + validSeparators + "])\"";
QRegularExpression valueSeparatorRegEx(valueSeparatorPattern);
auto matchValueSeparator = valueSeparatorRegEx.match(headerLine);
if(!matchValueSeparator.hasMatch()) {
qDebug() << "Could not decode value separator" << headerLine << "using pattern" << valueSeparatorPattern;
return false;
}
QChar valueSeparator = matchValueSeparator.captured("valueSeparator").front();
headerLine = fileStream.readLine();
QString const timeFormatPattern = "# Time format: (?<timeFormat>\\d)";
QRegularExpression timeFormatRegEx(timeFormatPattern);
auto matchTimeFormat = timeFormatRegEx.match(headerLine);
if(!matchTimeFormat.hasMatch()) {
qDebug() << "Could not decode time format" << headerLine << "using pattern" << timeFormatPattern;
return false;
}
auto timeFormat = matchTimeFormat.captured("timeFormat").front().digitValue();
headerLine = fileStream.readLine();
QString const timeSeparatorPattern = "# Time separator: \"(?<timeSeparator>[" + validSeparators + "]?)\"";
QRegularExpression timeSeparatorRegEx(timeSeparatorPattern);
auto matchTimeSeparator = timeSeparatorRegEx.match(headerLine);
if( !matchTimeSeparator.hasMatch()) {
qDebug() << "Could not decode time format" << headerLine << "using pattern" << timeSeparatorPattern;
return false;
}
QChar timeSeparator = matchTimeSeparator.captured("timeSeparator").front();
headerLine = fileStream.readLine();
QString const timeSeparatorMsPattern = "# Time separator ms: \"(?<timeSeparatorMs>[" + validSeparators + "]?)\"";
QRegularExpression timeSeparatorMsRegEx(timeSeparatorMsPattern);
auto matchTimeSeparatorMs = timeSeparatorMsRegEx.match(headerLine);
if( !matchTimeSeparatorMs.hasMatch()) {
qDebug() << "Could not decode time format ms" << headerLine << "using pattern" << timeSeparatorMsPattern;
return false;
}
QChar timeSeparatorMs = matchTimeSeparatorMs.captured("timeSeparatorMs").front();
headerLine = fileStream.readLine();
QString const dateSeparatorPattern = "# Date separator: \"(?<dateSeparator>[" + validSeparators + "]?)\"";
QRegularExpression dateSeparatorRegEx(dateSeparatorPattern);
auto matchDateSeparator = dateSeparatorRegEx.match(headerLine);
if( !matchDateSeparator.hasMatch()) {
qDebug() << "Could not decode time format ms" << headerLine << "using pattern" << dateSeparatorPattern;
return false;
}
QChar dateSeparator = matchDateSeparator.captured("dateSeparator").front();
headerLine = fileStream.readLine();
QString const timeDateSeparatorPattern = "# Time and date separator: \"(?<timeDateSeparator>[" + validSeparators + "]?)\"";
QRegularExpression timeDateSeparatorRegEx(timeDateSeparatorPattern);
auto matchTimeDateSeparator = timeDateSeparatorRegEx.match(headerLine);
if( !matchTimeDateSeparator.hasMatch()) {
qDebug() << "Could not decode time format ms" << headerLine << "using pattern" << timeDateSeparatorPattern;
return false;
}
QChar timeDateSeparator = matchTimeDateSeparator.captured("timeDateSeparator").front();
// Skip remaining header lines.
fileStream.readLine();
fileStream.readLine();
fileStream.readLine();
// Decode which fields are present.
headerLine = fileStream.readLine();
auto const presentFields = headerLine.split(valueSeparator);
QStringList const validStrings = {"Timestamp", "Type", "ID", "Length", "Data"};
if(!std::all_of(
presentFields.cbegin(),
presentFields.cend(),
[&validStrings](QString const& entry){return validStrings.contains(entry);})
) {
return false;
}
#ifdef QT_DEBUG
qDebug() << "Found CLX000 file";
qDebug() << "Base time:" << startDate;
qDebug() << "Time format:" << timeFormat;
qDebug() << "Value separator:" << valueSeparator;
qDebug() << "Time separator:" << timeSeparator;
qDebug() << "Time separator ms:" << timeSeparatorMs;
qDebug() << "Date separator:" << dateSeparator;
qDebug() << "Time and date separator:" << timeDateSeparator;
qDebug() << "Found" << presentFields;
#endif
// Prepare regex.
QString pattern = "";
if(presentFields.contains("Timestamp")) {
switch (timeFormat) {
case 6: {
// Handle year.
pattern += "(?<year>\\d\\d\\d\\d)";
if (dateSeparator != '\0') {
pattern += dateSeparator;
}
// Fallthrough
[[fallthrough]];
}
case 5: {
// Handle month.
pattern += "(?<month>\\d\\d)";
if (dateSeparator != '\0') {
pattern += dateSeparator;
}
// Fallthrough
[[fallthrough]];
}
case 4: {
// Handle day.
pattern += "(?<day>\\d\\d)";
if (timeDateSeparator != '\0') {
pattern += timeDateSeparator;
}
// Fallthrough
[[fallthrough]];
}
case 3: {
// Handle hours.
pattern += "(?<hours>\\d\\d)";
if (timeSeparator != '\0') {
pattern += timeSeparator;
}
// Fallthrough
[[fallthrough]];
}
case 2: {
// Handle minutes.
pattern += "(?<minutes>\\d\\d)";
if (timeSeparator != '\0') {
pattern += timeSeparator;
}
// Fallthrough
[[fallthrough]];
}
case 1: {
// Handle seconds.
pattern += "(?<seconds>\\d\\d)";
if (timeSeparatorMs != '\0') {
pattern += timeSeparatorMs;
}
// Fallthrough
[[fallthrough]];
}
case 0: {
// Handle milliseconds.
pattern += "(?<ms>\\d\\d\\d)";
break;
}
default:
qDebug() << "Unsupported time format" << timeFormat;
return false;
}
pattern += valueSeparator;
}
if(presentFields.contains("Type")) {
pattern += "(?<type>\\d)";
pattern += valueSeparator;
}
if(presentFields.contains("ID")) {
pattern += "(?<id>[a-fA-F\\d]{1,8})";
pattern += valueSeparator;
}
if(presentFields.contains("Length")) {
pattern += "(?<length>\\d)";
pattern += valueSeparator;
}
if(presentFields.contains("Data")) {
pattern += "(?<data>([a-fA-F\\d]{2}){0,64})";
}
QRegularExpression re(pattern);
re.optimize();
// Parse records.
QString recordLine;
CANFrame currentFrame;
unsigned lineCounter = 0;
while(fileStream.readLineInto(&recordLine)) {
auto res = re.match(recordLine);
if(res.hasMatch()) {
QDateTime currentTime = startDate;
currentFrame.setFrameType(QCanBusFrame::DataFrame);
currentFrame.bus = 0;
//currentTime is already initialized with startDate so it already has year,month,etc filled out.
//For each timestamp on the line we need to figure out how it differs from the already set time
//and move the timestamp accordingly.
if (res.captured("year").length() > 0)
{
//for all of these, only add the difference not the whole value!
currentTime = currentTime.addYears(res.captured("year").toUInt() - startDate.date().year());
}
if (res.captured("month").length() > 0)
{
currentTime = currentTime.addMonths(res.captured("month").toUInt() - startDate.date().month());
}
if (res.captured("day").length() > 0)
{
currentTime = currentTime.addMonths(res.captured("day").toUInt() - startDate.date().day());
}
unsigned int seconds = res.captured("hours").toUInt() * 60 * 60 + res.captured("minutes").toUInt() * 60 +
res.captured("seconds").toUInt() - (startDate.time().msecsSinceStartOfDay() / 1000);
currentTime = currentTime.addSecs(seconds);
currentTime = currentTime.addMSecs(res.captured("ms").toUInt() - (startDate.time().msecsSinceStartOfDay() % 1000));
//time is stored in microseconds so we need to get the timestamp as milliseconds since the epoch
//then multiplyby 1000 to get microseconds since the epoch.
currentFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, currentTime.toMSecsSinceEpoch() * 1000));
if(res.captured("type").length() != 0) {
auto frameType = res.captured("type").toUInt();
currentFrame.isReceived = !(frameType & 0x08);
currentFrame.setExtendedFrameFormat(frameType & 0x01);
}
if(res.captured("id").length() != 0) {
auto frameID = res.captured("id").toULong(nullptr, 16);
currentFrame.setFrameId(frameID);
if(res.captured("type").length() == 0) {
currentFrame.setExtendedFrameFormat(frameID > 0x7FFu);
}
}
if(res.captured("data").length() != 0) {
// Ensure field is valid.
if(res.captured("data").length() % 2 != 0) {
qDebug() << "Could not decode data field, un-even number of bytes";
continue;
}
currentFrame.setPayload(QByteArray::fromHex(res.captured("data").toLatin1()));
} else {
currentFrame.setPayload(QByteArray());
}
frames->append(currentFrame);
} else {
qDebug() << "Could not parse:" << recordLine;
}
if(++lineCounter >= 100) {
qApp->processEvents();
lineCounter = 0;
}
}
return !foundErrors;
}
bool FrameFileIO::isCANServerFile(QString filename)
{
QFile *inFile = new QFile(filename);
QByteArray headerData;
bool isMatch = false;
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
try
{
//Read the first 20 bytes from the file to check for the matching signature
headerData = inFile->read(22);
//qDebug() << "header.length: " << headerData.length();
if (headerData.length() == 22)
{
//qDebug() << "header: " << headerData;
//We have enough bytes to make up our header. Lets check if it matches
if (headerData == "CANSERVER_v2_CANSERVER")
{
isMatch = true;
}
}
}
catch (...)
{
isMatch = false;
}
inFile->close();
delete inFile;
return isMatch;
}
bool FrameFileIO::loadCANServerFile(QString filename, QVector<CANFrame>* frames)
{
QFile *inFile = new QFile(filename);
union framedata_U
{
char data[8];
std::uint64_t u64;
};
framedata_U framedata;
uint64_t timeStampBase = 0;
int frameCounter = 0;
bool foundErrors = false;
if (!inFile->open(QIODevice::ReadOnly))
{
delete inFile;
return false;
}
//Skip the header
bool fileIsGood = false;
QByteArray headerData = inFile->read(22);
if (headerData.length() == 22)
{
//qDebug() << "header: " << headerData;
//We have enough bytes to make up our header. Lets check if it matches
if (headerData == "CANSERVER_v2_CANSERVER")
{
fileIsGood = true;
}
}
if (fileIsGood)
{
//uint64_t lastFrameTime = 0;
uint8_t data[1];
while (!inFile->atEnd())
{
inFile->read((char*)&data, 1);
if (data[0] == 'C')
{
//We might have a new header here (if files were just concatenated together)
//Check to see if we have our full signature
qint64 originalPos = inFile->pos();
QByteArray possibleHeaderData = inFile->read(21);
if (possibleHeaderData.length() == 21)
{
if (possibleHeaderData == "ANSERVER_v2_CANSERVER" )
{
//We found another header. Lets just ignore things and move on
}
else
{
//Hmm. header wasn't right. Just move the file pointer back and keep processing
inFile->seek(originalPos);
}
}
}
else if (data[0] == 0xCD)
{
//Log mark message
//Read in the size of the mark
uint8_t markSize[1];
inFile->read((char*)&markSize, 1);
//Read in the mark message
QByteArray markData = inFile->read(markSize[0]);
/*
Log Marks aren't yet supported by SavvyCAN
//Add this log mark to the list of frames so that it shows up
CANFrame markFrame;
markFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, lastFrameTime));
markFrame.isMark = true;
markFrame.markMessage = QString(markData);
frames->append(markFrame);
*/
}
else if (data[0] == 0xCE)
{
//Timesync message
framedata_U timesyncvalue;
::memset(timesyncvalue.data, 0, sizeof(timesyncvalue.data));
inFile->read(timesyncvalue.data, 8);
//This data is a uint64_t that tells us the current file time in us
//qDebug() << "Found a time sync message: " << timesyncvalue.u64;
timeStampBase = timesyncvalue.u64;
}
else if (data[0] == 0xCF)
{
if (frameCounter++ > 100)
{
qApp->processEvents();
frameCounter = 0;
}
//CAN Frame
uint8_t frameheaderdata[5];
inFile->read((char*)frameheaderdata, 5);
//The frame time offset is how long since the last time sync message (now in ms) this frame is
uint8_t byte1 = frameheaderdata[0];
uint8_t byte2 = frameheaderdata[1];
uint16_t frametimeoffset = ((uint16_t)byte2 << 8) | byte1;
byte1 = frameheaderdata[2];
byte2 = frameheaderdata[3];
uint16_t messageId = ((uint16_t)byte2 << 8) | byte1;
uint8_t framelength = frameheaderdata[4] & 0x0F;
uint8_t busid = frameheaderdata[4] >> 4;
framelength = framelength > 8 ? 8 : framelength;
//Now that we have a length lets read those bytes
::memset(framedata.data, 0, sizeof(framedata.data));
inFile->read(framedata.data, framelength);
//Setup the frame object and populate it
CANFrame thisFrame;
thisFrame.setFrameType(QCanBusFrame::DataFrame);
thisFrame.setFrameId(messageId);
thisFrame.isReceived = true;
thisFrame.bus = busid;
uint64_t frameTime = timeStampBase;
uint64_t frameoffset = frametimeoffset;
frameoffset *= 1000;
frameTime += frameoffset;
//lastFrameTime = frameTime;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, frameTime));
QByteArray bytes(framelength,0);
for (int i = 0; i < framelength; i++)
{
bytes[i] = ((framedata.u64 >> (i*8)) & 0xFF);
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
}
}
}
else
{
foundErrors = true;
}
inFile->close();
delete inFile;
return !foundErrors;
}
bool FrameFileIO::loadWiresharkFile(QString filename, QVector<CANFrame>* frames)
{
pcap_t *pcap_data_file;
CANFrame thisFrame;
long long startTimestamp = 0;
long long timeStamp;
int lineCounter = 0;
bool foundErrors = false;
pcap_pkthdr packetHeader;
const char *packetData = NULL;
char errbuf[PCAP_ERRBUF_SIZE];
thisFrame.setFrameType(QCanBusFrame::DataFrame);
QByteArray ba = filename.toLocal8Bit();
pcap_data_file = pcap_open_offline(ba.data(), errbuf);
if (!pcap_data_file) {
return false;
}
packetData = (const char*)pcap_next(pcap_data_file, &packetHeader);
while (packetData) {
lineCounter++;
if (lineCounter > 100)
{
qApp->processEvents();
lineCounter = 0;
}
timeStamp = packetHeader.ts.tv_sec * 1000000 + packetHeader.ts.tv_usec;
if (0 == startTimestamp)
{
startTimestamp = timeStamp;
}
timeStamp -= startTimestamp;
thisFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, timeStamp));
thisFrame.isReceived = true; // TODO: check if tx detection is possible
thisFrame.setFrameType(QCanBusFrame::DataFrame);
thisFrame.setFrameId((0xff & *(packetData+17)) << 8 | (0xff & *(packetData+16)));
if (thisFrame.frameId() <= 0x7FF) thisFrame.setExtendedFrameFormat(false);
else thisFrame.setExtendedFrameFormat(true);
thisFrame.bus = 0;
int numBytes = *(packetData+20);
QByteArray bytes(numBytes, 0);
if (thisFrame.payload().length() > 8) thisFrame.payload().resize(8);
for (int d = 0; d < numBytes; d++)
{
bytes[d] = *(packetData + 24 + d);
}
thisFrame.setPayload(bytes);
frames->append(thisFrame);
packetData = (const char*)pcap_next(pcap_data_file, &packetHeader);
}
pcap_close(pcap_data_file);
pcap_data_file = NULL;
return !foundErrors;
}
bool FrameFileIO::isWiresharkFile(QString filename)
{
pcap_t *pcap_data_file;
char errbuf[PCAP_ERRBUF_SIZE];
QByteArray ba = filename.toLocal8Bit();
pcap_data_file = pcap_open_offline(ba.data(), errbuf);
if (!pcap_data_file) {
return false;
}
pcap_close(pcap_data_file);
pcap_data_file = NULL;
return true;
}
Reference in New Issue View Git Blame Copy Permalink