Working group proxy

applications/reconstruct/src/main.cpp

@@ -160,6 +160,7 @@ static void run(ftl::Configurable *root) {
 	}
 
 	stream->setLatency(5);  // FIXME: This depends on source!?
+	stream->add(&group);
 	stream->run();
 
 	bool busy = false;

components/rgbd-sources/src/group.cpp

@@ -222,6 +222,7 @@ void Group::sync(std::function<bool(ftl::rgbd::FrameSet &)> cb) {
 		return true;
 	});
 
+	LOG(INFO) << "Start timer";
 	ftl::timer::start(true);
 }
 

components/rgbd-sources/src/streamer.cpp

@@ -194,13 +194,16 @@ void Streamer::add(ftl::rgbd::Group *grp) {
 			//group_.addSource(src);
 
 			src->addRawCallback([this,s](Source *src, const ftl::codecs::StreamPacket &spkt, const ftl::codecs::Packet &pkt) {
+				LOG(INFO) << "RAW CALLBACK";
 				_transmitPacket(s, spkt, pkt, false);
 			});
 		}
 
-		LOG(INFO) << "Streaming: " << src->getID();
+		LOG(INFO) << "Proxy Streaming: " << src->getID();
 		net_->broadcast("add_stream", src->getID());
 	}
+
+	LOG(INFO) << "All proxy streams added";
 }
 
 void Streamer::_addClient(const string &source, int N, int rate, const ftl::UUID &peer, const string &dest) {
@@ -378,10 +381,11 @@ void Streamer::_process(ftl::rgbd::FrameSet &fs) {
 	// Prevent new clients during processing.
 	SHARED_LOCK(mutex_,slk);
 
-	if (fs.sources.size() != sources_.size()) {
-		LOG(ERROR) << "Incorrect number of sources in frameset: " << fs.sources.size() << " vs " << sources_.size();
-		return;
-	}
+	// This check is not valid, always assume fs.sources is correct
+	//if (fs.sources.size() != sources_.size()) {
+	//	LOG(ERROR) << "Incorrect number of sources in frameset: " << fs.sources.size() << " vs " << sources_.size();
+		//return;
+	//}
 
 	int totalclients = 0;