Minor changes

applications/vision/src/main.cpp

@@ -156,9 +156,11 @@ static void run(ftl::Configurable *root) {
 	ftl::data::Pool pool(2,5);
 	auto creator = pool.creator<ftl::data::IntervalFrameCreator>(0, source);
 
-	auto h = source->onFrame([](ftl::data::Frame &f) {
-		LOG(INFO) << "Got a frame";
-		if (f.has(ftl::codecs::Channel::Colour)) {
+	// Listen for any flush events for frameset 0
+	auto flushh = pool.group(0).onFlush([](ftl::data::Frame &f, ftl::codecs::Channel c) {
+		// Send to sender for encoding
+
+		if (c == ftl::codecs::Channel::Colour) {
 			cv::Mat tmp;
 			f.get<cv::cuda::GpuMat>(ftl::codecs::Channel::Colour).download(tmp);
 			cv::imshow("Image", tmp);
@@ -167,6 +169,16 @@ static void run(ftl::Configurable *root) {
 		return true;
 	});
 
+	// Callback for when a source has populated a frame with data
+	auto h = source->onFrame([](ftl::data::Frame &f) {
+		// Lock and send colour right now to encode in parallel
+		f.flush(ftl::codecs::Channel::Colour);
+
+		// Do pipeline here...
+		return true;
+	});
+
+	// Start the timed generation of frames
 	creator.start();
 
 	int stats_count = 0;

components/rgbd-sources/src/source.cpp

@@ -183,6 +183,7 @@ bool Source::capture(int64_t ts) {
 }
 
 bool Source::retrieve(ftl::data::Frame &f) {
+	if (is_retrieving) return false;
 	is_retrieving = true;
 	bool status = false;
 	if (impl_) status = impl_->retrieve(f.cast<ftl::rgbd::Frame>());

components/structures/include/ftl/data/framepool.hpp

@@ -19,6 +19,7 @@ class Pool {
 	void release(Frame &f);
 
 	ftl::data::Session &session(uint32_t id);
+	inline ftl::data::Session &group(uint32_t id) { return session(id); }
 
 	size_t size(uint32_t id);
 

components/structures/src/creators.cpp

@@ -31,7 +31,9 @@ void IntervalFrameCreator::start() {
 	retrieve_ = std::move(ftl::timer::add(ftl::timer::timerlevel_t::kTimerMain, [this](int64_t ts) {
 		Frame f = create(ts);
 		f.store();
-		src_->retrieve(f);
+		if (!src_->retrieve(f)) {
+			LOG(WARNING) << "Frame was skipping";
+		}
 		return true;
 	}));
 }