diff --git a/gui/src/SqpApplication.cpp b/gui/src/SqpApplication.cpp index 5d2dfc3..c2c5337 100644 --- a/gui/src/SqpApplication.cpp +++ b/gui/src/SqpApplication.cpp @@ -1,6 +1,7 @@ #include "SqpApplication.h" #include +#include #include #include #include @@ -63,6 +64,8 @@ public: m_VariableControllerThread.setObjectName("VariableControllerThread"); m_VisualizationController->moveToThread(&m_VisualizationControllerThread); m_VisualizationControllerThread.setObjectName("VsualizationControllerThread"); + m_CatalogueController->moveToThread(&m_CatalogueControllerThread); + m_CatalogueControllerThread.setObjectName("CatalogueControllerThread"); // Additionnal init @@ -82,6 +85,9 @@ public: m_VisualizationControllerThread.quit(); m_VisualizationControllerThread.wait(); + + m_CatalogueControllerThread.quit(); + m_CatalogueControllerThread.wait(); } std::unique_ptr m_DataSourceController; @@ -89,11 +95,13 @@ public: std::unique_ptr m_TimeController; std::unique_ptr m_NetworkController; std::unique_ptr m_VisualizationController; + std::unique_ptr m_CatalogueController; QThread m_DataSourceControllerThread; QThread m_NetworkControllerThread; QThread m_VariableControllerThread; QThread m_VisualizationControllerThread; + QThread m_CatalogueControllerThread; std::unique_ptr m_DragDropGuiController; std::unique_ptr m_ActionsGuiController; @@ -128,10 +136,16 @@ SqpApplication::SqpApplication(int &argc, char **argv) connect(&impl->m_VisualizationControllerThread, &QThread::finished, impl->m_VisualizationController.get(), &VisualizationController::finalize); + connect(&impl->m_CatalogueControllerThread, &QThread::started, + impl->m_CatalogueController.get(), &CatalogueController::initialize); + connect(&impl->m_CatalogueControllerThread, &QThread::finished, + impl->m_CatalogueController.get(), &CatalogueController::finalize); + impl->m_DataSourceControllerThread.start(); impl->m_NetworkControllerThread.start(); impl->m_VariableControllerThread.start(); impl->m_VisualizationControllerThread.start(); + impl->m_CatalogueControllerThread.start(); } SqpApplication::~SqpApplication()