Skip to content

Commit

Permalink
Merge branch 'master' into fix_customsendcrash
Browse files Browse the repository at this point in the history
  • Loading branch information
Andy Huska committed Nov 2, 2022
2 parents f30b9e5 + 02252c1 commit 662c5b9
Show file tree
Hide file tree
Showing 10 changed files with 233 additions and 24 deletions.
16 changes: 14 additions & 2 deletions connections/canbus.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -8,21 +8,24 @@ CANBus::CANBus()
listenOnly = false;
singleWire = false;
active = false;
canFD = false;
}


CANBus::CANBus(const CANBus& pBus) :
speed(pBus.speed),
listenOnly(pBus.listenOnly),
singleWire(pBus.singleWire),
active(pBus.active) {}
active(pBus.active),
canFD(pBus.canFD) {}


bool CANBus::operator==(const CANBus& bus) const{
return speed == bus.speed &&
listenOnly == bus.listenOnly &&
singleWire == bus.singleWire &&
active == bus.active;
active == bus.active &&
canFD == bus.canFD;
}

void CANBus::setSpeed(int newSpeed){
Expand All @@ -45,6 +48,11 @@ void CANBus::setActive(bool mode){
active = mode;
}

void CANBus::setCanFD(bool mode){
//qDebug() << "CANBUS setCanFD = " << mode;
canFD = mode;
}

int CANBus::getSpeed(){
return speed;
}
Expand All @@ -61,6 +69,10 @@ bool CANBus::isActive(){
return active;
}

bool CANBus::isCanFD(){
return canFD;
}


QDataStream& operator<<( QDataStream & pStream, const CANBus& pCanBus )
{
Expand Down
4 changes: 3 additions & 1 deletion connections/canbus.h
Original file line number Diff line number Diff line change
Expand Up @@ -16,16 +16,18 @@ class CANBus
bool listenOnly;
bool singleWire;
bool active; //is this bus turned on?

bool canFD;

void setSpeed(int); // new speed
void setListenOnly(bool); //bool for whether to only listen
void setSingleWire(bool); //bool for whether to use single wire mode
void setActive(bool); //whether this bus should be enabled or not.
void setCanFD(bool); // enable or disable CANFD support
int getSpeed();
bool isListenOnly();
bool isSingleWire();
bool isActive();
bool isCanFD();
};

QDataStream& operator<<( QDataStream & pStream, const CANBus& pCanBus );
Expand Down
10 changes: 9 additions & 1 deletion connections/connectionwindow.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -365,6 +365,7 @@ void ConnectionWindow::saveBusSettings()
bus.setSpeed(ui->cbBusSpeed->currentText().toInt());
bus.setActive(ui->ckEnable->isChecked());
bus.setListenOnly(ui->ckListenOnly->isChecked());
bus.setCanFD(ui->canFDEnable->isChecked());
conn_p->setBusSettings(offset, bus);
}
}
Expand All @@ -381,7 +382,8 @@ void ConnectionWindow::populateBusDetails(int offset)
{
//bool ret;
//int numBuses;

ui->canFDEnable->setVisible(false);
ui->canFDEnable_label->setVisible(false);
CANConnection* conn_p = connModel->getAtIdx(selIdx);
CANBus bus;
if(!conn_p) return;
Expand All @@ -396,6 +398,12 @@ void ConnectionWindow::populateBusDetails(int offset)
//ui->lblBusNum->setText(QString::number(busBase + offset));
ui->ckListenOnly->setChecked(bus.isListenOnly());
ui->ckEnable->setChecked(bus.isActive());
if (conn_p->getType() == CANCon::type::SERIALBUS)
{
ui->canFDEnable->setVisible(true);
ui->canFDEnable_label->setVisible(true);
ui->canFDEnable->setChecked(bus.isCanFD());
}

bool found = false;
for (int i = 0; i < ui->cbBusSpeed->count(); i++)
Expand Down
2 changes: 2 additions & 0 deletions connections/serialbusconnection.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,7 @@ void SerialBusConnection::piStarted()
mTimer.setSingleShot(false); //keep ticking
mTimer.start();
mBusData[0].mBus.setActive(true);
mBusData[0].mBus.setCanFD(false);
mBusData[0].mConfigured = true;
}

Expand Down Expand Up @@ -103,6 +104,7 @@ void SerialBusConnection::piSetBusSettings(int pBusIdx, CANBus bus)
//You cannot set the speed of a socketcan interface, it has to be set with console commands.
//But, you can probabaly set the speed of many of the other serialbus devices so go ahead and try
mDev_p->setConfigurationParameter(QCanBusDevice::BitRateKey, bus.speed);
mDev_p->setConfigurationParameter(QCanBusDevice::CanFdKey, bus.canFD);

