67 lines
1.5 KiB
C++
67 lines
1.5 KiB
C++
|
#include "worker.h"
|
||
|
|
#include "update.h"
|
||
|
|
|
||
|
|
#include <QCoreApplication>
|
||
|
|
#include <QApplication>
|
||
|
|
#include <QDebug>
|
||
|
|
#include <QTimer>
|
||
|
|
#include <QFileInfo>
|
||
|
|
#include <QDir>
|
||
|
|
#include <QThread>
|
||
|
|
|
||
|
|
#include "message_handler.h"
|
||
|
|
#include "plugins/interfaces.h"
|
||
|
|
|
||
|
|
|
||
|
|
Worker::Worker(QString update_ctrl_file, QString workingDir)
|
||
|
|
: m_update_ctrl_file(update_ctrl_file)
|
||
|
|
, m_workingDir(workingDir)
|
||
|
|
, m_workerThread("workerThread") {
|
||
|
|
|
||
|
|
this->moveToThread(&m_workerThread);
|
||
|
|
m_workerThread.start();
|
||
|
|
QThread::usleep(100000);
|
||
|
|
|
||
|
|
int cnt = 0;
|
||
|
|
while (!m_workerThread.isRunning()) {
|
||
|
|
if (++cnt > 5) {
|
||
|
|
qCritical() << "starting worker thread FAILED";
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
QThread::sleep(1);
|
||
|
|
}
|
||
|
|
|
||
|
|
connect(this, SIGNAL(workNow()), this, SLOT(work()), Qt::QueuedConnection);
|
||
|
|
connect(&m_timer, SIGNAL(timeout()), this, SLOT(update()));
|
||
|
|
m_timer.setSingleShot(true);
|
||
|
|
m_timer.start(1000);
|
||
|
|
}
|
||
|
|
|
||
|
|
Worker::~Worker() {
|
||
|
|
int cnt = 0;
|
||
|
|
m_workerThread.quit();
|
||
|
|
while (!m_workerThread.isFinished()) {
|
||
|
|
if (!m_workerThread.wait(1000)) {
|
||
|
|
if (++cnt > 5) {
|
||
|
|
qCritical() << "stopping worker thread FAILED";
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
void Worker::update() {
|
||
|
|
qCritical() << __func__ << ":" << __LINE__;
|
||
|
|
emit workNow();
|
||
|
|
}
|
||
|
|
|
||
|
|
void Worker::work() {
|
||
|
|
qCritical() << __func__ << ":" << __LINE__;
|
||
|
|
//Update m_update(m_update_ctrl_file, m_workingDir);
|
||
|
|
QThread::sleep(3);
|
||
|
|
//if (m_update.doUpdate()) {
|
||
|
|
//}
|
||
|
|
m_workerThread.quit();
|
||
|
|
QApplication::quit();
|
||
|
|
}
|