BackendThread.cpp

// Author: Kang Lin <kl222@126.com>
 
#include <QLoggingCategory>
#include <QMetaMethod>
#include "BackendThread.h"
#include "Backend.h"
 
static Q_LOGGING_CATEGORY(log, "BackendThread")
 
CBackendThread::CBackendThread(COperate *pOperate, QObject *pParent)
    : QThread(pParent)
    , m_pOperate(pOperate)
    , m_pBackend(nullptr)
{
    qDebug(log) << Q_FUNC_INFO;
    bool check = false;
    if(nullptr == pParent) {
        // It is deleted when it is finished.
        check = connect(this, SIGNAL(finished()), this, SLOT(deleteLater()));
        Q_ASSERT(check);
    }
}
 
CBackendThread::~CBackendThread()
{
    qDebug(log) << Q_FUNC_INFO;
}
 
void CBackendThread::quit()
{
    qDebug(log) << Q_FUNC_INFO;
    QThread::quit();
    if(m_pBackend) {
        m_pBackend->WakeUp();
    }
}

void CBackendThread::run()
{
    qDebug(log) << Q_FUNC_INFO << "start";
 
    Q_ASSERT(m_pOperate);
    int nRet = 0;
    /*
    const QMetaObject* metaObject = m_pOperate->metaObject();
    QStringList methods;
    for(int i = 0; i < metaObject->methodCount(); ++i)
        methods << QString::fromLatin1(metaObject->method(i).methodSignature());
    qDebug(log) << methods;
    //*/
    if(-1 == m_pOperate->metaObject()->indexOfMethod("InstanceBackend()"))
    {
        QString szErr;
        szErr = "The class " + QString(m_pOperate->metaObject()->className())
                + " has not method InstanceBackend()."
                  "Please add 'Q_INVOKABLE virtual CBackend* InstanceBackend()' to "
                + QString(m_pOperate->metaObject()->className());
        qCritical(log) << szErr;
        Q_ASSERT_X(false, "BackendThread", szErr.toStdString().c_str());
        emit m_pOperate->sigFinished();
        return;
    }
 
    bool bRet = QMetaObject::invokeMethod(
        m_pOperate, "InstanceBackend",
        Qt::DirectConnection,
        Q_RETURN_ARG(CBackend*, m_pBackend));
    if(!m_pBackend || !bRet)
    {
        qCritical(log) << "InstanceBackend fail";
        emit m_pOperate->sigFinished();
        return;
    }
 
    if(m_pBackend) {
        nRet = m_pBackend->Start();
        if(nRet) {
            qCritical(log) << "Backend start fail:" << nRet;
            m_pBackend->Stop();
            m_pBackend->deleteLater();
            m_pBackend = nullptr;
            //emit m_pOperate->sigFinished(); // 在 m_pBackend->Stop() 中触发
            return;
        }
    }
 
    exec();
 
    if(m_pBackend) {
        m_pBackend->Stop();
        m_pBackend->deleteLater();
    }
 
    qDebug(log) << Q_FUNC_INFO << "end";
}