/* connect device */
if (!mDev_p->connectDevice()) {
Expand Down
18 changes: 6 additions & 12 deletions connections/socketcand.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -288,19 +288,13 @@ QString SocketCANd::decodeFrames(QString data, int busNum)
buildFrame.setTimeStamp(QCanBusFrame::TimeStamp(0, frameParsed[2].toDouble() * 1000000l));
//buildFrame.len = frameParsed[3].length() * 0.5;

if(frameParsed.length() < 4)
{
qDebug() << "Received frame doesn't contain any data: " << data;
int framelength = 0;

//todo
//this is not totally true, ive seen frames come through that look like < frame 1F020240 1664924225.371291 >
//if we found the closing token but theres no data then remove the message from the buffer
return data;
if(frameParsed.length() == 4)
{
framelength = frameParsed[3].length() * 0.5;
}

int framelength = frameParsed[3].length() * 0.5;


QByteArray buildData;
buildData.resize(framelength);

Expand Down Expand Up @@ -328,8 +322,8 @@ QString SocketCANd::decodeFrames(QString data, int busNum)
getQueue().queue();
}
}
else
qDebug() << "can't get a frame, capture suspended";
//else
// qDebug() << "can't get a frame, capture suspended";

//take out the data that we just processed and anything that is in front of it
//this should keep broken frames from accumulating at in the data buffer
Expand Down
174 changes: 173 additions & 1 deletion mainwindow.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -119,6 +119,7 @@ MainWindow::MainWindow(QWidget *parent) :
connect(ui->actionFuzzy_Scope, &QAction::triggered, this, &MainWindow::showFuzzyScopeWindow);
connect(ui->actionRange_State_2, &QAction::triggered, this, &MainWindow::showRangeWindow);
connect(ui->actionSave_Decoded_Frames, &QAction::triggered, this, &MainWindow::handleSaveDecoded);
connect(ui->actionSave_Decoded_Frames_CSV, &QAction::triggered, this, &MainWindow::handleSaveDecodedCsv);
connect(ui->actionSingle_Multi_State_2, &QAction::triggered, this, &MainWindow::showSingleMultiWindow);
connect(ui->actionFile_Comparison, &QAction::triggered, this, &MainWindow::showComparisonWindow);
connect(ui->actionDBC_Comparison, &QAction::triggered, this, &MainWindow::showDBCComparisonWindow);
Expand Down Expand Up @@ -1009,6 +1010,16 @@ void MainWindow::handleLoadFilters()
}

void MainWindow::handleSaveDecoded()
{
handleSaveDecodedMethod(false);
}

void MainWindow::handleSaveDecodedCsv()
{
handleSaveDecodedMethod(true);
}

void MainWindow::handleSaveDecodedMethod(bool csv)
{
QString filename;
QFileDialog dialog(this);
Expand All @@ -1027,11 +1038,172 @@ void MainWindow::handleSaveDecoded()
{
filename = dialog.selectedFiles()[0];
if (!filename.contains('.')) filename += ".txt";
saveDecodedTextFile(filename);

if(csv)
saveDecodedTextFileAsColumns(filename);
else
saveDecodedTextFile(filename);

settings.setValue("FileIO/LoadSaveDirectory", dialog.directory().path());
}
}

