Correct Event Loop Connections

FaultFinder.cpp

@@ -2,10 +2,10 @@
 
 FaultFinder::FaultFinder(QObject *parent) : QObject(parent)
 {
-    fault_mgr = new FaultManager(parent);
-    image_mgr = new ImageManager(parent);
-    config_mgr = new ConfigManager(parent);
-    stream_mgr = new StreamManager(parent);
+    fault_mgr = new FaultManager(this);
+    image_mgr = new ImageManager(this);
+    config_mgr = new ConfigManager(this);
+    stream_mgr = new StreamManager(this);
 }
 
 FaultFinder::~FaultFinder()

ImageManager.cpp

@@ -3,8 +3,8 @@
 #include <opencv2/imgcodecs.hpp>
 #include <opencv2/imgproc.hpp>
 
+#include "FaultFinder.hpp"
 #include "ImageManager.hpp"
-#include "FaultManager.hpp"
 
 #define ZERO 0
 #define BITS8 0xff

ImageManager.hpp

@@ -25,6 +25,4 @@ private:
     
 };
 
-#include "FaultFinder.hpp"
-
 #endif

StreamManager.cpp

@@ -1,9 +1,11 @@
 #include "StreamManager.hpp"
+#include "FaultFinder.hpp"
 
 StreamManager::StreamManager(QObject *parent) : QObject(parent)
 {  
-    // Listen for New Emissivity Signal 
-    //connect(&config_mgr, &ConfigManager::NewEmissivity, this, &StreamManager::SetEmissivity);
+    // Connect Signals
+    connect(((FaultFinder *)parent)->config_mgr, &ConfigManager::NewEmissivity, this, &StreamManager::SetEmissivity);
+
     PvResult res;
 
     res = FindDevice();
@@ -28,6 +30,7 @@ StreamManager::StreamManager(QObject *parent) : QObject(parent)
     StartStream();
 
     ImageThread = new StreamReader(Device, Stream, Pipeline);
+    connect(ImageThread, &StreamReader::NewImage, this, &StreamManager::SendForProcessing, Qt::QueuedConnection);
     ImageThread->start(QThread::TimeCriticalPriority);
 }
 
@@ -39,8 +42,14 @@ StreamManager::~StreamManager()
     Disconnect();
 }
 
+void StreamManager::SendForProcessing(uint32_t width, uint32_t height, uint8_t *imgPointer)
+{
+    ((FaultFinder *)parent())->image_mgr->ProcessImage(width, height, imgPointer);
+}
+
 void StreamManager::SetEmissivity(double emissivity)
 {
+    qInfo() << "HERE";
     if (lDeviceParams)
         lDeviceParams->SetFloatValue("ObjectEmissivity", emissivity);
 }

StreamManager.hpp

@@ -10,7 +10,6 @@
 #include <PvPipeline.h>
 #include <PvDeviceGEV.h>
 #include <PvStreamGEV.h>
-
 #include "StreamReader.hpp"
 
 #define BUFFER_COUNT (32)
@@ -25,6 +24,7 @@ public:
 
 public slots:
     void SetEmissivity(double emissivity);
+    void SendForProcessing(uint32_t width, uint32_t height, uint8_t *imgPointer);
 
 private:
     PvResult FindDevice();

StreamReader.cpp

@@ -36,7 +36,7 @@ void StreamReader::run()
                     lWidth = lImage->GetWidth();
                     lHeight = lImage->GetHeight();
 
-                    NewImage(lWidth, lHeight, lImage->GetDataPointer());
+                    emit NewImage(lWidth, lHeight, lImage->GetDataPointer());
                 }
                 else 
                 {