Remove group callbacks

components/rgbd-sources/include/ftl/rgbd/source.hpp

@@ -199,7 +199,8 @@ class Source : public ftl::Configurable {
 	SHARED_MUTEX &mutex() { return mutex_; }
 
 	std::function<void(int64_t, const cv::Mat &, const cv::Mat &)> &callback() { return callback_; }
-	void setCallback(std::function<void(int64_t, const cv::Mat &, const cv::Mat &)> cb) { callback_ = cb; }
+	void setCallback(std::function<void(int64_t, const cv::Mat &, const cv::Mat &)> cb);
+	void removeCallback() { callback_ = nullptr; }
 
 
 	private:

components/rgbd-sources/src/group.cpp

@@ -11,7 +11,9 @@ Group::Group() : framesets_(kFrameBufferSize), head_(0) {
 }
 
 Group::~Group() {
-
+	for (auto s : sources_) {
+		s->removeCallback();
+	}
 }
 
 void Group::addSource(ftl::rgbd::Source *src) {

components/rgbd-sources/src/source.cpp

@@ -355,3 +355,8 @@ bool Source::setChannel(ftl::rgbd::channel_t c) {
 const ftl::rgbd::Camera Source::parameters(ftl::rgbd::channel_t chan) const {
 	return (impl_) ? impl_->parameters(chan) : parameters();
 }
+
+void Source::setCallback(std::function<void(int64_t, const cv::Mat &, const cv::Mat &)> cb) {
+	if (bool(callback_)) LOG(ERROR) << "Source already has a callback: " << getURI();
+	callback_ = cb;
+}