void MainWindow::saveDecodedTextFileAsColumns(QString filename)
{
QFile *outFile = new QFile(filename);
const QVector<CANFrame> *frames = model->getFilteredListReference();

const unsigned char *data;
int dataLen;
const CANFrame *frame;

if (!outFile->open(QIODevice::WriteOnly | QIODevice::Text))
return;
/*
Time: 205.173000 ID: 0x20E Std Bus: 0 Len: 8
Data Bytes: 88 10 00 13 BB 00 06 00
SignalName Value
*/
QList<QPair<int, int>> msgsAndColumns;
int columnsAdded = 0;
int dataStartCol = 0;

QString builderString;
//time
builderString += tr("Time") + ",";
dataStartCol++;
//id
builderString += tr("ID") + ",";
dataStartCol++;
//if (frame->hasExtendedFrameFormat()) builderString += tr(" Ext ");
//else builderString += tr(" Std ");
//bus
builderString += tr("Bus") + ",";
dataStartCol++;
//len
builderString += tr("DataLen") + ",";
dataStartCol++;

columnsAdded = dataStartCol;

//loop through all the frames and the message data therein
for (int c = 0; c < frames->count(); c++)
{
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();

//add all column names
if (dbcHandler != nullptr)
{
DBC_MESSAGE *msg = dbcHandler->findMessage(*frame);
if (msg != nullptr)
{
bool found = false;
for (int j = 0; j < msg->sigHandler->getCount(); j++)
{
if(j==0)
{
for(int m=0; m<msgsAndColumns.count(); m++)
{
if(msgsAndColumns[m].first == msg->ID)
found = true;
}
if(found == false)
msgsAndColumns.append(QPair<int,int>(msg->ID, columnsAdded));
}

if(found == false)
{
QString temp;
if (msg->sigHandler->findSignalByIdx(j)->processAsText(*frame, temp))
{
builderString.append(msg->sigHandler->findSignalByIdx(j)->name);
builderString.append(",");
columnsAdded++;
}
}
}
}
}
}

//add EOL
builderString += "\n";
//write out the header row
outFile->write(builderString.toUtf8());

//builderString = tr("Data Bytes: ");
//for (int temp = 0; temp < dataLen; temp++)
//{
// builderString += Utility::formatNumber(data[temp]) + " ";
//}
//builderString += "\n";
//outFile->write(builderString.toUtf8());

int dataColumnsAdded = 0;
builderString = "";
for (int c = 0; c < frames->count(); c++)
{
dataColumnsAdded = 0;
frame = &frames->at(c);
data = reinterpret_cast<const unsigned char *>(frame->payload().constData());
dataLen = frame->payload().count();

QString builderString;
builderString += QString::number((frame->timeStamp().microSeconds() / 1000000.0), 'f', 6) + ",";
dataColumnsAdded++;
//id
builderString += Utility::formatCANID(frame->frameId(), frame->hasExtendedFrameFormat()) + ",";
dataColumnsAdded++;
//if (frame->hasExtendedFrameFormat()) builderString += tr(" Ext ");
//else builderString += tr(" Std ");
//bus
builderString += QString::number(frame->bus) + ",";
dataColumnsAdded++;
//len
builderString += QString::number(dataLen) + ",";
dataColumnsAdded++;

if (dbcHandler != nullptr)
{
DBC_MESSAGE *msg = dbcHandler->findMessage(*frame);
if (msg != nullptr)
{
for (int j = 0; j < msg->sigHandler->getCount(); j++)
{
if(j==0)
{
for(int i = 0; i<msgsAndColumns.count(); i++)
{
if(msgsAndColumns[i].first == msg->ID)
{
int startCol = msgsAndColumns[i].second;
while(dataColumnsAdded < startCol)
{
builderString += ",";
dataColumnsAdded++;
}
}
}
}

QString temp;
if (msg->sigHandler->findSignalByIdx(j)->processAsText(*frame, temp, false))
{
builderString.append(temp);
builderString.append(",");
dataColumnsAdded++;
}
}
}
builderString.append("\n");
outFile->write(builderString.toUtf8());
}
}
outFile->close();
}

void MainWindow::saveDecodedTextFile(QString filename)
{
QFile *outFile = new QFile(filename);
Expand Down
3 changes: 3 additions & 0 deletions mainwindow.h
Original file line number Diff line number Diff line change
Expand Up @@ -91,6 +91,7 @@ private slots:
void showDBCComparisonWindow();
void exitApp();
void handleSaveDecoded();
void handleSaveDecodedCsv();
void connectionStatusUpdated(int conns);
void gridClicked(QModelIndex);
void gridDoubleClicked(QModelIndex);
Expand Down Expand Up @@ -196,7 +197,9 @@ public slots:
//private methods
QString getSignalNameFromPosition(QPoint pos);
uint32_t getMessageIDFromPosition(QPoint pos);
void handleSaveDecodedMethod(bool csv);
void saveDecodedTextFile(QString);
void saveDecodedTextFileAsColumns(QString);
void addFrameToDisplay(CANFrame &, bool);
void updateFileStatus();
void closeEvent(QCloseEvent *event);
Expand Down
4 changes: 2 additions & 2 deletions re/graphingwindow.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ void GraphingWindow::changeEvent(QEvent *event)
}
else
{
setWindowOpacity(0.25);
//setWindowOpacity(0.25);
// widget is now inactive
qDebug() << "Hide";
}
Expand Down Expand Up @@ -199,7 +199,7 @@ void GraphingWindow::updatedFrames(int numFrames)
ui->graphingView->replot(); //now, redisplay them all
}
else //just got some new frames. See if they are relevant.
{
{
if (numFrames > modelFrames->count()) return;

for (int j = 0; j < graphParams.count(); j++)
Expand Down
Loading

0 comments on commit 662c5b9

Please sign in to comment.