PluginClientThread.cpp

#include "PluginClientThread.h"
 
#include <QLoggingCategory>
 
static Q_LOGGING_CATEGORY(log, "Client.Plugin.Thread")
 
CPluginClientThread::CPluginClientThread(QObject *parent)
    : CPluginClient(parent),
    m_pThread(nullptr)
{
    m_pThread = new CPluginThread(); // Note that the parent object pointer cannot be set here.
    if(m_pThread)
    {
        // The object is also deleted when the thread finishes executing.
        bool check = connect(m_pThread, SIGNAL(finished()),
                           m_pThread, SLOT(deleteLater()));
        Q_ASSERT(check);
        m_pThread->start();
    }
}
 
CPluginClientThread::~CPluginClientThread()
{
    qDebug(log) << "CPluginClientThread::~CPluginClientThread";
    if(m_pThread)
        m_pThread->quit(); // The don't deleteLater().
                           // because of it is connected finished signal
}
 
CConnecter *CPluginClientThread::CreateConnecter(const QString &szProtocol)
{
    qDebug(log) << "CPluginClientThread::CreateConnecter()" << szProtocol;
    CConnecterConnect* pConnecter = OnCreateConnecter(szProtocol);
    if(!pConnecter) return nullptr;
    
    if(nullptr == m_pThread)
    {
        qDebug(log) << "The thread is nullptr";
        return nullptr;
    }
 
    bool check = connect(pConnecter, SIGNAL(sigOpenConnect(CConnecterConnect*)),
                         m_pThread, SIGNAL(sigConnect(CConnecterConnect*)));
    Q_ASSERT(check);
    check = connect(pConnecter, SIGNAL(sigCloseconnect(CConnecterConnect*)),
                    m_pThread, SIGNAL(sigDisconnect(CConnecterConnect*)));
    Q_ASSERT(check);
    
    return pConnecter;
}