2016-09-03 19:39:43 +02:00
|
|
|
#include "./syncthingprocess.h"
|
|
|
|
|
|
|
|
#include <QTimer>
|
|
|
|
|
|
|
|
namespace Data {
|
|
|
|
|
|
|
|
SyncthingProcess::SyncthingProcess(QObject *parent) :
|
2016-09-29 21:19:54 +02:00
|
|
|
QProcess(parent)
|
2016-09-03 19:39:43 +02:00
|
|
|
{
|
|
|
|
setProcessChannelMode(QProcess::MergedChannels);
|
|
|
|
connect(this, static_cast<void(SyncthingProcess::*)(int exitCode, QProcess::ExitStatus exitStatus)>(&SyncthingProcess::finished), this, &SyncthingProcess::handleFinished);
|
|
|
|
}
|
|
|
|
|
2016-09-29 21:19:54 +02:00
|
|
|
void SyncthingProcess::restartSyncthing(const QString &cmd)
|
2016-09-03 19:39:43 +02:00
|
|
|
{
|
|
|
|
if(state() == QProcess::Running) {
|
2016-09-29 21:19:54 +02:00
|
|
|
m_cmd = cmd;
|
2016-09-03 19:39:43 +02:00
|
|
|
// give Syncthing 5 seconds to terminate, otherwise kill it
|
|
|
|
QTimer::singleShot(5000, this, SLOT(killToRestart()));
|
|
|
|
terminate();
|
|
|
|
} else {
|
2016-09-29 21:19:54 +02:00
|
|
|
startSyncthing(cmd);
|
2016-09-03 19:39:43 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-09-29 21:19:54 +02:00
|
|
|
void SyncthingProcess::startSyncthing(const QString &cmd)
|
2016-09-03 19:39:43 +02:00
|
|
|
{
|
2016-09-24 16:19:23 +02:00
|
|
|
if(state() == QProcess::NotRunning) {
|
2016-09-29 21:19:54 +02:00
|
|
|
if(cmd.isEmpty()) {
|
|
|
|
start(QProcess::ReadOnly);
|
|
|
|
} else {
|
|
|
|
start(cmd, QProcess::ReadOnly);
|
|
|
|
}
|
2016-09-24 16:19:23 +02:00
|
|
|
}
|
2016-09-03 19:39:43 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void SyncthingProcess::handleFinished(int exitCode, QProcess::ExitStatus exitStatus)
|
|
|
|
{
|
|
|
|
Q_UNUSED(exitCode)
|
|
|
|
Q_UNUSED(exitStatus)
|
2016-09-29 21:19:54 +02:00
|
|
|
if(!m_cmd.isEmpty()) {
|
|
|
|
startSyncthing(m_cmd);
|
|
|
|
m_cmd.clear();
|
2016-09-03 19:39:43 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void SyncthingProcess::killToRestart()
|
|
|
|
{
|
2016-09-29 21:19:54 +02:00
|
|
|
if(!m_cmd.isEmpty()) {
|
2016-09-03 19:39:43 +02:00
|
|
|
kill();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
SyncthingProcess &syncthingProcess()
|
|
|
|
{
|
|
|
|
static SyncthingProcess process;
|
|
|
|
return process;
|
|
|
|
}
|
|
|
|
|
|
|
|
} // namespace Data
|