From bf42c259a5d77c27abefb67abe894ea968a78445 Mon Sep 17 00:00:00 2001
From: Nicolas Pope <nwpope@utu.fi>
Date: Fri, 24 Jul 2020 13:55:43 +0300
Subject: [PATCH] WIP drop partial framesets
---
components/streams/src/feed.cpp | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/components/streams/src/feed.cpp b/components/streams/src/feed.cpp
index c8dff9d32..0eeadf3d3 100644
--- a/components/streams/src/feed.cpp
+++ b/components/streams/src/feed.cpp
@@ -169,6 +169,13 @@ Feed::Feed(nlohmann::json &config, ftl::net::Universe*net) :
handle_receiver_ = receiver_->onFrameSet(
[this](const ftl::data::FrameSetPtr& fs) {
+ if (value("drop_partial_framesets", false)) {
+ if (fs->count < fs->frames.size()) {
+ LOG(WARNING) << "Dropping partial frameset: " << fs->timestamp();
+ return true;
+ }
+ }
+
// FIXME: What happens if pipeline added concurrently?
if (pre_pipelines_.count(fs->frameset()) == 1) {
pre_pipelines_[fs->frameset()]->apply(*fs, *fs, 0);
--
GitLab