mirror of
https://github.com/dragonpilot/dragonpilot.git
synced 2026-02-22 09:33:52 +08:00
3ca8e3653b
* initial version * print all message's in ncurses window * show download progress bar * move all to class ConsoleUI * timeline * improve timeline&stats * fix logMessage * add warning indicator * continue * cleanup * cast type to int * simplify seekToFlag * more * <= * handle enter * add box to logging window * fix multiple threads problem * fix concurrency issues * draw indicator * many improvements * more * fix multipe threads logging * stop replay before exit * use lambda instead of std::bind * cleanup * small cleanup * use carFingerPrint * don't emit signal in replay::stream * merge car_events into timeline * cleanup DonloadStats * cleanup * rename carname to carFingerprint * improve alert * add comments * add help functions templete function * handle term resize * display replaying status * rename to INSTANT * helper function pauseReplay * more * cleanup use rDebug * no template * less colors * remove function mv_add_str * use BORDER_SIZE * tune colors * add spaces * apply reviews use /
87 lines
2.8 KiB
C++
87 lines
2.8 KiB
C++
#include "selfdrive/ui/replay/camera.h"
|
|
#include "selfdrive/ui/replay/util.h"
|
|
|
|
#include <cassert>
|
|
|
|
CameraServer::CameraServer(std::pair<int, int> camera_size[MAX_CAMERAS], bool send_yuv) : send_yuv(send_yuv) {
|
|
for (int i = 0; i < MAX_CAMERAS; ++i) {
|
|
std::tie(cameras_[i].width, cameras_[i].height) = camera_size[i];
|
|
}
|
|
startVipcServer();
|
|
}
|
|
|
|
CameraServer::~CameraServer() {
|
|
for (auto &cam : cameras_) {
|
|
if (cam.thread.joinable()) {
|
|
cam.queue.push({});
|
|
cam.thread.join();
|
|
}
|
|
}
|
|
vipc_server_.reset(nullptr);
|
|
}
|
|
|
|
void CameraServer::startVipcServer() {
|
|
vipc_server_.reset(new VisionIpcServer("camerad"));
|
|
for (auto &cam : cameras_) {
|
|
if (cam.width > 0 && cam.height > 0) {
|
|
rInfo("camera[%d] frame size %dx%d", cam.type, cam.width, cam.height);
|
|
vipc_server_->create_buffers(cam.rgb_type, UI_BUF_COUNT, true, cam.width, cam.height);
|
|
if (send_yuv) {
|
|
vipc_server_->create_buffers(cam.yuv_type, YUV_BUFFER_COUNT, false, cam.width, cam.height);
|
|
}
|
|
if (!cam.thread.joinable()) {
|
|
cam.thread = std::thread(&CameraServer::cameraThread, this, std::ref(cam));
|
|
}
|
|
}
|
|
}
|
|
vipc_server_->start_listener();
|
|
}
|
|
|
|
void CameraServer::cameraThread(Camera &cam) {
|
|
auto read_frame = [&](FrameReader *fr, int frame_id) {
|
|
VisionBuf *rgb_buf = vipc_server_->get_buffer(cam.rgb_type);
|
|
VisionBuf *yuv_buf = send_yuv ? vipc_server_->get_buffer(cam.yuv_type) : nullptr;
|
|
bool ret = fr->get(frame_id, (uint8_t *)rgb_buf->addr, yuv_buf ? (uint8_t *)yuv_buf->addr : nullptr);
|
|
return ret ? std::pair{rgb_buf, yuv_buf} : std::pair{nullptr, nullptr};
|
|
};
|
|
|
|
while (true) {
|
|
const auto [fr, eidx] = cam.queue.pop();
|
|
if (!fr) break;
|
|
|
|
const int id = eidx.getSegmentId();
|
|
bool prefetched = (id == cam.cached_id && eidx.getSegmentNum() == cam.cached_seg);
|
|
auto [rgb, yuv] = prefetched ? cam.cached_buf : read_frame(fr, id);
|
|
if (rgb || yuv) {
|
|
VisionIpcBufExtra extra = {
|
|
.frame_id = eidx.getFrameId(),
|
|
.timestamp_sof = eidx.getTimestampSof(),
|
|
.timestamp_eof = eidx.getTimestampEof(),
|
|
};
|
|
if (rgb) vipc_server_->send(rgb, &extra, false);
|
|
if (yuv) vipc_server_->send(yuv, &extra, false);
|
|
} else {
|
|
rError("camera[%d] failed to get frame:", cam.type, eidx.getSegmentId());
|
|
}
|
|
|
|
cam.cached_id = id + 1;
|
|
cam.cached_seg = eidx.getSegmentNum();
|
|
cam.cached_buf = read_frame(fr, cam.cached_id);
|
|
|
|
--publishing_;
|
|
}
|
|
}
|
|
|
|
void CameraServer::pushFrame(CameraType type, FrameReader *fr, const cereal::EncodeIndex::Reader &eidx) {
|
|
auto &cam = cameras_[type];
|
|
if (cam.width != fr->width || cam.height != fr->height) {
|
|
cam.width = fr->width;
|
|
cam.height = fr->height;
|
|
waitFinish();
|
|
startVipcServer();
|
|
}
|
|
|
|
++publishing_;
|
|
cam.queue.push({fr, eidx});
|
|
}
|