Compare commits
No commits in common. "e24022a612ce8044600ccdfda57e594c4e5c3a79" and "0933274c8236b32aa5b1905dfcaed4c7a0db3fe5" have entirely different histories.
e24022a612
...
0933274c82
@ -20,11 +20,7 @@ EXTENDED_VERSION="$${VERSION}-$${GIT_COMMIT}"
|
|||||||
INCLUDEINTERFACES=/opt/ptu5/opt/DCLibraries/include
|
INCLUDEINTERFACES=/opt/ptu5/opt/DCLibraries/include
|
||||||
}
|
}
|
||||||
|
|
||||||
INCLUDEPATH += \
|
INCLUDEPATH += plugins $${INCLUDEINTERFACES} $${_PRO_FILE_PWD_}/../UpdatePTUDevCtrl
|
||||||
plugins \
|
|
||||||
$${INCLUDEINTERFACES} \
|
|
||||||
$${_PRO_FILE_PWD_}/../UpdatePTUDevCtrl \
|
|
||||||
$${_PRO_FILE_PWD_}/../../ATBUpdateTool/common/include
|
|
||||||
|
|
||||||
CONFIG += c++17
|
CONFIG += c++17
|
||||||
|
|
||||||
@ -80,14 +76,12 @@ SOURCES += \
|
|||||||
main.cpp \
|
main.cpp \
|
||||||
../UpdatePTUDevCtrl/message_handler.cpp \
|
../UpdatePTUDevCtrl/message_handler.cpp \
|
||||||
../UpdatePTUDevCtrl/commandline_parser.cpp \
|
../UpdatePTUDevCtrl/commandline_parser.cpp \
|
||||||
update.cpp \
|
update.cpp
|
||||||
../../ATBUpdateTool/common/src/System.cpp
|
|
||||||
|
|
||||||
HEADERS += \
|
HEADERS += \
|
||||||
../UpdatePTUDevCtrl/message_handler.h \
|
../UpdatePTUDevCtrl/message_handler.h \
|
||||||
../UpdatePTUDevCtrl/commandline_parser.h \
|
../UpdatePTUDevCtrl/commandline_parser.h \
|
||||||
update.h \
|
update.h
|
||||||
../../ATBUpdateTool/common/include/System.h
|
|
||||||
|
|
||||||
OTHER_FILES += \
|
OTHER_FILES += \
|
||||||
ATBDownloadDCJsonFiles.ini
|
ATBDownloadDCJsonFiles.ini
|
||||||
|
@ -230,64 +230,6 @@ bool Update::doUpdate(QStringList const &filesToWorkOn) {
|
|||||||
return res;
|
return res;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool Update::checkDownloadedJsonVersions(QStringList const& jsonFileNames) {
|
|
||||||
for (QStringList::size_type i=0; i < jsonFileNames.size(); ++i) {
|
|
||||||
|
|
||||||
uint8_t jsonNr = 0;
|
|
||||||
|
|
||||||
QString const &fName = jsonFileNames[i];
|
|
||||||
|
|
||||||
if (fName.endsWith("conf.json")) {
|
|
||||||
jsonNr = 1;
|
|
||||||
} else
|
|
||||||
if (fName.endsWith("device.json")) {
|
|
||||||
jsonNr = 2;
|
|
||||||
} else
|
|
||||||
if (fName.endsWith("cash.json")) {
|
|
||||||
jsonNr = 3;
|
|
||||||
} else {
|
|
||||||
QRegularExpressionMatch match;
|
|
||||||
static const QRegularExpression re("^(.*print)([0-3][0-9])\\.json\\s*$");
|
|
||||||
int idx = fName.indexOf(re, 0, &match);
|
|
||||||
if (idx != -1) {
|
|
||||||
QString captured = match.captured(match.lastCapturedIndex());
|
|
||||||
bool ok = false;
|
|
||||||
int n = captured.toInt(&ok);
|
|
||||||
if (ok) {
|
|
||||||
jsonNr = n + 4;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (jsonNr != 0) {
|
|
||||||
#if 0
|
|
||||||
m_hw->sys_requestJsonVersions(jsonNr);
|
|
||||||
QThread::msleep(500);
|
|
||||||
|
|
||||||
char buf[64];
|
|
||||||
memset(buf, 0x00, sizeof(buf));
|
|
||||||
m_hw->sys_getJsonVersions(jsonNr, buf);
|
|
||||||
buf[sizeof(buf)-1] = '\0';
|
|
||||||
|
|
||||||
QString const installedVersion(buf);
|
|
||||||
QString const fileVersion = getFileVersion(jsonFileNames[i]);
|
|
||||||
|
|
||||||
qCritical() << "installed version:" << installedVersion;
|
|
||||||
qCritical() << " file version:" << fileVersion;
|
|
||||||
|
|
||||||
if (installedVersion == fileVersion) {
|
|
||||||
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
|
|
||||||
} else {
|
|
||||||
qCritical() << "CANNOT FIND JSON-NR FOR" << fName;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
bool Update::downloadJson(enum FileTypeJson type,
|
bool Update::downloadJson(enum FileTypeJson type,
|
||||||
int templateIdx,
|
int templateIdx,
|
||||||
QString jsFileToSendToDC) const {
|
QString jsFileToSendToDC) const {
|
||||||
|
@ -66,8 +66,6 @@ public:
|
|||||||
bool downloadJson(enum FileTypeJson type, int templateIdx,
|
bool downloadJson(enum FileTypeJson type, int templateIdx,
|
||||||
QString jsFileToSendToDC) const;
|
QString jsFileToSendToDC) const;
|
||||||
|
|
||||||
|
|
||||||
bool checkDownloadedJsonVersions(QStringList const& jsonFileNames);
|
|
||||||
/*
|
/*
|
||||||
bool checkDownloadedJsonVersions(QStringList const& jsonFileNames);
|
bool checkDownloadedJsonVersions(QStringList const& jsonFileNames);
|
||||||
|
|
||||||
|
@ -116,10 +116,7 @@ DEFINES += QT_DEPRECATED_WARNINGS
|
|||||||
# 1.4.5 : In case a new branch has been created in a remote
|
# 1.4.5 : In case a new branch has been created in a remote
|
||||||
# customer-repository (e.g. origin/zg1/zone101), then fetch/pull
|
# customer-repository (e.g. origin/zg1/zone101), then fetch/pull
|
||||||
# this branch before switching to this now locally existen branch.
|
# this branch before switching to this now locally existen branch.
|
||||||
# : Improve output of GUI/Console and messages sent to ISMAS.
|
VERSION="1.4.5"
|
||||||
# : Fix: do not send the json-files to dc in any case. Bug introduced
|
|
||||||
# when pulling new branch, but branch already existed locally.
|
|
||||||
VERSION="1.4.6"
|
|
||||||
# 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.
|
||||||
# 2: Wenn der WAIT-Button aktiv ist, dann wird ein Repository repariert (neu
|
# 2: Wenn der WAIT-Button aktiv ist, dann wird ein Repository repariert (neu
|
||||||
|
@ -193,7 +193,7 @@ QStringList GitClient::gitShowReason(QString branchName) {
|
|||||||
int const m = s.indexOf("m=");
|
int const m = s.indexOf("m=");
|
||||||
int const d = s.indexOf("d=");
|
int const d = s.indexOf("d=");
|
||||||
|
|
||||||
QString msg{""}; // IsmasClient::getReasonForLastSendVersion();
|
QString msg = IsmasClient::getReasonForLastSendVersion();
|
||||||
QString commit{""}, date{""};
|
QString commit{""}, date{""};
|
||||||
|
|
||||||
if (c != -1) {
|
if (c != -1) {
|
||||||
@ -205,9 +205,9 @@ QStringList GitClient::gitShowReason(QString branchName) {
|
|||||||
start = m + 2;
|
start = m + 2;
|
||||||
if (d >= start) {
|
if (d >= start) {
|
||||||
length = d - start;
|
length = d - start;
|
||||||
// msg = " (";
|
msg += " (";
|
||||||
msg = s.mid(start, length).trimmed();
|
msg = s.mid(start, length).trimmed();
|
||||||
// msg += ")";
|
msg += ")";
|
||||||
|
|
||||||
start = d + 2;
|
start = d + 2;
|
||||||
date = s.mid(start);
|
date = s.mid(start);
|
||||||
|
@ -384,7 +384,7 @@ QString IsmasClient::errorBackendNotConnected(QString const &info,
|
|||||||
QString const &version) {
|
QString const &version) {
|
||||||
return updateNewsToIsmas("U0003",
|
return updateNewsToIsmas("U0003",
|
||||||
m_progressInPercent,
|
m_progressInPercent,
|
||||||
RESULT_CODE::ISMAS_NO_CONNECTION_ERROR,
|
RESULT_CODE::INSTALL_ERROR,
|
||||||
"CHECK BACKEND CONNECTIVITY",
|
"CHECK BACKEND CONNECTIVITY",
|
||||||
info.toStdString().c_str(),
|
info.toStdString().c_str(),
|
||||||
version.toStdString().c_str());
|
version.toStdString().c_str());
|
||||||
@ -394,7 +394,7 @@ QString IsmasClient::errorGitClone(QString const &info,
|
|||||||
QString const &version) {
|
QString const &version) {
|
||||||
return updateNewsToIsmas("U0003",
|
return updateNewsToIsmas("U0003",
|
||||||
m_progressInPercent,
|
m_progressInPercent,
|
||||||
RESULT_CODE::GIT_CLONE_ERROR,
|
RESULT_CODE::INSTALL_ERROR,
|
||||||
"CLONE CUSTOMER REPOSITORY FAILED",
|
"CLONE CUSTOMER REPOSITORY FAILED",
|
||||||
info.toStdString().c_str(),
|
info.toStdString().c_str(),
|
||||||
version.toStdString().c_str());
|
version.toStdString().c_str());
|
||||||
@ -442,7 +442,7 @@ QString IsmasClient::updateTriggerSet(QString const &info, QString const &versio
|
|||||||
QString IsmasClient::errorUpdateTrigger(QString const &info, QString const &version) {
|
QString IsmasClient::errorUpdateTrigger(QString const &info, QString const &version) {
|
||||||
return updateNewsToIsmas("U0003",
|
return updateNewsToIsmas("U0003",
|
||||||
m_progressInPercent,
|
m_progressInPercent,
|
||||||
RESULT_CODE::ISMAS_TRIGGER_ERROR,
|
RESULT_CODE::INSTALL_ERROR,
|
||||||
"CHECK UPDATE TRIGGER",
|
"CHECK UPDATE TRIGGER",
|
||||||
info.toStdString().c_str(),
|
info.toStdString().c_str(),
|
||||||
version.toStdString().c_str());
|
version.toStdString().c_str());
|
||||||
|
@ -145,47 +145,13 @@ public:
|
|||||||
DIRECT_PORT = 7778
|
DIRECT_PORT = 7778
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
enum RESULT_CODE {
|
enum RESULT_CODE {
|
||||||
SUCCESS=0,
|
SUCCESS=0,
|
||||||
// if between 00:00 - 04:00 Wait-button state not WAIT, then we assume
|
|
||||||
// that's an automatic nightly (not-necessary) update
|
|
||||||
NO_UPDATE_NECESSARY=1,
|
NO_UPDATE_NECESSARY=1,
|
||||||
// if APISM reports the ISMAS is not available (15x, 6s delay each)
|
BACKUP_FAILED=2,
|
||||||
ISMAS_NO_CONNECTION_ERROR=2,
|
WRONG_PACKAGE=3,
|
||||||
// if not within 00:00-04:00 and WAIT-button was not in state WAIT
|
INSTALL_ERROR=4};
|
||||||
ISMAS_TRIGGER_ERROR=3,
|
|
||||||
// cloning git repo. not possible
|
|
||||||
GIT_CLONE_ERROR=4,
|
|
||||||
// pulling from remote git server not possible
|
|
||||||
GIT_PULL_ERROR=5,
|
|
||||||
// fetching from remote git server not possible
|
|
||||||
GIT_FETCH_ERROR=6,
|
|
||||||
// merging fetched data not possible
|
|
||||||
GIT_MERGE_ERROR=7,
|
|
||||||
// check sanity of local customer-repository failed
|
|
||||||
GIT_CHECK_REPOSITORY_ERROR=8,
|
|
||||||
// switch/checkout of branch (i.e. zone) on error
|
|
||||||
GIT_SWITCH_BRANCH_ERROR=9,
|
|
||||||
// fetch/pull of new branch failed. the new branch was not available
|
|
||||||
// when installing via SD-card followed by intial clone during the
|
|
||||||
// update process.
|
|
||||||
GIT_FETCH_NEW_BRANCH_ERROR=10,
|
|
||||||
// error computing git-blob hash-value
|
|
||||||
GIT_HASH_ERROR=11,
|
|
||||||
// update for general json files failed.
|
|
||||||
JSON_FILES_UPDATE_ERROR=12,
|
|
||||||
// error downloading config-json-files to device controller
|
|
||||||
JSON_FILES_DOWNLOAD_ERROR=13,
|
|
||||||
// error downloading device-controller
|
|
||||||
DC_DOWNLOAD_ERROR=14,
|
|
||||||
// error rsyncing json/ini-files to local filesystem
|
|
||||||
RSYN_ERROR=15,
|
|
||||||
// HASH_VALUE_ERROR=14,
|
|
||||||
// HW_COMPATIBILITY_ERROR=15,
|
|
||||||
OPKG_COMMANDS_ERROR=16,
|
|
||||||
// CLEANUP_ERROR=18,
|
|
||||||
UPDATE_IN_ERROR_STATE=99
|
|
||||||
};
|
|
||||||
|
|
||||||
enum REASON {
|
enum REASON {
|
||||||
TIME_TRIGGERED = 0,
|
TIME_TRIGGERED = 0,
|
||||||
|
@ -44,7 +44,6 @@ QString Utils::getLocation(QString fileName) {
|
|||||||
if (c != -1) {
|
if (c != -1) {
|
||||||
location = line.mid(c+1);
|
location = line.mid(c+1);
|
||||||
if (!location.isEmpty()) {
|
if (!location.isEmpty()) {
|
||||||
location = location.replace(QChar(','), QString(""));
|
|
||||||
return location.replace(QChar('"'), QString("")).trimmed();
|
return location.replace(QChar('"'), QString("")).trimmed();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -70,7 +69,6 @@ QString Utils::getTariffVersion(QString fileName) {
|
|||||||
if (c != -1) {
|
if (c != -1) {
|
||||||
version = line.mid(c+1);
|
version = line.mid(c+1);
|
||||||
if (!version.isEmpty()) {
|
if (!version.isEmpty()) {
|
||||||
version = version.replace(QChar(','), QString(""));
|
|
||||||
return version.replace(QChar('"'), QString("")).trimmed();
|
return version.replace(QChar('"'), QString("")).trimmed();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -96,7 +94,6 @@ QString Utils::getTariffInfo(QString fileName) {
|
|||||||
if (c != -1) {
|
if (c != -1) {
|
||||||
info = line.mid(c+1);
|
info = line.mid(c+1);
|
||||||
if (!info.isEmpty()) {
|
if (!info.isEmpty()) {
|
||||||
info = info.replace(QChar(','), QString(""));
|
|
||||||
return info.replace(QChar('"'), QString("")).trimmed();
|
return info.replace(QChar('"'), QString("")).trimmed();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -17,7 +17,6 @@
|
|||||||
#include <QJsonParseError>
|
#include <QJsonParseError>
|
||||||
#include <Qt>
|
#include <Qt>
|
||||||
#include <QScopedPointer>
|
#include <QScopedPointer>
|
||||||
#include <QRegularExpression>
|
|
||||||
|
|
||||||
#include "message_handler.h"
|
#include "message_handler.h"
|
||||||
#include <DeviceController/interfaces.h>
|
#include <DeviceController/interfaces.h>
|
||||||
@ -301,18 +300,13 @@ void Worker::privateUpdate() {
|
|||||||
m_updateNotNecessary = true;
|
m_updateNotNecessary = true;
|
||||||
m_ismasTriggerStatusMessage = QStringList(QString("NO UPDATE NECESSARY (%1)").arg(current.toString(Qt::ISODate)));
|
m_ismasTriggerStatusMessage = QStringList(QString("NO UPDATE NECESSARY (%1)").arg(current.toString(Qt::ISODate)));
|
||||||
|
|
||||||
qCritical() << "privateUpdate m_ismasTriggerStatusMessage:"
|
qCritical() << "privateUpdate m_ismasTriggerStatusMessage:" << QStringList(QString("NO UPDATE NECESSARY (%1)").arg(current.toString(Qt::ISODate)));
|
||||||
<< QStringList(m_ismasTriggerStatusMessage);
|
|
||||||
qCritical() << "***";
|
qCritical() << "***";
|
||||||
|
|
||||||
// the customer-repository does exist, and the ISMAS-trigger is
|
// the customer-repository does exist, but the ISMAS-trigger is
|
||||||
// *NOT* "WAIT", but from 00:00:00 - 00:03:59 this counts as an
|
// *NOT* "WAIT", but from 00:00:00 - 00:03:59 this counts as an
|
||||||
// automatic update
|
// automatic update
|
||||||
|
|
||||||
QStringList lst = m_ismasTriggerStatusMessage;
|
|
||||||
// trigger message to ISMAS and CONSOLE
|
|
||||||
ISMAS(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_SUCCESS));
|
|
||||||
// overwrite m_lastFailedUpdateStep
|
|
||||||
m_lastFailedUpdateStep = UPDATE_STEP::NONE;
|
m_lastFailedUpdateStep = UPDATE_STEP::NONE;
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@ -736,28 +730,29 @@ bool Worker::customerEnvironment() {
|
|||||||
if (QDir(m_customerRepository).exists()) {
|
if (QDir(m_customerRepository).exists()) {
|
||||||
if (m_clone == false) {
|
if (m_clone == false) {
|
||||||
if (m_gc.branchExistsRemotely()) {
|
if (m_gc.branchExistsRemotely()) {
|
||||||
QString msg;
|
QString msg("PULL NEW BRANCH " + m_branchName);
|
||||||
QStringList lst;
|
QStringList lst(msg);
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << UPDATE_STEP::PULL_NEW_BRANCH));
|
||||||
if (!m_gc.branchExistsLocally()) {
|
if (!m_gc.branchExistsLocally()) {
|
||||||
lst.clear();
|
|
||||||
msg = QString("PULLING OF NEW BRANCH " + m_branchName + " DOES NOT EXIST LOCALLY");
|
msg = QString("PULLING OF NEW BRANCH " + m_branchName + " DOES NOT EXIST LOCALLY");
|
||||||
lst << msg;
|
QStringList lst(msg);
|
||||||
CONSOLE(lst) << UPDATE_STEP::PULL_NEW_BRANCH;
|
CONSOLE(lst) << UPDATE_STEP::PULL_NEW_BRANCH;
|
||||||
if (!m_gc.gitPullNewBranches()) {
|
if (!m_gc.gitPullNewBranches()) {
|
||||||
lst.clear();
|
|
||||||
msg = QString("PULLING OF NEW BRANCH " + m_branchName + "FAILED");
|
msg = QString("PULLING OF NEW BRANCH " + m_branchName + "FAILED");
|
||||||
lst << msg;
|
QStringList lst(msg);
|
||||||
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::PULL_NEW_BRANCH_FAILURE)));
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::PULL_NEW_BRANCH_FAILURE)));
|
||||||
return false;
|
return false;
|
||||||
} else {
|
} else {
|
||||||
lst.clear();
|
|
||||||
msg = QString("PULLING OF NEW BRANCH " + m_branchName + "SUCCESS");
|
msg = QString("PULLING OF NEW BRANCH " + m_branchName + "SUCCESS");
|
||||||
lst << msg;
|
QStringList lst(msg);
|
||||||
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS)));
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS)));
|
||||||
m_pulledNewBranch = true;
|
m_pulledNewBranch = true;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
m_pulledNewBranch = false;
|
msg = QString("PULLING ALREADY EXISTING LOCAL BRANCH " + m_branchName + "SUCCESS");
|
||||||
|
QStringList lst(msg);
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS)));
|
||||||
|
m_pulledNewBranch = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -1256,48 +1251,15 @@ PSAInstalled Worker::getPSAInstalled() {
|
|||||||
psaInstalled.versionInfo.created = "N/A";
|
psaInstalled.versionInfo.created = "N/A";
|
||||||
|
|
||||||
if (m_versionInfo.size() == 3) {
|
if (m_versionInfo.size() == 3) {
|
||||||
QString const &lastCommit = m_versionInfo.at(0);
|
qCritical() << QString("***** %1:%2").arg(__func__).arg(__LINE__)
|
||||||
QString reason = m_versionInfo.at(1);
|
<< "m_versionInfo" << m_versionInfo << "*****";
|
||||||
QDateTime const dt = QDateTime::fromString(m_versionInfo.at(2), Qt::ISODate);
|
psaInstalled.versionInfo.lastCommit = QString("%1-%2")
|
||||||
QString version{""};
|
.arg(QCoreApplication::applicationPid())
|
||||||
QString date{""};
|
.arg(m_versionInfo.at(0));
|
||||||
if (dt.isValid()) {
|
psaInstalled.versionInfo.reason = m_versionInfo.at(1);
|
||||||
date += " ";
|
|
||||||
date += dt.date().toString(Qt::ISODate);
|
|
||||||
}
|
|
||||||
static const QRegularExpression re("^\\s*(\\d+)\\.(\\d+)\\.(\\d+)(.*$)");
|
|
||||||
QRegularExpressionMatch match = re.match(reason);
|
|
||||||
if (match.hasMatch()) {
|
|
||||||
int const lastCapturedIndex = match.lastCapturedIndex();
|
|
||||||
if (lastCapturedIndex >= 1) {
|
|
||||||
version += " v";
|
|
||||||
version += match.captured(1); // major
|
|
||||||
}
|
|
||||||
if (lastCapturedIndex >= 2) {
|
|
||||||
version += ".";
|
|
||||||
version += match.captured(2); // minor
|
|
||||||
}
|
|
||||||
if (lastCapturedIndex >= 3) {
|
|
||||||
version += ".";
|
|
||||||
version += match.captured(3); // patch
|
|
||||||
}
|
|
||||||
if (lastCapturedIndex >= 4) { // rest after version
|
|
||||||
reason = match.captured(4);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
psaInstalled.versionInfo.lastCommit = QString("%1%2").arg(lastCommit).arg(version);
|
|
||||||
psaInstalled.versionInfo.reason = reason;
|
|
||||||
psaInstalled.versionInfo.created = m_versionInfo.at(2);
|
psaInstalled.versionInfo.created = m_versionInfo.at(2);
|
||||||
}
|
}
|
||||||
|
|
||||||
//qCritical() << "";
|
|
||||||
//qCritical() << "VERSION-INFO";
|
|
||||||
//qCritical() << "LAST-COMMIT" << psaInstalled.versionInfo.lastCommit;
|
|
||||||
//qCritical() << "REASON" << psaInstalled.versionInfo.reason;
|
|
||||||
//qCritical() << "CREATED" << psaInstalled.versionInfo.created;
|
|
||||||
//qCritical() << "";
|
|
||||||
|
|
||||||
if (m_zoneNr != 0) {
|
if (m_zoneNr != 0) {
|
||||||
QString const &n = QString("%1").arg(m_zoneNr).rightJustified(2, '0');
|
QString const &n = QString("%1").arg(m_zoneNr).rightJustified(2, '0');
|
||||||
psaInstalled.tariff.name = QString("tariff%1.json").arg(n);
|
psaInstalled.tariff.name = QString("tariff%1.json").arg(n);
|
||||||
|
@ -26,21 +26,11 @@
|
|||||||
#define SERIAL_PORT "ttyUSB0"
|
#define SERIAL_PORT "ttyUSB0"
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
/*
|
#define _ISMAS_DONE "U0001" // 100%
|
||||||
Note:
|
#define _ISMAS_SET_WAIT_OK "U0002" // empty WAIT-button ("")
|
||||||
! After U0002 immer ein CMD_SENDVERSION
|
|
||||||
! Only U0002 and U0003 finish the Update process.
|
|
||||||
! U0001: Update finished but not activated
|
|
||||||
! U0002: Update finished and activated
|
|
||||||
! U0003: Update finished but FAILed.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#define _ISMAS_DONE "U0001" // 100%, Check: Resultcode: 0
|
|
||||||
#define _ISMAS_SET_WAIT_OK "U0002" // empty WAIT-button (""), ResultCode: 0
|
|
||||||
#define _ISMAS_FAILURE "U0003" // FAIL
|
#define _ISMAS_FAILURE "U0003" // FAIL
|
||||||
#define _ISMAS_CONTINUE "U0010" // %-values: Update laeuft, Resultcodes entsprechend laufender Schritt
|
#define _ISMAS_CONTINUE "U0010" // %-values
|
||||||
#define _ISMAS_RESET_WAIT "ISMAS" // reset WAIT-button to "WAIT"
|
#define _ISMAS_RESET_WAIT "ISMAS" // reset WAIT-button to "WAIT"
|
||||||
#define _ISMAS_TEST_TRIGGER "U0099" // check the WAIT-button
|
|
||||||
|
|
||||||
#define _STARTED (1)
|
#define _STARTED (1)
|
||||||
#define _CHECK_ISMAS_TRIGGER (2)
|
#define _CHECK_ISMAS_TRIGGER (2)
|
||||||
@ -733,7 +723,7 @@ private:
|
|||||||
}
|
}
|
||||||
|
|
||||||
Worker::instance->m_currentStep = step;
|
Worker::instance->m_currentStep = step;
|
||||||
// QStringList lst = QStringList(smap[step]);
|
QStringList lst = QStringList(smap[step]);
|
||||||
|
|
||||||
switch (step) {
|
switch (step) {
|
||||||
case UPDATE_STEP::NONE: {
|
case UPDATE_STEP::NONE: {
|
||||||
@ -749,15 +739,14 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010
|
"U0010",
|
||||||
_CHECKOUT_REPOSITORY_SUCCESS,
|
_CHECKOUT_REPOSITORY_SUCCESS,
|
||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::CHECK_REPOSITORY],
|
smap[UPDATE_STEP::CHECK_REPOSITORY],
|
||||||
QString("REPOSITORY %1 AND BRANCH %2 OK")
|
QString("REPOSITORY %1 AND BRANCH %2 OK")
|
||||||
.arg(instance->m_customerRepository)
|
.arg(instance->m_customerRepository)
|
||||||
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
@ -766,15 +755,14 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010
|
"U0010",
|
||||||
_CHECKOUT_REPOSITORY_FAILURE,
|
_CHECKOUT_REPOSITORY_FAILURE,
|
||||||
IsmasClient::RESULT_CODE::GIT_SWITCH_BRANCH_ERROR,
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
smap[UPDATE_STEP::CHECKOUT_REPOSITORY],
|
smap[UPDATE_STEP::CHECKOUT_REPOSITORY],
|
||||||
QString("REPOSITORY %1 and BRANCH %2 ***NOT OK***")
|
QString("REPOSITORY %1 and BRANCH %2 ***NOT OK***")
|
||||||
.arg(instance->m_customerRepository)
|
.arg(instance->m_customerRepository)
|
||||||
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
@ -786,15 +774,14 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010
|
"U0010",
|
||||||
_CHECK_SANITY_SUCCESS,
|
_CHECK_SANITY_SUCCESS,
|
||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::CHECK_SANITY],
|
smap[UPDATE_STEP::CHECK_SANITY],
|
||||||
QString("SANITY OF %1 (BRANCH %2) OK")
|
QString("SANITY OF %1 (BRANCH %2) OK")
|
||||||
.arg(instance->m_customerRepository)
|
.arg(instance->m_customerRepository)
|
||||||
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
@ -803,41 +790,39 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010
|
"U0010",
|
||||||
_CHECK_SANITY_FAILURE,
|
_CHECK_SANITY_FAILURE,
|
||||||
IsmasClient::RESULT_CODE::GIT_CHECK_REPOSITORY_ERROR,
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
smap[UPDATE_STEP::CHECK_SANITY],
|
smap[UPDATE_STEP::CHECK_SANITY],
|
||||||
QString("SANITY OF %1 and BRANCH %2 ***NOT*** OK")
|
QString("SANITY OF %1 and BRANCH %2 ***NOT*** OK")
|
||||||
.arg(instance->m_customerRepository)
|
.arg(instance->m_customerRepository)
|
||||||
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
case UPDATE_STEP::REPOSITORY_RECOVERED_SUCCESS: {
|
case UPDATE_STEP::REPOSITORY_RECOVERED_SUCCESS:
|
||||||
ismasClient.setProgressInPercent(_REPOSITORY_RECOVERED_SUCCESS);
|
ismasClient.setProgressInPercent(_REPOSITORY_RECOVERED_SUCCESS);
|
||||||
} break;
|
break;
|
||||||
case UPDATE_STEP::REPOSITORY_RECOVERED_FAILURE: {
|
case UPDATE_STEP::REPOSITORY_RECOVERED_FAILURE:
|
||||||
ismasClient.setProgressInPercent(_REPOSITORY_RECOVERED_FAILURE);
|
ismasClient.setProgressInPercent(_REPOSITORY_RECOVERED_FAILURE);
|
||||||
} break;
|
break;
|
||||||
case UPDATE_STEP::CLONE_REPOSITORY: {
|
case UPDATE_STEP::CLONE_REPOSITORY:
|
||||||
ismasClient.setProgressInPercent(_CLONE_REPOSITORY);
|
ismasClient.setProgressInPercent(_CLONE_REPOSITORY);
|
||||||
} break;
|
break;
|
||||||
case UPDATE_STEP::CLONE_REPOSITORY_SUCCESS: {
|
case UPDATE_STEP::CLONE_REPOSITORY_SUCCESS: {
|
||||||
ismasClient.setProgressInPercent(_CLONE_REPOSITORY_SUCCESS);
|
ismasClient.setProgressInPercent(_CLONE_REPOSITORY_SUCCESS);
|
||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010
|
"U0010",
|
||||||
_CLONE_REPOSITORY_SUCCESS,
|
_CLONE_REPOSITORY_SUCCESS,
|
||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::CLONE_REPOSITORY],
|
smap[UPDATE_STEP::CLONE_REPOSITORY],
|
||||||
QString("CLONED REPOSITORY %1 AND CHECKED OUT BRANCH %2")
|
QString("CLONED REPOSITORY %1 AND CHECKED OUT BRANCH %2")
|
||||||
.arg(instance->m_customerRepository)
|
.arg(instance->m_customerRepository)
|
||||||
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(IsmasClient::APISM::DB_PORT,
|
ismasClient.sendRequestReceiveResponse(IsmasClient::APISM::DB_PORT,
|
||||||
ismasUpdateNews);
|
ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
@ -846,22 +831,21 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010 -> even on error: U0002/3 are sent only once
|
"U0003",
|
||||||
_CLONE_REPOSITORY_FAILURE,
|
_CLONE_REPOSITORY_FAILURE,
|
||||||
IsmasClient::RESULT_CODE::GIT_CLONE_ERROR,
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
smap[UPDATE_STEP::CHECKOUT_REPOSITORY],
|
smap[UPDATE_STEP::CHECKOUT_REPOSITORY],
|
||||||
QString("CLONING REPOSITORY %1 OR CHECKING OUT BRANCH %2 FAILED")
|
QString("CLONING REPOSITORY %1 OR CHECKING OUT BRANCH %2 FAILED")
|
||||||
.arg(instance->m_customerRepository)
|
.arg(instance->m_customerRepository)
|
||||||
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
case UPDATE_STEP::CHECKOUT_REPOSITORY:
|
case UPDATE_STEP::CHECKOUT_REPOSITORY:
|
||||||
ismasClient.setProgressInPercent(_CHECKOUT_REPOSITORY);
|
ismasClient.setProgressInPercent(_CHECKOUT_REPOSITORY);
|
||||||
break;
|
break;
|
||||||
case UPDATE_STEP::CHECKOUT_REPOSITORY_SUCCESS: {
|
case UPDATE_STEP::CHECKOUT_REPOSITORY_SUCCESS:
|
||||||
ismasClient.setProgressInPercent(_CHECKOUT_REPOSITORY_SUCCESS);
|
ismasClient.setProgressInPercent(_CHECKOUT_REPOSITORY_SUCCESS);
|
||||||
ismasClient.sendRequestReceiveResponse(IsmasClient::APISM::DB_PORT,
|
ismasClient.sendRequestReceiveResponse(IsmasClient::APISM::DB_PORT,
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
@ -869,122 +853,55 @@ private:
|
|||||||
QString("CHECKED OUT REPOSITORY %1 AND CHECKED OUT BRANCH %2")
|
QString("CHECKED OUT REPOSITORY %1 AND CHECKED OUT BRANCH %2")
|
||||||
.arg(instance->m_customerRepository)
|
.arg(instance->m_customerRepository)
|
||||||
.arg(instance->m_gc.branchName()),
|
.arg(instance->m_gc.branchName()),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A"));
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A"));
|
break;
|
||||||
} break;
|
case UPDATE_STEP::CHECKOUT_REPOSITORY_FAILURE:
|
||||||
case UPDATE_STEP::CHECKOUT_REPOSITORY_FAILURE: {
|
|
||||||
ismasClient.setProgressInPercent(_CHECKOUT_REPOSITORY_FAILURE);
|
ismasClient.setProgressInPercent(_CHECKOUT_REPOSITORY_FAILURE);
|
||||||
QString const &ismasUpdateNews =
|
break;
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
case UPDATE_STEP::CHECK_ISMAS_TRIGGER:
|
||||||
ismasClient.updateNewsToIsmas(
|
|
||||||
_ISMAS_CONTINUE, // U0010 -> even on error: U0002/3 are sent only once
|
|
||||||
_CHECKOUT_REPOSITORY_FAILURE,
|
|
||||||
IsmasClient::RESULT_CODE::GIT_SWITCH_BRANCH_ERROR,
|
|
||||||
smap[UPDATE_STEP::CHECKOUT_REPOSITORY],
|
|
||||||
QString("%1: CHECKING OUT BRANCH %2 FAILED")
|
|
||||||
.arg(instance->m_customerRepository)
|
|
||||||
.arg(instance->m_gc.branchName()).toStdString().c_str(),
|
|
||||||
instance->m_versionInfo.size() >= 1
|
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
|
||||||
} break;
|
|
||||||
case UPDATE_STEP::CHECK_ISMAS_TRIGGER: {
|
|
||||||
ismasClient.setProgressInPercent(_CHECK_ISMAS_TRIGGER);
|
ismasClient.setProgressInPercent(_CHECK_ISMAS_TRIGGER);
|
||||||
} break;
|
break;
|
||||||
case UPDATE_STEP::CHECK_ISMAS_TRIGGER_SUCCESS: {
|
case UPDATE_STEP::CHECK_ISMAS_TRIGGER_SUCCESS:
|
||||||
ismasClient.setProgressInPercent(_CHECK_ISMAS_TRIGGER_SUCCESS);
|
ismasClient.setProgressInPercent(_CHECK_ISMAS_TRIGGER_SUCCESS);
|
||||||
QString const &ismasUpdateNews =
|
ismasClient.sendRequestReceiveResponse(IsmasClient::APISM::DB_PORT,
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateTriggerSet("ISMAS TRIGGER SET",
|
||||||
_ISMAS_CONTINUE, //
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A"));
|
||||||
_CHECK_ISMAS_TRIGGER_SUCCESS,
|
break;
|
||||||
(instance->m_updateNotNecessary)
|
case UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE:
|
||||||
? IsmasClient::RESULT_CODE::NO_UPDATE_NECESSARY
|
|
||||||
: IsmasClient::RESULT_CODE::SUCCESS,
|
|
||||||
smap[UPDATE_STEP::CHECK_ISMAS_TRIGGER_SUCCESS],
|
|
||||||
instance->m_updateNotNecessary
|
|
||||||
? QString("NO-UPDATE-NECESSARY (%1:%2)")
|
|
||||||
.arg(instance->m_customerRepository)
|
|
||||||
.arg(instance->m_gc.branchName()).toStdString().c_str()
|
|
||||||
: QString("ISMAS-TRIGGER ON WAIT").toStdString().c_str(),
|
|
||||||
instance->m_versionInfo.size() >= 1
|
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
|
||||||
} break;
|
|
||||||
case UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE: {
|
|
||||||
ismasClient.setProgressInPercent(_CHECK_ISMAS_TRIGGER_WRONG_VALUE);
|
ismasClient.setProgressInPercent(_CHECK_ISMAS_TRIGGER_WRONG_VALUE);
|
||||||
QString const &ismasUpdateNews =
|
break;
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
|
||||||
ismasClient.updateNewsToIsmas(
|
|
||||||
_ISMAS_TEST_TRIGGER, // U0099
|
|
||||||
_CHECK_ISMAS_TRIGGER_WRONG_VALUE,
|
|
||||||
IsmasClient::RESULT_CODE::ISMAS_TRIGGER_ERROR,
|
|
||||||
smap[UPDATE_STEP::CHECK_ISMAS_TRIGGER],
|
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
|
||||||
instance->m_versionInfo.size() >= 1
|
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
|
||||||
} break;
|
|
||||||
case UPDATE_STEP::CHECK_ISMAS_TRIGGER_FAILURE: {
|
case UPDATE_STEP::CHECK_ISMAS_TRIGGER_FAILURE: {
|
||||||
ismasClient.setProgressInPercent(_CHECK_ISMAS_TRIGGER_FAILURE);
|
ismasClient.setProgressInPercent(_CHECK_ISMAS_TRIGGER_FAILURE);
|
||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_TEST_TRIGGER, // U0099
|
"U0003",
|
||||||
_CHECK_ISMAS_TRIGGER_FAILURE,
|
_CHECK_ISMAS_TRIGGER_FAILURE,
|
||||||
IsmasClient::RESULT_CODE::ISMAS_TRIGGER_ERROR,
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
smap[UPDATE_STEP::CHECK_ISMAS_TRIGGER],
|
smap[UPDATE_STEP::CHECK_ISMAS_TRIGGER],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
case UPDATE_STEP::INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER: {
|
case UPDATE_STEP::INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER:
|
||||||
ismasClient.setProgressInPercent(_INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER);
|
ismasClient.setProgressInPercent(_INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER);
|
||||||
QString const &ismasUpdateNews =
|
break;
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
case UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER:
|
||||||
ismasClient.updateNewsToIsmas(
|
|
||||||
_ISMAS_CONTINUE, // U0010
|
|
||||||
_INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER,
|
|
||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
|
||||||
smap[UPDATE_STEP::INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER],
|
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
|
||||||
instance->m_versionInfo.size() >= 1
|
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
|
||||||
} break;
|
|
||||||
case UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER: {
|
|
||||||
ismasClient.setProgressInPercent(_INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER);
|
ismasClient.setProgressInPercent(_INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER);
|
||||||
QString const &ismasUpdateNews =
|
break;
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
|
||||||
ismasClient.updateNewsToIsmas(
|
|
||||||
_ISMAS_CONTINUE, // U0010
|
|
||||||
_INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER,
|
|
||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
|
||||||
smap[UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER],
|
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
|
||||||
instance->m_versionInfo.size() >= 1
|
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
|
||||||
} break;
|
|
||||||
case UPDATE_STEP::PULL_NEW_BRANCH: {
|
case UPDATE_STEP::PULL_NEW_BRANCH: {
|
||||||
ismasClient.setProgressInPercent(_PULL_NEW_BRANCH);
|
ismasClient.setProgressInPercent(_PULL_NEW_BRANCH);
|
||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010
|
"U0010",
|
||||||
_PULL_NEW_BRANCH,
|
_PULL_NEW_BRANCH,
|
||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
}
|
}
|
||||||
@ -994,13 +911,12 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010 -> even on error: U0002/3 are sent only once
|
"U0003",
|
||||||
_PULL_NEW_BRANCH_FAILURE,
|
_PULL_NEW_BRANCH_FAILURE,
|
||||||
IsmasClient::RESULT_CODE::GIT_PULL_ERROR,
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
}
|
}
|
||||||
@ -1010,13 +926,12 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_CONTINUE, // U0010
|
"U0010",
|
||||||
_PULL_NEW_BRANCH_SUCCESS,
|
_PULL_NEW_BRANCH_SUCCESS,
|
||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
}
|
}
|
||||||
@ -1031,8 +946,7 @@ private:
|
|||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
@ -1046,8 +960,7 @@ private:
|
|||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
@ -1056,13 +969,12 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_FAILURE, // U0003
|
"U0003",
|
||||||
_CHECKOUT_BRANCH_FAILURE,
|
_CHECKOUT_BRANCH_FAILURE,
|
||||||
IsmasClient::RESULT_CODE::GIT_SWITCH_BRANCH_ERROR,
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
|
||||||
ismasClient.sendRequestReceiveResponse(
|
ismasClient.sendRequestReceiveResponse(
|
||||||
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
} break;
|
} break;
|
||||||
@ -1221,7 +1133,7 @@ private:
|
|||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_FAILURE,
|
_ISMAS_FAILURE,
|
||||||
ismasClient.getProgressInPercent(),
|
ismasClient.getProgressInPercent(),
|
||||||
IsmasClient::RESULT_CODE::OPKG_COMMANDS_ERROR,
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
smap[step],
|
smap[step],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
@ -1339,7 +1251,7 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_SET_WAIT_OK, // U0002
|
_ISMAS_SET_WAIT_OK,
|
||||||
ismasClient.getProgressInPercent(),
|
ismasClient.getProgressInPercent(),
|
||||||
IsmasClient::RESULT_CODE::SUCCESS,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::UPDATE_FINALIZE],
|
smap[UPDATE_STEP::UPDATE_FINALIZE],
|
||||||
@ -1353,9 +1265,9 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_SET_WAIT_OK, // U0002
|
_ISMAS_SET_WAIT_OK,
|
||||||
ismasClient.getProgressInPercent(),
|
ismasClient.getProgressInPercent(),
|
||||||
IsmasClient::RESULT_CODE::NO_UPDATE_NECESSARY,
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
smap[UPDATE_STEP::UPDATE_FINALIZE],
|
smap[UPDATE_STEP::UPDATE_FINALIZE],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
@ -1367,9 +1279,9 @@ private:
|
|||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
QString("#M=APISM#C=CMD_EVENT#J=") +
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
ismasClient.updateNewsToIsmas(
|
ismasClient.updateNewsToIsmas(
|
||||||
_ISMAS_FAILURE, // U0003 is sent only once
|
_ISMAS_FAILURE,
|
||||||
ismasClient.getProgressInPercent(),
|
ismasClient.getProgressInPercent(),
|
||||||
IsmasClient::RESULT_CODE::UPDATE_IN_ERROR_STATE,
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
smap[UPDATE_STEP::UPDATE_FINALIZE],
|
smap[UPDATE_STEP::UPDATE_FINALIZE],
|
||||||
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
|
@ -1,55 +0,0 @@
|
|||||||
#ifndef SYSTEM_H
|
|
||||||
#define SYSTEM_H
|
|
||||||
|
|
||||||
|
|
||||||
#include <QObject>
|
|
||||||
|
|
||||||
class System : public QObject
|
|
||||||
{
|
|
||||||
Q_OBJECT
|
|
||||||
|
|
||||||
private:
|
|
||||||
explicit System(QObject *parent = 0);
|
|
||||||
|
|
||||||
static QString errorMsg;
|
|
||||||
|
|
||||||
|
|
||||||
public:
|
|
||||||
|
|
||||||
|
|
||||||
static bool checkForSDCard();
|
|
||||||
static bool umountSDCard();
|
|
||||||
|
|
||||||
static bool checkForUSBStick();
|
|
||||||
static QString getUSBMountPath();
|
|
||||||
static QString getUSBDeviceName();
|
|
||||||
static bool umountUSBStick();
|
|
||||||
|
|
||||||
static bool test_mount(const QString& dev, const QString &mountpoint);
|
|
||||||
static bool test_dir(const QString& dir);
|
|
||||||
|
|
||||||
static quint32 getFreeDiskSpace(const QString& dev);
|
|
||||||
static quint32 getFreeDiskSpaceSDCard();
|
|
||||||
static bool isSDCardWritable();
|
|
||||||
static quint32 getFreeDiskSpaceUSBStick();
|
|
||||||
static bool isUSBStickWritable();
|
|
||||||
|
|
||||||
static quint8 createLogFileBackup(const QString & targzfile, const QString &filelistfile = "");
|
|
||||||
static QString getSDCardMountPath();
|
|
||||||
static QString getSDCardDeviceName();
|
|
||||||
|
|
||||||
static QString getUniqueDeviceId();
|
|
||||||
|
|
||||||
static QString getErrorMessage();
|
|
||||||
|
|
||||||
static QString readStringFromFile(const QString & filename);
|
|
||||||
static int readIntFromFile(const QString & filename);
|
|
||||||
|
|
||||||
static QString getPTU4SerialNumber();
|
|
||||||
static QString getPTU4MACAddress();
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
#endif // SYSTEM_H
|
|
@ -1,647 +0,0 @@
|
|||||||
#include "System.h"
|
|
||||||
#include <QFile>
|
|
||||||
#include <QFileInfo>
|
|
||||||
#include <QDir>
|
|
||||||
#include <QTextStream>
|
|
||||||
#include <QProcess>
|
|
||||||
#include <QRegExp>
|
|
||||||
#include <QStringList>
|
|
||||||
#include <QDebug>
|
|
||||||
|
|
||||||
//#include "version.h"
|
|
||||||
|
|
||||||
|
|
||||||
QString System::errorMsg = "";
|
|
||||||
|
|
||||||
System::System(QObject *parent) :
|
|
||||||
QObject(parent)
|
|
||||||
{
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function to return error message.
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
QString System::getErrorMessage()
|
|
||||||
{
|
|
||||||
return errorMsg;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function to check if a writable SD-card is in the cardslot.
|
|
||||||
*
|
|
||||||
* This function only checks a certain path or a mount entry. It does not mount
|
|
||||||
* a SD-card, this must be provided by the OS (automounter).
|
|
||||||
*
|
|
||||||
* returns 1 if a SD-card is available, 0 otherwise.
|
|
||||||
*/
|
|
||||||
bool System::checkForSDCard()
|
|
||||||
{
|
|
||||||
#if defined (ARCH_DesktopLinux)
|
|
||||||
// DEBUG / TEST:
|
|
||||||
return true;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
if (!test_mount(getSDCardDeviceName(), getSDCardMountPath())) {
|
|
||||||
qDebug() << "check for SD-card failed: \n"
|
|
||||||
<< " device name is: " << getSDCardDeviceName()
|
|
||||||
<< " mount path is: " << getSDCardMountPath();
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function for umount sd-card.
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
bool System::umountSDCard()
|
|
||||||
{
|
|
||||||
#if defined (ARCH_DesktopLinux)
|
|
||||||
// DEBUG / TEST:
|
|
||||||
return true;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
QProcess process;
|
|
||||||
process.setProcessChannelMode(QProcess::MergedChannels);
|
|
||||||
|
|
||||||
QString commandString = "umount " + getSDCardMountPath();
|
|
||||||
|
|
||||||
process.start(commandString);
|
|
||||||
if (!process.waitForStarted()) {
|
|
||||||
errorMsg = "System::umountSDCard(): ERROR: waitForStarted()";
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
if (!process.waitForFinished(600000)) {
|
|
||||||
errorMsg = "System::umountSDCard(): ERROR: " + process.errorString();
|
|
||||||
qDebug() << errorMsg;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
QByteArray bytes = process.readAll();
|
|
||||||
QStringList lines = QString(bytes).split("\n");
|
|
||||||
foreach (QString line, lines) {
|
|
||||||
qDebug() << "System::umountSDCard() line: " << line;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function for umount usb-stick.
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
bool System::umountUSBStick()
|
|
||||||
{
|
|
||||||
#if defined (ARCH_DesktopLinux)
|
|
||||||
// DEBUG / TEST:
|
|
||||||
return true;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
QProcess process;
|
|
||||||
process.setProcessChannelMode(QProcess::MergedChannels);
|
|
||||||
|
|
||||||
QString commandString = "umount " + getUSBMountPath();
|
|
||||||
|
|
||||||
process.start(commandString);
|
|
||||||
if (!process.waitForStarted()) {
|
|
||||||
errorMsg = "System::umountUSBStick(): ERROR: waitForStarted()";
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
if (!process.waitForFinished(600000)) {
|
|
||||||
errorMsg = "System::umountUSBStick(): ERROR: " + process.errorString();
|
|
||||||
qDebug() << errorMsg;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
QByteArray bytes = process.readAll();
|
|
||||||
QStringList lines = QString(bytes).split("\n");
|
|
||||||
foreach (QString line, lines) {
|
|
||||||
qDebug() << "System::umountUSBStick() line: " << line;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* test, if a certain device is already mounted
|
|
||||||
*
|
|
||||||
* e.g. a mounted SD-card on PTU4:
|
|
||||||
* - device is '/dev/mmcblk0p1'
|
|
||||||
* - mount path is '/media/mmcblk0p1'
|
|
||||||
*
|
|
||||||
* e.g. a mounted USB-Stick on PTU4:
|
|
||||||
* - device is '/dev/sda'
|
|
||||||
* - mount path is '/media/sda'
|
|
||||||
*/
|
|
||||||
bool System::test_mount(const QString& dev, const QString& mountpoint)
|
|
||||||
{
|
|
||||||
bool mounted = false;
|
|
||||||
QProcess process;
|
|
||||||
process.setProcessChannelMode(QProcess::MergedChannels);
|
|
||||||
|
|
||||||
qDebug() << "System::test_mount() dev = " << dev;
|
|
||||||
qDebug() << "System::test_mount() mountpoint = " << mountpoint;
|
|
||||||
|
|
||||||
//normalize mountpoint: (mountpoint is without trailing '/')
|
|
||||||
QString tmp_mountpoint = QString(mountpoint).remove(QRegExp("/*$"));
|
|
||||||
|
|
||||||
QString commandString = "mount";
|
|
||||||
|
|
||||||
process.start(commandString);
|
|
||||||
if (!process.waitForStarted()) {
|
|
||||||
errorMsg = "System::test_mount(): ERROR: waitForStarted()";
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
if (!process.waitForFinished(600000)) {
|
|
||||||
errorMsg = "System::test_mount(): ERROR: " + process.errorString();
|
|
||||||
qDebug() << errorMsg;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
QByteArray bytes = process.readAll();
|
|
||||||
QStringList lines = QString(bytes).split("\n");
|
|
||||||
foreach (QString line, lines) {
|
|
||||||
//qDebug() << "System::test_mount() line: " << line;
|
|
||||||
|
|
||||||
//if (line.contains(dev)) qDebug() << "System::test_mount() line contains dev";
|
|
||||||
//if (line.contains(tmp_mountpoint)) qDebug() << "System::test_mount() line contains mountpoint";
|
|
||||||
|
|
||||||
if (line.contains(dev) && line.contains(tmp_mountpoint)) {
|
|
||||||
qDebug() << "System::test_mount(): " << dev << " is mounted on " << tmp_mountpoint;
|
|
||||||
mounted = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
return mounted;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* test, if a certain directory is existing and readable
|
|
||||||
*/
|
|
||||||
bool System::test_dir(const QString& dir)
|
|
||||||
{
|
|
||||||
QFileInfo fileInfo(dir);
|
|
||||||
if (! fileInfo.isDir() ) { return false; }
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
bool System::checkForUSBStick()
|
|
||||||
{
|
|
||||||
#if defined (ARCH_DesktopLinux)
|
|
||||||
// DEBUG / TEST:
|
|
||||||
if (QFileInfo(getUSBMountPath()).isDir())
|
|
||||||
return true;
|
|
||||||
else
|
|
||||||
return false;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
if (getUSBMountPath().isEmpty()) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @brief SupportSystem::getUSBMountPath
|
|
||||||
* @return path where a USB storage device is mounted.
|
|
||||||
*
|
|
||||||
* Note, do not return an empty string ("") here because a calling method (which could not be
|
|
||||||
* identified till now) is relying on this!
|
|
||||||
*/
|
|
||||||
QString System::getUSBMountPath()
|
|
||||||
{
|
|
||||||
|
|
||||||
#if defined (ARCH_DesktopLinux)
|
|
||||||
// DEBUG / TEST:
|
|
||||||
return QDir::homePath().append("/APconfigTest/USB");
|
|
||||||
#endif
|
|
||||||
|
|
||||||
QProcess process;
|
|
||||||
process.setProcessChannelMode(QProcess::MergedChannels);
|
|
||||||
|
|
||||||
QStringList mountLine;
|
|
||||||
|
|
||||||
qDebug() << "System::getUSBMountPath()";
|
|
||||||
|
|
||||||
QRegExp devRegExp = QRegExp("dev/sd*", Qt::CaseSensitive, QRegExp::WildcardUnix);
|
|
||||||
QRegExp mountRegExp = QRegExp("media/sd*", Qt::CaseSensitive, QRegExp::WildcardUnix);
|
|
||||||
|
|
||||||
QString commandString = "mount";
|
|
||||||
|
|
||||||
process.start(commandString);
|
|
||||||
if (!process.waitForStarted()) {
|
|
||||||
errorMsg = "System::getUSBMountPath(): ERROR: waitForStarted()";
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
if (!process.waitForFinished(600000)) {
|
|
||||||
errorMsg = "System::getUSBMountPath(): ERROR: " + process.errorString();
|
|
||||||
qDebug() << errorMsg;
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
QByteArray bytes = process.readAll();
|
|
||||||
QStringList lines = QString(bytes).split("\n");
|
|
||||||
foreach (QString line, lines) {
|
|
||||||
qDebug() << "System::getUSBMountPath() line: " << line;
|
|
||||||
|
|
||||||
if (line.contains(devRegExp) && line.contains(mountRegExp)) {
|
|
||||||
|
|
||||||
qDebug() << " -> this line is a usb storage device mount" << line;
|
|
||||||
|
|
||||||
mountLine = line.split(' ');
|
|
||||||
if (mountLine.size() > 3) {
|
|
||||||
qDebug() << "System::getUSBMountPath(): " << mountLine.at(0) << " is mounted on " << mountLine.at(2);
|
|
||||||
return mountLine.at(2);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
qDebug() << "System::getUSBMountPath() no mounted usb device found!";
|
|
||||||
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function to check if a mounted sd-card is writable.
|
|
||||||
*
|
|
||||||
* Note: the caller must ensure (e.g. by calling checkForSDCard()) that a
|
|
||||||
* sd-card is mounted.
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
bool System::isSDCardWritable()
|
|
||||||
{
|
|
||||||
QFileInfo fi(getSDCardMountPath());
|
|
||||||
|
|
||||||
if(fi.isDir() && fi.isWritable()) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function to check if a mounted usb-stick is writable.
|
|
||||||
*
|
|
||||||
* Note: the caller must ensure (e.g. by calling checkForUSBStick()) that a
|
|
||||||
* usb-stick is mounted.
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
bool System::isUSBStickWritable()
|
|
||||||
{
|
|
||||||
QFileInfo fi(getUSBMountPath());
|
|
||||||
|
|
||||||
if(fi.isDir() && fi.isWritable()) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* wrapper function for getting free space on a sd-card on ptu
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
quint32 System::getFreeDiskSpaceSDCard()
|
|
||||||
{
|
|
||||||
#if defined (ARCH_DesktopLinux)
|
|
||||||
return getFreeDiskSpace("/home/siegert/server1home");
|
|
||||||
#endif
|
|
||||||
return getFreeDiskSpace(getSDCardMountPath());
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* wrapper function for getting free space on a usb storage device on ptu
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
quint32 System::getFreeDiskSpaceUSBStick()
|
|
||||||
{
|
|
||||||
#if defined (ARCH_DesktopLinux)
|
|
||||||
return getFreeDiskSpace("/home/siegert/server1home");
|
|
||||||
#endif
|
|
||||||
return getFreeDiskSpace(getUSBMountPath());
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function to read free disk space
|
|
||||||
*
|
|
||||||
* example output of 'df' command on ptu:
|
|
||||||
* # df
|
|
||||||
* Filesystem 1K-blocks Used Available Use% Mounted on
|
|
||||||
* ubi0:rootfs 111704 78940 32764 71% /
|
|
||||||
* devtmpfs 62072 0 62072 0% /dev
|
|
||||||
* tmpfs 62332 0 62332 0% /dev/shm
|
|
||||||
* tmpfs 62332 416 61916 1% /tmp
|
|
||||||
* tmpfs 62332 24 62308 1% /run
|
|
||||||
* ubi0:data 222260 5892 216368 3% /opt
|
|
||||||
* tmpfs 62332 0 62332 0% /media
|
|
||||||
* /dev/mmcblk0p1 3878912 87360 3791552 3% /media/mmcblk0p1
|
|
||||||
*
|
|
||||||
* in this case, if we want to get the free space on the sd-card the methode should
|
|
||||||
* be called:
|
|
||||||
* getFreeDiskSpace("/dev/mmcblk0p1")
|
|
||||||
* the result should be:
|
|
||||||
* 3791552
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
quint32 System::getFreeDiskSpace(const QString& dev)
|
|
||||||
{
|
|
||||||
quint32 availableSpace = 0;
|
|
||||||
QProcess process;
|
|
||||||
process.setProcessChannelMode(QProcess::MergedChannels);
|
|
||||||
|
|
||||||
//qDebug() << "System::getFreeDiskSpace() dev = " << dev;
|
|
||||||
|
|
||||||
QString commandString = "df";
|
|
||||||
|
|
||||||
process.start(commandString);
|
|
||||||
if (!process.waitForStarted()) {
|
|
||||||
errorMsg = "System::getFreeDiskSpace(): ERROR: waitForStarted()";
|
|
||||||
return availableSpace;
|
|
||||||
}
|
|
||||||
if (!process.waitForFinished(600000)) {
|
|
||||||
errorMsg = "System::getFreeDiskSpace(): ERROR: " + process.errorString();
|
|
||||||
qDebug() << errorMsg;
|
|
||||||
return availableSpace;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
QByteArray bytes = process.readAll();
|
|
||||||
QStringList lines = QString(bytes).split("\n");
|
|
||||||
foreach (QString line, lines) {
|
|
||||||
//qDebug() << "System::getFreeDiskSpace() line: " << line;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
if (line.contains(dev)) {
|
|
||||||
//qDebug() << "System::getFreeDiskSpace() line contains dev";
|
|
||||||
|
|
||||||
QStringList processResultLine = line.split(' ', QString::SkipEmptyParts);
|
|
||||||
if (processResultLine.size() >= 4) {
|
|
||||||
bool ok;
|
|
||||||
availableSpace = processResultLine.at(3).toLong(&ok);
|
|
||||||
if (!ok) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
qDebug() << "System::getFreeDiskSpace() availableSpace = " << availableSpace;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
return availableSpace;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
return availableSpace;
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function to create a backup of logfiles
|
|
||||||
*
|
|
||||||
* 'targzfile' is an absolute filename for ar tar.gz file wich will be created
|
|
||||||
* 'filelistfile' is an absolute filename of a file containing all names of files
|
|
||||||
* which should be backed up.
|
|
||||||
*
|
|
||||||
* returns:
|
|
||||||
* 1 on success
|
|
||||||
* 0 on failure
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
quint8 System::createLogFileBackup(const QString & targzfile, const QString &filelistfile)
|
|
||||||
{
|
|
||||||
QProcess process;
|
|
||||||
process.setProcessChannelMode(QProcess::MergedChannels);
|
|
||||||
|
|
||||||
qDebug() << "System::createLogFileBackup() targzfile = " << targzfile;
|
|
||||||
qDebug() << "System::createLogFileBackup() filelistfile = " << filelistfile;
|
|
||||||
|
|
||||||
QString commandString = "tar hczvf " + targzfile + " -T " + filelistfile;
|
|
||||||
|
|
||||||
qDebug() << "System::createLogFileBackup() tar command:" << commandString;
|
|
||||||
|
|
||||||
process.start(commandString);
|
|
||||||
if (!process.waitForStarted()) {
|
|
||||||
errorMsg = "System::createLogFileBackup(): ERROR: waitForStarted()";
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
if (!process.waitForFinished(600000)) {
|
|
||||||
errorMsg = "System::createLogFileBackup(): ERROR: " + process.errorString();
|
|
||||||
qDebug() << errorMsg;
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
// DEBUG
|
|
||||||
//QByteArray bytes = process.readAll();
|
|
||||||
//QStringList lines = QString(bytes).split("\n");
|
|
||||||
//foreach (QString line, lines) {
|
|
||||||
// qDebug() << "System::createLogFileBackup() line: " << line;
|
|
||||||
//}
|
|
||||||
}
|
|
||||||
|
|
||||||
QString resultMessage;
|
|
||||||
QProcess::ExitStatus exitStatus = process.exitStatus();
|
|
||||||
int exitCode = process.exitCode();
|
|
||||||
|
|
||||||
if (exitStatus == QProcess::CrashExit) {
|
|
||||||
resultMessage = "local backup program crashed";
|
|
||||||
qCritical() << resultMessage;
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
|
|
||||||
/**
|
|
||||||
* note for exit codes of process tar:
|
|
||||||
* see: http://www.gnu.org/software/tar/manual/html_section/tar_19.html#Synopsis
|
|
||||||
*
|
|
||||||
* tar returns exitCode 2 if some files in logFileList could not be read (e.g. if they are not existing)
|
|
||||||
* however, tar-archive is created although!
|
|
||||||
* This means success for our needs!
|
|
||||||
*/
|
|
||||||
|
|
||||||
if ( (exitCode != 0) && (exitCode != 2) && (exitStatus == QProcess::NormalExit) ) {
|
|
||||||
resultMessage = "Local Backup file \"" + targzfile + "\" with exit code = " + QString::number(exitCode);
|
|
||||||
qCritical() << resultMessage;
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
resultMessage = "Local Backup file \"" + targzfile + "\" was created successfully.";
|
|
||||||
qCritical() << resultMessage;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
return 0;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* get SD-card mount path.
|
|
||||||
*/
|
|
||||||
QString System::getSDCardMountPath()
|
|
||||||
{
|
|
||||||
#if defined (ARCH_PTU4)
|
|
||||||
return "/media/mmcblk0p1";
|
|
||||||
#elif defined (ARCH_PTU5)
|
|
||||||
return "/media/mmcblk0p1";
|
|
||||||
#elif defined (ARCH_DesktopLinux)
|
|
||||||
// DEBUG / TEST:
|
|
||||||
return "/home/siegert/APconfigTest";
|
|
||||||
#endif
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/*****************************************************************************
|
|
||||||
* get SD-card device name.
|
|
||||||
*/
|
|
||||||
QString System::getSDCardDeviceName()
|
|
||||||
{
|
|
||||||
#if defined (ARCH_PTU4)
|
|
||||||
return "/dev/mmcblk0p1";
|
|
||||||
#elif defined (ARCH_PTU5)
|
|
||||||
return "/dev/mmcblk0p1";
|
|
||||||
#elif defined (ARCH_DesktopLinux)
|
|
||||||
return "/dev/sdf1";
|
|
||||||
#endif
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/********************************************************************************
|
|
||||||
* static function to build and return a unique device id.
|
|
||||||
* This id consists currently only of the mac-address of network device eth0.
|
|
||||||
*/
|
|
||||||
QString System::getUniqueDeviceId()
|
|
||||||
{
|
|
||||||
QString filename = "/sys/class/net/eth0/address";
|
|
||||||
QString result;
|
|
||||||
|
|
||||||
QFile file(filename);
|
|
||||||
if(!file.open(QIODevice::ReadOnly)) {
|
|
||||||
qCritical() << "System::getUniqueDeviceId() could not open file: " << filename;
|
|
||||||
result = "0";
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
QTextStream in(&file);
|
|
||||||
result = in.readLine(20);
|
|
||||||
}
|
|
||||||
|
|
||||||
file.close();
|
|
||||||
|
|
||||||
result.remove(':');
|
|
||||||
|
|
||||||
return result;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
QString System::readStringFromFile(const QString & filename)
|
|
||||||
{
|
|
||||||
#if defined (ARCH_PTU4)
|
|
||||||
QFileInfo fileinfo(filename);
|
|
||||||
#else
|
|
||||||
QFileInfo fileinfo(QDir::homePath() + filename);
|
|
||||||
#endif
|
|
||||||
if (! fileinfo.isReadable() ) {
|
|
||||||
qDebug() << "System::readStringFromFile(): \"" << filename << "\" is not readable";
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
|
|
||||||
#if defined (ARCH_PTU4)
|
|
||||||
QFile file(filename);
|
|
||||||
#else
|
|
||||||
QFile file(QDir::homePath() + filename);
|
|
||||||
#endif
|
|
||||||
if (!file.open(QIODevice::ReadOnly | QIODevice::Text)) {
|
|
||||||
qDebug() << "System::readStringFromFile() cannot open file: " << filename;
|
|
||||||
return "";
|
|
||||||
}
|
|
||||||
|
|
||||||
QTextStream in(&file);
|
|
||||||
|
|
||||||
QString stringValue = in.readLine(100);
|
|
||||||
qDebug() << "System::readStringFromFile() stringValue = " << stringValue;
|
|
||||||
|
|
||||||
file.close();
|
|
||||||
|
|
||||||
return stringValue;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
int System::readIntFromFile(const QString & filename)
|
|
||||||
{
|
|
||||||
bool ok;
|
|
||||||
int result = (int)readStringFromFile(filename).toInt(&ok);
|
|
||||||
|
|
||||||
if (!ok) {
|
|
||||||
result = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/****************************************************************************
|
|
||||||
* read ptu internal data
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
QString System::getPTU4SerialNumber()
|
|
||||||
{
|
|
||||||
return readStringFromFile("/sys/bus/i2c/devices/0-0050/SNO");
|
|
||||||
}
|
|
||||||
|
|
||||||
QString System::getPTU4MACAddress()
|
|
||||||
{
|
|
||||||
return readStringFromFile("/sys/bus/i2c/devices/0-0050/MAC");
|
|
||||||
}
|
|
||||||
|
|
Loading…
x
Reference in New Issue
Block a user