mirror of
https://github.com/dragonpilot/dragonpilot.git
synced 2026-07-13 08:52:06 +08:00
Dean Lee
1b8324af87
* draft * continue * fix QChart unresponsive with large points * build with --extras * add filter * save DBC button * more buttons * add flag to use qcamera * stop replay in dctor * README * use getMsg * video control * edit signal * add colors * correct ts * add/edit signals * use bus:address as key
67 lines
1.6 KiB
C++
67 lines
1.6 KiB
C++
#pragma once
|
|
|
|
#include <QApplication>
|
|
#include <QObject>
|
|
#include <QThread>
|
|
#include <atomic>
|
|
#include <map>
|
|
|
|
#include "opendbc/can/common.h"
|
|
#include "opendbc/can/common_dbc.h"
|
|
#include "tools/replay/replay.h"
|
|
|
|
const int DATA_LIST_SIZE = 500;
|
|
// const int FPS = 20;
|
|
|
|
struct CanData {
|
|
QString id;
|
|
double ts;
|
|
uint32_t address;
|
|
uint16_t bus_time;
|
|
uint8_t source;
|
|
QByteArray dat;
|
|
QString hex_dat;
|
|
};
|
|
|
|
class Parser : public QObject {
|
|
Q_OBJECT
|
|
|
|
public:
|
|
Parser(QObject *parent);
|
|
~Parser();
|
|
static uint32_t addressFromId(const QString &id);
|
|
bool loadRoute(const QString &route, const QString &data_dir, bool use_qcam);
|
|
void openDBC(const QString &name);
|
|
void saveDBC(const QString &name) {}
|
|
void addNewMsg(const Msg &msg);
|
|
void removeSignal(const QString &id, const QString &sig_name);
|
|
const Msg *getMsg(const QString &id) {
|
|
return getMsg(addressFromId(id));
|
|
}
|
|
const Msg *getMsg(uint32_t address) {
|
|
auto it = msg_map.find(address);
|
|
return it != msg_map.end() ? it->second : nullptr;
|
|
}
|
|
signals:
|
|
void showPlot(const QString &id, const QString &name);
|
|
void hidePlot(const QString &id, const QString &name);
|
|
void received(std::vector<CanData> can);
|
|
void updated();
|
|
|
|
public:
|
|
void recvThread();
|
|
void process(std::vector<CanData> can);
|
|
QThread *thread;
|
|
QString dbc_name;
|
|
std::atomic<bool> exit = false;
|
|
std::map<QString, std::list<CanData>> can_msgs;
|
|
std::map<QString, uint64_t> counters;
|
|
Replay *replay = nullptr;
|
|
DBC *dbc = nullptr;
|
|
std::map<uint32_t, const Msg *> msg_map;
|
|
};
|
|
|
|
Q_DECLARE_METATYPE(std::vector<CanData>);
|
|
|
|
extern Parser *parser;
|