Compare commits
3 Commits
gerhard-de
...
v1.3.21
Author | SHA1 | Date | |
---|---|---|---|
e87456f26b | |||
0c9a7bc7b5 | |||
a35c6afcb8 |
@@ -64,8 +64,8 @@ DEFINES += QT_DEPRECATED_WARNINGS
|
|||||||
# given in ATBUpdateTool.ini can be overwritten on the command-line.
|
# given in ATBUpdateTool.ini can be overwritten on the command-line.
|
||||||
# 1.3.18: Bug fixes found during testing.
|
# 1.3.18: Bug fixes found during testing.
|
||||||
# 1.3.19: Bug fixes found during testing.
|
# 1.3.19: Bug fixes found during testing.
|
||||||
VERSION="1.3.20"
|
|
||||||
# 1.3.20: Bug fixes found during testing.
|
# 1.3.20: Bug fixes found during testing.
|
||||||
|
VERSION="1.3.21"
|
||||||
|
|
||||||
# PLANNED TODOS:
|
# PLANNED TODOS:
|
||||||
# 1: Das Repository wird repariert bwz. neu geklont. Unabhaengig vom WAIT.
|
# 1: Das Repository wird repariert bwz. neu geklont. Unabhaengig vom WAIT.
|
||||||
@@ -96,6 +96,9 @@ VERSION="1.3.20"
|
|||||||
# Stellung des WAIT-Button. Grund: es koennte sein, dass andernfalls ein
|
# Stellung des WAIT-Button. Grund: es koennte sein, dass andernfalls ein
|
||||||
# PSA weit hiter anderen steht, und dann ploetzlich einmal alle vorher-
|
# PSA weit hiter anderen steht, und dann ploetzlich einmal alle vorher-
|
||||||
# gehenden Aenderungen anzieht, die gar nicht fuer ihn gemeint waren.
|
# gehenden Aenderungen anzieht, die gar nicht fuer ihn gemeint waren.
|
||||||
|
# 10: Bei einer Neuinstallation (Neuhauser) immer JSON files runterladen,
|
||||||
|
# Tariff-Files syncen (d.h. nur wenn noch kein Repo vorhanden ist), und
|
||||||
|
# zwar auch ohne WAIT-Button.
|
||||||
|
|
||||||
|
|
||||||
win32 {
|
win32 {
|
||||||
|
77
interfaces.h
77
interfaces.h
@@ -2,7 +2,6 @@
|
|||||||
#define INTERFACE_H
|
#define INTERFACE_H
|
||||||
|
|
||||||
#include <QtPlugin>
|
#include <QtPlugin>
|
||||||
#include <QString>
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -398,8 +397,6 @@ struct T_bna
|
|||||||
|
|
||||||
};
|
};
|
||||||
|
|
||||||
class hwapi;
|
|
||||||
class DownloadThread;
|
|
||||||
class hwinf
|
class hwinf
|
||||||
{
|
{
|
||||||
|
|
||||||
@@ -2276,62 +2273,35 @@ public:
|
|||||||
// countOfBills[1] for 10€ and so on
|
// countOfBills[1] for 10€ and so on
|
||||||
|
|
||||||
|
|
||||||
// download device controller
|
|
||||||
virtual bool dcDownloadRequest(QString const &fileToDownload) const {
|
|
||||||
Q_UNUSED(fileToDownload);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
virtual bool dcDownloadRequested() const { return false; }
|
|
||||||
virtual bool dcDownloadResetRequest() const { return false; }
|
|
||||||
virtual bool dcDownloadRequestAck() const { return false; }
|
|
||||||
virtual bool dcDownloadRunning() const { return false; }
|
|
||||||
virtual bool dcDownloadFinished() { return false; }
|
|
||||||
|
|
||||||
virtual bool dcDownloadReportStart() const { return false; }
|
|
||||||
virtual bool dcDownloadReportRunning() const { return true; }
|
|
||||||
virtual bool dcDownloadReportFinished() { return true; }
|
|
||||||
|
|
||||||
virtual bool dcDownloadThreadStart() { return false; }
|
|
||||||
virtual bool dcDownloadThreadRunning() const { return true; }
|
|
||||||
virtual void dcDownloadThreadFinalize(DownloadThread *) {}
|
|
||||||
virtual bool dcDownloadThreadFinished() const { return true; }
|
|
||||||
virtual bool dcDownloadReportThreadStart() { return false; }
|
|
||||||
virtual bool dcDownloadReportThreadRunning() const { return true; }
|
|
||||||
virtual void dcDownloadReportThreadFinalize() {}
|
|
||||||
virtual void dcDownloadReportThreadQuit() {}
|
|
||||||
virtual bool dcDownloadReportThreadFinished() const { return true; }
|
|
||||||
|
|
||||||
|
|
||||||
virtual QString dcDownloadFileName() const { return ""; }
|
signals:
|
||||||
virtual bool dcDownloadSetRequested(bool requested) {
|
virtual void hwapi_templatePrintFinished_OK(void) const=0;
|
||||||
Q_UNUSED(requested); return false;
|
virtual void hwapi_templatePrintFinished_Err(void) const=0;
|
||||||
}
|
|
||||||
virtual bool dcDownloadSetRunning(bool running) {
|
|
||||||
Q_UNUSED(running); return false;
|
|
||||||
}
|
|
||||||
virtual bool dcDownloadSetFinished(bool finished) {
|
|
||||||
Q_UNUSED(finished); return false;
|
|
||||||
}
|
|
||||||
virtual void dcDownloadSetTotalBlockNumber(uint16_t totalBlockNumber) {
|
|
||||||
Q_UNUSED(totalBlockNumber);
|
|
||||||
}
|
|
||||||
virtual void dcDownloadSetCurrentBlockNumber(uint16_t currentBlockNumber) {
|
|
||||||
Q_UNUSED(currentBlockNumber);
|
|
||||||
}
|
|
||||||
virtual bool dcDownloadGetRequested() const { return false; }
|
|
||||||
virtual bool dcDownloadGetRunning() const { return false; }
|
|
||||||
virtual bool dcDownloadGetFinished() const { return false; }
|
|
||||||
virtual uint16_t dcDownloadGetTotalBlockNumber() const { return 0; }
|
|
||||||
virtual uint16_t dcDownloadGetCurrentBlockNumber() const { return 0; }
|
|
||||||
|
|
||||||
virtual QObject const *getAPI() { return nullptr; }
|
virtual void hwapi_coinCollectionJustStarted(void) const=0;
|
||||||
|
virtual void hwapi_coinCollectionAborted(void) const=0;
|
||||||
|
|
||||||
|
virtual void hwapi_gotNewCoin(void) const=0;
|
||||||
|
virtual void hwapi_payStopByMax(void) const=0;
|
||||||
|
virtual void hwapi_payStopByPushbutton(void) const=0;
|
||||||
|
|
||||||
|
virtual void hwapi_payStopByEscrow(void) const=0;
|
||||||
|
virtual void hwapi_payStopByError(void) const=0;
|
||||||
|
virtual void hwapi_payStopByTimeout(void) const=0;
|
||||||
|
virtual void hwapi_payCancelled(void) const=0;
|
||||||
|
virtual void hwapi_coinProcessJustStopped(void) const=0;
|
||||||
|
|
||||||
|
virtual void hwapi_doorServiceDoorOpened(void) const=0;
|
||||||
|
virtual void hwapi_doorVaultDoorOpened(void) const=0;
|
||||||
|
virtual void hwapi_doorCoinBoxRemoved(void) const=0;
|
||||||
|
virtual void hwapi_doorCoinBoxInserted(void) const=0;
|
||||||
|
virtual void hwapi_doorCBinAndAllDoorsClosed(void) const=0;
|
||||||
|
virtual void hwapi_doorAllDoorsClosed(void) const=0;
|
||||||
|
|
||||||
signals: // for download
|
|
||||||
void hwapi_reportDCDownloadStatus(QString const&) const;
|
|
||||||
void hwapi_reportDCDownloadSuccess(QString const&) const;
|
|
||||||
void hwapi_reportDCDownloadFailure(QString const&) const;
|
|
||||||
|
|
||||||
// NOTE: declaring a "pure virtual" "signal" should be an error and thus not valid.
|
// NOTE: declaring a "pure virtual" "signal" should be an error and thus not valid.
|
||||||
|
/* GH Version, bringt Fehler
|
||||||
void hwapi_templatePrintFinished_OK() const;
|
void hwapi_templatePrintFinished_OK() const;
|
||||||
void hwapi_templatePrintFinished_Err() const;
|
void hwapi_templatePrintFinished_Err() const;
|
||||||
|
|
||||||
@@ -2354,6 +2324,7 @@ signals: // for download
|
|||||||
void hwapi_doorCoinBoxInserted() const;
|
void hwapi_doorCoinBoxInserted() const;
|
||||||
void hwapi_doorCBinAndAllDoorsClosed() const;
|
void hwapi_doorCBinAndAllDoorsClosed() const;
|
||||||
void hwapi_doorAllDoorsClosed() const;
|
void hwapi_doorAllDoorsClosed() const;
|
||||||
|
*/
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
|
@@ -156,15 +156,6 @@ void MainWindow::onQuit() {
|
|||||||
m_exitTimer->stop();
|
m_exitTimer->stop();
|
||||||
int errorCode = 0;
|
int errorCode = 0;
|
||||||
|
|
||||||
Update *update = m_worker->update();
|
|
||||||
if (update) {
|
|
||||||
hwinf *hw = update->hw();
|
|
||||||
if (hw) {
|
|
||||||
hw->dcDownloadReportFinished();
|
|
||||||
hw->dcDownloadFinished();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
qCritical()
|
qCritical()
|
||||||
<< QString("ON QUIT: CURRENT STEP %1")
|
<< QString("ON QUIT: CURRENT STEP %1")
|
||||||
.arg(m_worker->getSmap()[m_worker->currentStep()]);
|
.arg(m_worker->getSmap()[m_worker->currentStep()]);
|
||||||
|
@@ -2,7 +2,6 @@
|
|||||||
#define INTERFACE_H
|
#define INTERFACE_H
|
||||||
|
|
||||||
#include <QtPlugin>
|
#include <QtPlugin>
|
||||||
#include <QString>
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -398,8 +397,6 @@ struct T_bna
|
|||||||
|
|
||||||
};
|
};
|
||||||
|
|
||||||
class hwapi;
|
|
||||||
class DownloadThread;
|
|
||||||
class hwinf
|
class hwinf
|
||||||
{
|
{
|
||||||
|
|
||||||
@@ -1837,9 +1834,6 @@ public:
|
|||||||
virtual uint8_t prn_getPrintResult() const {
|
virtual uint8_t prn_getPrintResult() const {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
// return: 0: just printing, wait
|
|
||||||
// 1: OK - last print was succesful
|
|
||||||
// 2: error - not printed
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -2276,61 +2270,9 @@ public:
|
|||||||
// countOfBills[1] for 10€ and so on
|
// countOfBills[1] for 10€ and so on
|
||||||
|
|
||||||
|
|
||||||
// download device controller
|
|
||||||
virtual bool dcDownloadRequest(QString const &fileToDownload) const {
|
|
||||||
Q_UNUSED(fileToDownload);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
virtual bool dcDownloadRequested() const { return false; }
|
|
||||||
virtual bool dcDownloadResetRequest() const { return false; }
|
|
||||||
virtual bool dcDownloadRequestAck() const { return false; }
|
|
||||||
virtual bool dcDownloadRunning() const { return false; }
|
|
||||||
virtual bool dcDownloadFinished() { return false; }
|
|
||||||
|
|
||||||
virtual bool dcDownloadReportStart() const { return false; }
|
|
||||||
virtual bool dcDownloadReportRunning() const { return true; }
|
|
||||||
virtual bool dcDownloadReportFinished() { return true; }
|
|
||||||
|
|
||||||
virtual bool dcDownloadThreadStart() { return false; }
|
|
||||||
virtual bool dcDownloadThreadRunning() const { return true; }
|
|
||||||
virtual void dcDownloadThreadFinalize(DownloadThread *) {}
|
|
||||||
virtual bool dcDownloadThreadFinished() const { return true; }
|
|
||||||
virtual bool dcDownloadReportThreadStart() { return false; }
|
|
||||||
virtual bool dcDownloadReportThreadRunning() const { return true; }
|
|
||||||
virtual void dcDownloadReportThreadFinalize() {}
|
|
||||||
virtual void dcDownloadReportThreadQuit() {}
|
|
||||||
virtual bool dcDownloadReportThreadFinished() const { return true; }
|
|
||||||
|
|
||||||
|
|
||||||
virtual QString dcDownloadFileName() const { return ""; }
|
signals:
|
||||||
virtual bool dcDownloadSetRequested(bool requested) {
|
|
||||||
Q_UNUSED(requested); return false;
|
|
||||||
}
|
|
||||||
virtual bool dcDownloadSetRunning(bool running) {
|
|
||||||
Q_UNUSED(running); return false;
|
|
||||||
}
|
|
||||||
virtual bool dcDownloadSetFinished(bool finished) {
|
|
||||||
Q_UNUSED(finished); return false;
|
|
||||||
}
|
|
||||||
virtual void dcDownloadSetTotalBlockNumber(uint16_t totalBlockNumber) {
|
|
||||||
Q_UNUSED(totalBlockNumber);
|
|
||||||
}
|
|
||||||
virtual void dcDownloadSetCurrentBlockNumber(uint16_t currentBlockNumber) {
|
|
||||||
Q_UNUSED(currentBlockNumber);
|
|
||||||
}
|
|
||||||
virtual bool dcDownloadGetRequested() const { return false; }
|
|
||||||
virtual bool dcDownloadGetRunning() const { return false; }
|
|
||||||
virtual bool dcDownloadGetFinished() const { return false; }
|
|
||||||
virtual uint16_t dcDownloadGetTotalBlockNumber() const { return 0; }
|
|
||||||
virtual uint16_t dcDownloadGetCurrentBlockNumber() const { return 0; }
|
|
||||||
|
|
||||||
virtual QObject const *getAPI() { return nullptr; }
|
|
||||||
|
|
||||||
signals: // for download
|
|
||||||
void hwapi_reportDCDownloadStatus(QString const&) const;
|
|
||||||
void hwapi_reportDCDownloadSuccess(QString const&) const;
|
|
||||||
void hwapi_reportDCDownloadFailure(QString const&) const;
|
|
||||||
|
|
||||||
// NOTE: declaring a "pure virtual" "signal" should be an error and thus not valid.
|
// NOTE: declaring a "pure virtual" "signal" should be an error and thus not valid.
|
||||||
void hwapi_templatePrintFinished_OK() const;
|
void hwapi_templatePrintFinished_OK() const;
|
||||||
void hwapi_templatePrintFinished_Err() const;
|
void hwapi_templatePrintFinished_Err() const;
|
||||||
|
88
update.cpp
88
update.cpp
@@ -94,7 +94,6 @@ bool Update::unloadDCPlugin() {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
class hwapi;
|
|
||||||
Update::Update(Worker *worker,
|
Update::Update(Worker *worker,
|
||||||
QString customerRepository,
|
QString customerRepository,
|
||||||
QString customerNrStr,
|
QString customerNrStr,
|
||||||
@@ -131,44 +130,18 @@ Update::Update(Worker *worker,
|
|||||||
|
|
||||||
qCritical() << "UPDATE: m_sys_areDCDataValid ..." << m_sys_areDCdataValid;
|
qCritical() << "UPDATE: m_sys_areDCDataValid ..." << m_sys_areDCdataValid;
|
||||||
|
|
||||||
QObject const *obj = m_hw->getAPI();
|
//qInfo() << "UPDATE: m_serialInterface ..." << m_serialInterface;
|
||||||
// QObject const *obj = (QObject const *)(hw);
|
//qInfo() << "UPDATE: m_baudrate ..." << m_baudrate;
|
||||||
|
//qInfo() << "UPDATE: m_customerRepository ..." << m_customerRepository;
|
||||||
if (!connect(obj,
|
//qInfo() << "UPDATE: m_customerNr ..........." << m_customerNrStr;
|
||||||
SIGNAL(hwapi_reportDCDownloadStatus(QString const&)), this,
|
//qInfo() << "UPDATE: m_branchName ..........." << m_branchName;
|
||||||
SLOT(onReportDCDownloadStatus(QString const &)))) {
|
//qInfo() << "UPDATE: m_pluginName ..........." << m_pluginName;
|
||||||
qCritical() << "ERROR connect() to onReportDCDownloadStatus() failed";
|
//qInfo() << "UPDATE: m_workingDirectory ....." << m_workingDir;
|
||||||
}
|
|
||||||
if (!connect(obj,
|
|
||||||
SIGNAL(hwapi_reportDCDownloadSuccess(QString const&)), this,
|
|
||||||
SLOT(onReportDCDownloadSuccess(QString const &)))) {
|
|
||||||
qCritical() << "ERROR connect() to onReportDCDownloadSuccess() failed";
|
|
||||||
}
|
|
||||||
if (!connect(obj,
|
|
||||||
SIGNAL(hwapi_reportDCDownloadFailure(QString const &)), this,
|
|
||||||
SLOT(onReportDCDownloadFailure(QString const &)))) {
|
|
||||||
qCritical() << "ERROR connect() to onReportDCDownloadFailure() failed";
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
Update::~Update() {
|
Update::~Update() {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
void Update::onReportDCDownloadStatus(QString const &status) {
|
|
||||||
emit m_worker->showStatusMessage("DL", status);
|
|
||||||
}
|
|
||||||
|
|
||||||
void Update::onReportDCDownloadSuccess(QString const &msg) {
|
|
||||||
qCritical() << "msg" << msg;
|
|
||||||
}
|
|
||||||
|
|
||||||
void Update::onReportDCDownloadFailure(QString const &errorMsg) {
|
|
||||||
qCritical() << "msg" << errorMsg;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// br is a index into a table, used for historical reasons.
|
// br is a index into a table, used for historical reasons.
|
||||||
bool Update::openSerial(int br, QString baudrate, QString comPort) const {
|
bool Update::openSerial(int br, QString baudrate, QString comPort) const {
|
||||||
qDebug() << "opening serial" << br << baudrate << comPort << "...";
|
qDebug() << "opening serial" << br << baudrate << comPort << "...";
|
||||||
@@ -528,57 +501,16 @@ bool Update::doUpdate(int &displayIndex, QStringList const &filesToWorkOn) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
bool res = false;
|
bool res = false;
|
||||||
bool dcDownloadPossible = true;
|
|
||||||
|
|
||||||
QList<QString>::const_iterator it;
|
QList<QString>::const_iterator it;
|
||||||
for (it = filesToWorkOn.cbegin(); it != filesToWorkOn.cend(); ++it) {
|
for (it = filesToWorkOn.cbegin(); it != filesToWorkOn.cend(); ++it) {
|
||||||
m_worker->startProgressLoop();
|
m_worker->startProgressLoop();
|
||||||
QString const &fToWorkOn = QDir::cleanPath(m_customerRepository + QDir::separator() + it->trimmed());
|
QString const &fToWorkOn = QDir::cleanPath(m_customerRepository + QDir::separator() + it->trimmed());
|
||||||
static const QRegularExpression version("^.*dc2c[.][0-9]{1,2}[.][0-9]{1,2}[.]bin.*$");
|
static const QRegularExpression version("^.*dc2c[.][0-9]{1,2}[.][0-9]{1,2}[.]bin.*$");
|
||||||
qCritical() << "ABOUT TO START REPORTING THREAD (1)" << fToWorkOn;
|
if (fToWorkOn.contains(version)) {
|
||||||
if (fToWorkOn.contains(version) && dcDownloadPossible) {
|
|
||||||
// download for dc possible only once
|
|
||||||
dcDownloadPossible = false;
|
|
||||||
|
|
||||||
m_hw->dcDownloadRequest(fToWorkOn); // initiate download process
|
|
||||||
|
|
||||||
// test
|
|
||||||
m_hw->dcDownloadThreadStart();
|
|
||||||
|
|
||||||
if (!m_hw->dcDownloadRunning()) { // may take some time
|
|
||||||
qCritical() << QDateTime::currentDateTime() << __PRETTY_FUNCTION__
|
|
||||||
<< QString("line=%1 DOWNLOAD NOT RUNNING").arg(__LINE__);
|
|
||||||
continue; // wait for reporting thread to start
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!m_hw->dcDownloadReportThreadStart()) { // may take some time
|
|
||||||
qCritical() << QDateTime::currentDateTime() << __PRETTY_FUNCTION__
|
|
||||||
<< QString("line=%1 REPORT THREAD NOT RUNNING").arg(__LINE__);
|
|
||||||
continue; // wait for reporting thread to start
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!m_hw->dcDownloadReportRunning()) { // may take some time
|
|
||||||
qCritical() << QDateTime::currentDateTime() << __PRETTY_FUNCTION__
|
|
||||||
<< QString("line=%1 DOWNLOAD REPORT NOT RUNNING").arg(__LINE__);
|
|
||||||
continue; // reporting events from download thread
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!m_hw->dcDownloadReportFinished()) { // may take some time
|
|
||||||
qCritical() << QDateTime::currentDateTime() << __PRETTY_FUNCTION__
|
|
||||||
<< QString("line=%1 DOWNLOAD REPORT THREAD DID NOT FINISH").arg(__LINE__);
|
|
||||||
m_hw->dcDownloadReportThreadQuit();
|
|
||||||
continue; // wait for download thread to finish
|
|
||||||
}
|
|
||||||
|
|
||||||
qCritical() << QDateTime::currentDateTime() << __PRETTY_FUNCTION__
|
|
||||||
<< QString("line=%1 DOWNLOAD SUCCESS").arg(__LINE__);
|
|
||||||
|
|
||||||
bool updateBinaryRes = true;
|
bool updateBinaryRes = true;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// CONSOLE()
|
// CONSOLE()
|
||||||
#if 0
|
|
||||||
m_hw->dc_autoRequest(false);// default: turn auto-request setting off
|
m_hw->dc_autoRequest(false);// default: turn auto-request setting off
|
||||||
QThread::sleep(1); // wait to be sure that there are no more
|
QThread::sleep(1); // wait to be sure that there are no more
|
||||||
// commands sent to dc-hardware
|
// commands sent to dc-hardware
|
||||||
@@ -607,7 +539,7 @@ bool Update::doUpdate(int &displayIndex, QStringList const &filesToWorkOn) {
|
|||||||
qInfo() << "dc-firmware-version (NOT UPDATED)" << versions[1];
|
qInfo() << "dc-firmware-version (NOT UPDATED)" << versions[1];
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
res = updateBinaryRes;
|
res = updateBinaryRes;
|
||||||
|
|
||||||
} else if (fToWorkOn.contains("DC2C_print", Qt::CaseInsensitive)
|
} else if (fToWorkOn.contains("DC2C_print", Qt::CaseInsensitive)
|
||||||
|
3
update.h
3
update.h
@@ -92,9 +92,6 @@ private slots:
|
|||||||
void readyReadStandardOutput();
|
void readyReadStandardOutput();
|
||||||
void readyReadStandardError();
|
void readyReadStandardError();
|
||||||
void finished(int exitCode, QProcess::ExitStatus exitStatus);
|
void finished(int exitCode, QProcess::ExitStatus exitStatus);
|
||||||
void onReportDCDownloadStatus(QString const &status);
|
|
||||||
void onReportDCDownloadSuccess(QString const &msg);
|
|
||||||
void onReportDCDownloadFailure(QString const &errorMsg);
|
|
||||||
|
|
||||||
};
|
};
|
||||||
#endif // UPDATE_H_INCLUDED
|
#endif // UPDATE_H_INCLUDED
|
||||||
|
39
worker.cpp
39
worker.cpp
@@ -157,14 +157,7 @@ Worker::Worker(int customerNr,
|
|||||||
, m_updateProcessRunning(true)
|
, m_updateProcessRunning(true)
|
||||||
, m_mainWindow(nullptr) /* contains plugin */
|
, m_mainWindow(nullptr) /* contains plugin */
|
||||||
//, m_withoutIsmasDirectPort(true) /* useful for testing */ {
|
//, m_withoutIsmasDirectPort(true) /* useful for testing */ {
|
||||||
, m_withoutIsmasDirectPort(false) /* useful for testing */
|
, m_withoutIsmasDirectPort(false) /* useful for testing */ {
|
||||||
// IMPORTANT: allocate m_update here, otherwise the connects() inside of
|
|
||||||
// Update might not work: keep in mind that worker (this) is a thread without
|
|
||||||
// an own event-loop.
|
|
||||||
, m_update(new Update(this,
|
|
||||||
QDir::cleanPath(m_workingDirectory + QDir::separator() + m_customerNrStr),
|
|
||||||
m_customerNrStr, m_branchName, m_pluginDir,
|
|
||||||
m_pluginName, m_workingDirectory)) {
|
|
||||||
|
|
||||||
// TODO: turn object into singleton
|
// TODO: turn object into singleton
|
||||||
instance = this;
|
instance = this;
|
||||||
@@ -173,15 +166,9 @@ Worker::Worker(int customerNr,
|
|||||||
QDir::setCurrent(m_workingDirectory);
|
QDir::setCurrent(m_workingDirectory);
|
||||||
|
|
||||||
m_apismVersion = getAPISMYoctoVersion();
|
m_apismVersion = getAPISMYoctoVersion();
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
Worker::~Worker() {
|
Worker::~Worker() {
|
||||||
if (m_update) {
|
|
||||||
qCritical() << "DELETE UPDATE";
|
|
||||||
delete m_update;
|
|
||||||
m_update = nullptr;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void Worker::displayProgressInMainWindow(int progress) {
|
void Worker::displayProgressInMainWindow(int progress) {
|
||||||
@@ -740,7 +727,7 @@ bool Worker::execOpkgCommands() {
|
|||||||
if (f.open(QIODevice::ReadOnly)) {
|
if (f.open(QIODevice::ReadOnly)) {
|
||||||
QTextStream in(&f);
|
QTextStream in(&f);
|
||||||
m_opkgCommands.clear();
|
m_opkgCommands.clear();
|
||||||
bool executeOpkgCommandFailed = false;
|
QStringList opkgErrorLst;
|
||||||
while (!in.atEnd()) {
|
while (!in.atEnd()) {
|
||||||
QString line = in.readLine();
|
QString line = in.readLine();
|
||||||
static const QRegularExpression comment("^\\s*#.*$");
|
static const QRegularExpression comment("^\\s*#.*$");
|
||||||
@@ -748,7 +735,7 @@ bool Worker::execOpkgCommands() {
|
|||||||
// found opkg command
|
// found opkg command
|
||||||
QString opkgCommand = line.trimmed();
|
QString opkgCommand = line.trimmed();
|
||||||
if (!executeOpkgCommand(opkgCommand)) {
|
if (!executeOpkgCommand(opkgCommand)) {
|
||||||
executeOpkgCommandFailed = true;
|
opkgErrorLst << opkgCommand;
|
||||||
} else {
|
} else {
|
||||||
QString cmd = "\n " + opkgCommand;
|
QString cmd = "\n " + opkgCommand;
|
||||||
emit appendText(cmd);
|
emit appendText(cmd);
|
||||||
@@ -802,14 +789,15 @@ bool Worker::execOpkgCommands() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
f.close();
|
f.close();
|
||||||
if (!executeOpkgCommandFailed) {
|
if (opkgErrorLst.size() == 0) {
|
||||||
if (m_opkgCommands.size() > 0) {
|
if (m_opkgCommands.size() > 0) {
|
||||||
m_displayIndex = 1;
|
m_displayIndex = 1;
|
||||||
GUI() << UPDATE_STEP::EXEC_OPKG_COMMAND_SUCCESS;
|
ISMAS() << (GUI() << (CONSOLE() << UPDATE_STEP::EXEC_OPKG_COMMAND_SUCCESS));
|
||||||
setProgress(_EXEC_OPKG_COMMAND_SUCCESS);
|
setProgress(_EXEC_OPKG_COMMAND_SUCCESS);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
m_displayIndex = 1;
|
m_displayIndex = 1;
|
||||||
|
ISMAS(opkgErrorLst) << (GUI(opkgErrorLst) << (CONSOLE() << UPDATE_STEP::EXEC_OPKG_COMMAND_FAILURE));
|
||||||
GUI() << UPDATE_STEP::EXEC_OPKG_COMMAND_FAILURE;
|
GUI() << UPDATE_STEP::EXEC_OPKG_COMMAND_FAILURE;
|
||||||
setProgress(_EXEC_OPKG_COMMAND_FAILURE);
|
setProgress(_EXEC_OPKG_COMMAND_FAILURE);
|
||||||
return false;
|
return false;
|
||||||
@@ -832,12 +820,15 @@ bool Worker::downloadFilesToPSAHardware() {
|
|||||||
if (computeFilesToDownload()) {
|
if (computeFilesToDownload()) {
|
||||||
CONSOLE(m_filesToDownload) << UPDATE_STEP::FILES_TO_DOWNLOAD;
|
CONSOLE(m_filesToDownload) << UPDATE_STEP::FILES_TO_DOWNLOAD;
|
||||||
|
|
||||||
//m_update = new Update(this,
|
Update update(this,
|
||||||
// QDir::cleanPath(m_workingDirectory + QDir::separator() + m_customerNrStr),
|
QDir::cleanPath(m_workingDirectory + QDir::separator() + m_customerNrStr),
|
||||||
// m_customerNrStr, m_branchName, m_pluginDir,
|
m_customerNrStr,
|
||||||
// m_pluginName, m_workingDirectory);
|
m_branchName,
|
||||||
|
m_pluginDir,
|
||||||
|
m_pluginName,
|
||||||
|
m_workingDirectory);
|
||||||
|
|
||||||
return m_update->doUpdate(m_displayIndex, m_filesToDownload);
|
return update.doUpdate(m_displayIndex, m_filesToDownload);
|
||||||
} else {
|
} else {
|
||||||
CONSOLE(QStringList("NO FILES TO DOWNLOAD TO PSA-HW")) << UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE;
|
CONSOLE(QStringList("NO FILES TO DOWNLOAD TO PSA-HW")) << UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE;
|
||||||
setProgress(_DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE);
|
setProgress(_DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE);
|
||||||
@@ -857,7 +848,7 @@ bool Worker::syncCustomerRepositoryAndFS() {
|
|||||||
QStringList() << "-c" << "mkdir -p /etc/psa_config /etc/dc /etc/psa_tariff")) {
|
QStringList() << "-c" << "mkdir -p /etc/psa_config /etc/dc /etc/psa_tariff")) {
|
||||||
qCritical() << "COULD NOT EXECUTE '" << md.command() << "' exitCode=(" << md.exitCode() << ")";
|
qCritical() << "COULD NOT EXECUTE '" << md.command() << "' exitCode=(" << md.exitCode() << ")";
|
||||||
}
|
}
|
||||||
QString const params("-v "
|
QString const params("-vvv "
|
||||||
"--recursive "
|
"--recursive "
|
||||||
"--progress "
|
"--progress "
|
||||||
"--checksum "
|
"--checksum "
|
||||||
|
6
worker.h
6
worker.h
@@ -557,8 +557,10 @@ private:
|
|||||||
break;
|
break;
|
||||||
case UPDATE_STEP::EXEC_OPKG_COMMAND_SUCCESS:
|
case UPDATE_STEP::EXEC_OPKG_COMMAND_SUCCESS:
|
||||||
break;
|
break;
|
||||||
case UPDATE_STEP::EXEC_OPKG_COMMAND_FAILURE:
|
case UPDATE_STEP::EXEC_OPKG_COMMAND_FAILURE: {
|
||||||
break;
|
lst << instance->m_debugMsg;
|
||||||
|
Utils::printUpdateStatusMsg(debug, lst);
|
||||||
|
} break;
|
||||||
case UPDATE_STEP::DOWNLOAD_CONFIG_FILE:
|
case UPDATE_STEP::DOWNLOAD_CONFIG_FILE:
|
||||||
break;
|
break;
|
||||||
case UPDATE_STEP::DOWNLOAD_CONFIG_FILE_SUCCESS:
|
case UPDATE_STEP::DOWNLOAD_CONFIG_FILE_SUCCESS:
|
||||||
|
Reference in New Issue
Block a user