You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
48 lines
1.7 KiB
48 lines
1.7 KiB
#include "tools/cabana/streams/replaystream.h"
|
|
|
|
#include "tools/cabana/dbcmanager.h"
|
|
|
|
ReplayStream::ReplayStream(uint32_t replay_flags, QObject *parent) : replay_flags(replay_flags), AbstractStream(parent, false) {
|
|
QObject::connect(&settings, &Settings::changed, [this]() {
|
|
if (replay) replay->setSegmentCacheLimit(settings.max_cached_minutes);
|
|
});
|
|
}
|
|
|
|
ReplayStream::~ReplayStream() {
|
|
if (replay) replay->stop();
|
|
}
|
|
|
|
static bool event_filter(const Event *e, void *opaque) {
|
|
return ((ReplayStream *)opaque)->eventFilter(e);
|
|
}
|
|
|
|
bool ReplayStream::loadRoute(const QString &route, const QString &data_dir) {
|
|
replay.reset(new Replay(route, {"can", "roadEncodeIdx", "wideRoadEncodeIdx", "carParams"}, {}, nullptr, replay_flags, data_dir, this));
|
|
replay->setSegmentCacheLimit(settings.max_cached_minutes);
|
|
replay->installEventFilter(event_filter, this);
|
|
QObject::connect(replay.get(), &Replay::seekedTo, this, &AbstractStream::seekedTo);
|
|
QObject::connect(replay.get(), &Replay::segmentsMerged, this, &AbstractStream::eventsMerged);
|
|
QObject::connect(replay.get(), &Replay::streamStarted, this, &AbstractStream::streamStarted);
|
|
if (replay->load()) {
|
|
const auto &segments = replay->route()->segments();
|
|
if (std::none_of(segments.begin(), segments.end(), [](auto &s) { return s.second.rlog.length() > 0; })) {
|
|
qWarning() << "no rlogs in route" << route;
|
|
return false;
|
|
}
|
|
replay->start();
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
bool ReplayStream::eventFilter(const Event *event) {
|
|
if (event->which == cereal::Event::Which::CAN) {
|
|
updateEvent(event);
|
|
}
|
|
return true;
|
|
}
|
|
|
|
void ReplayStream::pause(bool pause) {
|
|
replay->pause(pause);
|
|
emit(pause ? paused() : resume());
|
|
}
|
|
|