Skip to content

Commit

Permalink
Fixing outstanding issues (#1537)
Browse files Browse the repository at this point in the history
* Correct stopEnableAttemptsTimer thread affinity

* Restart correctly, if running as service

* Add instance# in API response

* Qt6 updates

* Update fallthrough guide

* Update Compile warning
  • Loading branch information
Lord-Grey authored Dec 19, 2022
1 parent 10b755b commit 2217135
Show file tree
Hide file tree
Showing 9 changed files with 26 additions and 17 deletions.
1 change: 1 addition & 0 deletions include/utils/ColorRgb.h
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
#include <cstdint>
#include <iostream>

#include <QString>
#include <QTextStream>

///
Expand Down
2 changes: 1 addition & 1 deletion include/utils/Process.h
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

namespace Process {

void restartHyperion(bool asNewProcess=false);
void restartHyperion(int exitCode = 0);
QByteArray command_exec(const QString& cmd, const QByteArray& data = {});

}
8 changes: 4 additions & 4 deletions libsrc/api/JsonAPI.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -990,7 +990,7 @@ void JsonAPI::handleConfigCommand(const QJsonObject &message, const QString &com
{
Debug(_log, "Restarting due to RPC command");

Process::restartHyperion();
Process::restartHyperion(10);

sendSuccessReply(command + "-" + subcommand, tan);
}
Expand Down Expand Up @@ -1425,7 +1425,7 @@ void JsonAPI::handleAuthorizeCommand(const QJsonObject &message, const QString &
if (!token.isEmpty())
{
// userToken is longer
if (token.count() > 36)
if (token.size() > 36)
{
if (API::isUserTokenAuthorized(token))
sendSuccessReply(command + "-" + subc, tan);
Expand All @@ -1435,7 +1435,7 @@ void JsonAPI::handleAuthorizeCommand(const QJsonObject &message, const QString &
return;
}
// usual app token is 36
if (token.count() == 36)
if (token.size() == 36)
{
if (API::isTokenAuthorized(token))
{
Expand All @@ -1449,7 +1449,7 @@ void JsonAPI::handleAuthorizeCommand(const QJsonObject &message, const QString &

// password
// use password
if (password.count() >= 8)
if (password.size() >= 8)
{
QString userTokenRep;
if (API::isUserAuthorized(password) && API::getUserToken(userTokenRep))
Expand Down
1 change: 1 addition & 0 deletions libsrc/api/JsonCB.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -171,6 +171,7 @@ void JsonCB::setSubscriptionsTo(Hyperion* hyperion)
void JsonCB::doCallback(const QString& cmd, const QVariant& data)
{
QJsonObject obj;
obj["instance"] = _hyperion->getInstanceIndex();
obj["command"] = cmd;

if (data.userType() == QMetaType::QJsonArray)
Expand Down
2 changes: 1 addition & 1 deletion libsrc/grabber/video/mediafoundation/MFGrabber.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -537,7 +537,7 @@ void MFGrabber::process_image(const void *frameImageBuffer, int size)
Error(_log, "Frame too small: %d != %d", size, _frameByteSize);
else if (_threadManager != nullptr)
{
for (int i = 0; i < _threadManager->_threadCount; i++)
for (unsigned long i = 0; i < _threadManager->_threadCount; i++)
{
if (!_threadManager->_threads[i]->isBusy())
{
Expand Down
3 changes: 1 addition & 2 deletions libsrc/leddevice/LedDevice.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -67,8 +67,6 @@ LedDevice::LedDevice(const QJsonObject& deviceConfig, QObject* parent)

LedDevice::~LedDevice()
{
this->stopEnableAttemptsTimer();
this->stopRefreshTimer();
}

void LedDevice::start()
Expand Down Expand Up @@ -97,6 +95,7 @@ void LedDevice::start()
void LedDevice::stop()
{
Debug(_log, "Stop device");
this->stopEnableAttemptsTimer();
this->disable();
this->stopRefreshTimer();
Info(_log, " Stopped LedDevice '%s'", QSTRING_CSTR(_activeDeviceType));
Expand Down
4 changes: 2 additions & 2 deletions libsrc/leddevice/dev_serial/LedDeviceAdalight.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -95,9 +95,9 @@ void LedDeviceAdalight::prepareHeader()

case Adalight::AWA:
_bufferLength += 7;
[[clang::fallthrough]];
[[fallthrough]];
case Adalight::ADA:
[[clang::fallthrough]];
[[fallthrough]];
default:
totalLedCount -= 1;
_ledBuffer.resize(static_cast<size_t>(_bufferLength), 0x00);
Expand Down
20 changes: 14 additions & 6 deletions libsrc/utils/Process.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

namespace Process {

void restartHyperion(bool asNewProcess)
void restartHyperion(int exitCode)
{
Logger* log = Logger::getInstance("Process");
Info(log, "Restarting hyperion ...");
Expand All @@ -18,7 +18,8 @@ void restartHyperion(bool asNewProcess)

QProcess::startDetached(QCoreApplication::applicationFilePath(), arguments);

QCoreApplication::quit();
//Exit with non-zero code to ensure service deamon restarts hyperion
QCoreApplication::exit(exitCode);
}

QByteArray command_exec(const QString& /*cmd*/, const QByteArray& /*data*/)
Expand All @@ -42,9 +43,15 @@ QByteArray command_exec(const QString& /*cmd*/, const QByteArray& /*data*/)
#include <memory>
#include <stdexcept>

#include <csignal>

#include <QDebug>
#include <QMetaObject>

namespace Process {

void restartHyperion(bool asNewProcess)

void restartHyperion(int exitCode)
{
Logger* log = Logger::getInstance("Process");
Info(log, "Restarting hyperion ...");
Expand All @@ -60,10 +67,11 @@ void restartHyperion(bool asNewProcess)

QProcess::startDetached(QCoreApplication::applicationFilePath(), arguments);

QCoreApplication::quit();
//Exit with non-zero code to ensure service deamon restarts hyperion
QCoreApplication::exit(exitCode);
}

QByteArray command_exec(const QString& cmd, const QByteArray& data)
QByteArray command_exec(const QString& cmd, const QByteArray& /*data*/)
{
char buffer[128];
QString result;
Expand All @@ -73,7 +81,7 @@ QByteArray command_exec(const QString& cmd, const QByteArray& data)
{
while (!feof(pipe.get()))
{
if (fgets(buffer, 128, pipe.get()) != NULL)
if (fgets(buffer, 128, pipe.get()) != nullptr)
result += buffer;
}
}
Expand Down
2 changes: 1 addition & 1 deletion src/hyperiond/systray.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ void SysTray::createTrayIcon()

restartAction = new QAction(tr("&Restart"), this);
restartAction->setIcon(QPixmap(":/restart.svg"));
connect(restartAction, &QAction::triggered, this , [=](){ Process::restartHyperion(); });
connect(restartAction, &QAction::triggered, this , [=](){ Process::restartHyperion(11); });

colorAction = new QAction(tr("&Color"), this);
colorAction->setIcon(QPixmap(":/color.svg"));
Expand Down

0 comments on commit 2217135

Please sign in to comment.