Skip to content
Snippets Groups Projects
Commit e670e3b7 authored by Nicolas Pope's avatar Nicolas Pope
Browse files

Fixes for latency display

parent c7e8d869
No related branches found
No related tags found
Loading
Pipeline #28591 passed
...@@ -39,7 +39,7 @@ void Camera::update(double delta) { ...@@ -39,7 +39,7 @@ void Camera::update(double delta) {
auto *mod = screen->getModule<ftl::gui2::Statistics>(); auto *mod = screen->getModule<ftl::gui2::Statistics>();
mod->getJSON(StatisticsPanel::PERFORMANCE_INFO)["FPS"] = n/diff; mod->getJSON(StatisticsPanel::PERFORMANCE_INFO)["FPS"] = n/diff;
mod->getJSON(StatisticsPanel::PERFORMANCE_INFO)["Latency"] = l; mod->getJSON(StatisticsPanel::PERFORMANCE_INFO)["Latency"] = std::to_string(int(l))+std::string("ms");
if (live_) mod->getJSON(StatisticsPanel::MEDIA_STATUS)["LIVE"] = nlohmann::json{{"icon", ENTYPO_ICON_VIDEO_CAMERA},{"value", true},{"colour","#0000FF"},{"size",28}}; if (live_) mod->getJSON(StatisticsPanel::MEDIA_STATUS)["LIVE"] = nlohmann::json{{"icon", ENTYPO_ICON_VIDEO_CAMERA},{"value", true},{"colour","#0000FF"},{"size",28}};
auto ptr = std::atomic_load(&latest_); auto ptr = std::atomic_load(&latest_);
......
...@@ -209,9 +209,10 @@ void Receiver::_processData(const StreamPacket &spkt, const Packet &pkt) { ...@@ -209,9 +209,10 @@ void Receiver::_processData(const StreamPacket &spkt, const Packet &pkt) {
//UNIQUE_LOCK(vidstate.mutex, lk); //UNIQUE_LOCK(vidstate.mutex, lk);
timestamp_ = spkt.timestamp; timestamp_ = spkt.timestamp;
fs->completed(spkt.frame_number); fs->completed(spkt.frame_number);
fs->localTimestamp = spkt.localTimestamp;
} }
fs->localTimestamp = spkt.localTimestamp;
/*const auto *cs = stream_; /*const auto *cs = stream_;
const auto sel = stream_->selected(spkt.frameSetID()) & cs->available(spkt.frameSetID()); const auto sel = stream_->selected(spkt.frameSetID()) & cs->available(spkt.frameSetID());
...@@ -259,9 +260,10 @@ void Receiver::_processAudio(const StreamPacket &spkt, const Packet &pkt) { ...@@ -259,9 +260,10 @@ void Receiver::_processAudio(const StreamPacket &spkt, const Packet &pkt) {
//UNIQUE_LOCK(vidstate.mutex, lk); //UNIQUE_LOCK(vidstate.mutex, lk);
timestamp_ = spkt.timestamp; timestamp_ = spkt.timestamp;
fs->completed(spkt.frame_number); fs->completed(spkt.frame_number);
fs->localTimestamp = spkt.localTimestamp;
} }
fs->localTimestamp = spkt.localTimestamp;
// Generate settings from packet data // Generate settings from packet data
/*ftl::audio::AudioSettings settings; /*ftl::audio::AudioSettings settings;
settings.channels = (spkt.channel == Channel::AudioStereo) ? 2 : 1; settings.channels = (spkt.channel == Channel::AudioStereo) ? 2 : 1;
...@@ -437,9 +439,10 @@ void Receiver::_processVideo(const StreamPacket &spkt, const Packet &pkt) { ...@@ -437,9 +439,10 @@ void Receiver::_processVideo(const StreamPacket &spkt, const Packet &pkt) {
UNIQUE_LOCK(vidstate.mutex, lk); UNIQUE_LOCK(vidstate.mutex, lk);
timestamp_ = spkt.timestamp; timestamp_ = spkt.timestamp;
fs->completed(spkt.frame_number+i); fs->completed(spkt.frame_number+i);
fs->localTimestamp = spkt.localTimestamp;
} }
} }
fs->localTimestamp = spkt.localTimestamp;
} }
void Receiver::processPackets(const StreamPacket &spkt, const Packet &pkt) { void Receiver::processPackets(const StreamPacket &spkt, const Packet &pkt) {
...@@ -461,7 +464,6 @@ void Receiver::processPackets(const StreamPacket &spkt, const Packet &pkt) { ...@@ -461,7 +464,6 @@ void Receiver::processPackets(const StreamPacket &spkt, const Packet &pkt) {
//UNIQUE_LOCK(vidstate.mutex, lk); // FIXME: Should have a lock here... //UNIQUE_LOCK(vidstate.mutex, lk); // FIXME: Should have a lock here...
timestamp_ = spkt.timestamp; timestamp_ = spkt.timestamp;
fs->completed(frame.source()); fs->completed(frame.source());
fs->localTimestamp = spkt.localTimestamp;
} }
//if (frame.availableAll(sel)) { //if (frame.availableAll(sel)) {
...@@ -469,6 +471,8 @@ void Receiver::processPackets(const StreamPacket &spkt, const Packet &pkt) { ...@@ -469,6 +471,8 @@ void Receiver::processPackets(const StreamPacket &spkt, const Packet &pkt) {
// fs->completed(frame.source()); // fs->completed(frame.source());
//} //}
} }
fs->localTimestamp = spkt.localTimestamp;
} }
return; return;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment