mirror of
https://github.com/sunnypilot/sunnypilot.git
synced 2026-09-15 04:23:43 +08:00
Dean Lee
504453c3e4
* support live streaming
* update live stream's time
* cleanup stream classes
* disable video control in live streaming mode
* emit streamStarted() in LiveStream::streamThread
* disable some features in live streaming mode
* refactor charts to support live streaming mode
* disable dynamic mode checkbox in live streaming mode
* updateDispalyRange
* thread safe events
* TODO: add support for ZMQ
* atomic time stamp
* only keep settings.cached_segment_limit*60 seconds data in liveStream
* make charts work better in live mode
* cleanup ChartView
* fix toolbar
* cleanup
cleanup
* disable openpilotPrefix and useOpenGL on macos
* add comment
* exit gracefully
* support ZMQ
* use ::operator new/delete
* cleanup streams
* cleanup
* align stream buffers
* check looping back
* check if series is empty
* cleanup
* add TODO: write stream to log file to replay it
* upper_bound
* remove class member event_range
* change default settings value
* cleanup updateDisplayrange
* fix merge error
old-commit-hash: f9490739ab
68 lines
2.2 KiB
C++
68 lines
2.2 KiB
C++
#pragma once
|
|
|
|
#include <map>
|
|
#include <QObject>
|
|
#include <QString>
|
|
#include "opendbc/can/common_dbc.h"
|
|
|
|
struct DBCMsg {
|
|
QString name;
|
|
uint32_t size;
|
|
std::map<QString, Signal> sigs;
|
|
std::vector<const Signal*> getSignals() const;
|
|
};
|
|
|
|
class DBCManager : public QObject {
|
|
Q_OBJECT
|
|
|
|
public:
|
|
DBCManager(QObject *parent);
|
|
~DBCManager();
|
|
|
|
void open(const QString &dbc_file_name);
|
|
void open(const QString &name, const QString &content);
|
|
QString generateDBC();
|
|
void addSignal(const QString &id, const Signal &sig);
|
|
void updateSignal(const QString &id, const QString &sig_name, const Signal &sig);
|
|
void removeSignal(const QString &id, const QString &sig_name);
|
|
|
|
static std::pair<uint8_t, uint32_t> parseId(const QString &id);
|
|
inline static std::vector<std::string> allDBCNames() { return get_dbc_names(); }
|
|
inline QString name() const { return dbc ? dbc->name.c_str() : ""; }
|
|
void updateMsg(const QString &id, const QString &name, uint32_t size);
|
|
void removeMsg(const QString &id);
|
|
inline const std::map<uint32_t, DBCMsg> &messages() const { return msgs; }
|
|
inline const DBCMsg *msg(const QString &id) const { return msg(parseId(id).second); }
|
|
inline const DBCMsg *msg(uint32_t address) const {
|
|
auto it = msgs.find(address);
|
|
return it != msgs.end() ? &it->second : nullptr;
|
|
}
|
|
|
|
signals:
|
|
void signalAdded(const Signal *sig);
|
|
void signalRemoved(const Signal *sig);
|
|
void signalUpdated(const Signal *sig);
|
|
void msgUpdated(uint32_t address);
|
|
void msgRemoved(uint32_t address);
|
|
void DBCFileChanged();
|
|
|
|
private:
|
|
void initMsgMap();
|
|
DBC *dbc = nullptr;
|
|
std::map<uint32_t, DBCMsg> msgs;
|
|
};
|
|
|
|
// TODO: Add helper function in dbc.h
|
|
double get_raw_value(uint8_t *data, size_t data_size, const Signal &sig);
|
|
bool operator==(const Signal &l, const Signal &r);
|
|
inline bool operator!=(const Signal &l, const Signal &r) { return !(l == r); }
|
|
int bigEndianStartBitsIndex(int start_bit);
|
|
int bigEndianBitIndex(int index);
|
|
void updateSigSizeParamsFromRange(Signal &s, int start_bit, int size);
|
|
std::pair<int, int> getSignalRange(const Signal *s);
|
|
DBCManager *dbc();
|
|
inline QString msgName(const QString &id, const char *def = "untitled") {
|
|
auto msg = dbc()->msg(id);
|
|
return msg ? msg->name : def;
|
|
}
|