57 lines
1.5 KiB
C++
57 lines
1.5 KiB
C++
#include "replay.h"
|
|
#include "selfdrive/hardware/hw.h"
|
|
|
|
Replay::Replay(QString route_, int seek) : route(route_) {
|
|
unlogger = new Unlogger(&events, &events_lock, &frs, seek);
|
|
current_segment = 0;
|
|
bool create_jwt = !Hardware::PC();
|
|
http = new HttpRequest(this, "https://api.commadotai.com/v1/route/" + route + "/files", "", create_jwt);
|
|
QObject::connect(http, &HttpRequest::receivedResponse, this, &Replay::parseResponse);
|
|
}
|
|
|
|
void Replay::parseResponse(const QString &response){
|
|
QJsonDocument doc = QJsonDocument::fromJson(response.trimmed().toUtf8());
|
|
|
|
if (doc.isNull()) {
|
|
qDebug() << "JSON Parse failed";
|
|
return;
|
|
}
|
|
|
|
camera_paths = doc["cameras"].toArray();
|
|
log_paths = doc["logs"].toArray();
|
|
|
|
// add first segment
|
|
addSegment(0);
|
|
}
|
|
|
|
void Replay::addSegment(int i){
|
|
if (lrs.find(i) != lrs.end()) {
|
|
return;
|
|
}
|
|
|
|
QThread* thread = new QThread;
|
|
|
|
QString log_fn = this->log_paths.at(i).toString();
|
|
lrs.insert(i, new LogReader(log_fn, &events, &events_lock, &unlogger->eidx));
|
|
|
|
lrs[i]->moveToThread(thread);
|
|
QObject::connect(thread, &QThread::started, lrs[i], &LogReader::process);
|
|
thread->start();
|
|
|
|
QString camera_fn = this->camera_paths.at(i).toString();
|
|
frs.insert(i, new FrameReader(qPrintable(camera_fn)));
|
|
}
|
|
|
|
void Replay::stream(SubMaster *sm){
|
|
QThread* thread = new QThread;
|
|
unlogger->moveToThread(thread);
|
|
QObject::connect(thread, &QThread::started, [=](){
|
|
unlogger->process(sm);
|
|
});
|
|
thread->start();
|
|
|
|
QObject::connect(unlogger, &Unlogger::loadSegment, [=](){
|
|
addSegment(++current_segment);
|
|
});
|
|
}
|