blob: 9e4b9741433e39936ef82923b2c81cbd8729e2f5 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
// Copyright (C) 2022 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only WITH Qt-GPL-exception-1.0
#include "squishserverprocess.h"
#include <utils/qtcassert.h>
namespace Squish::Internal {
SquishServerProcess::SquishServerProcess(QObject *parent)
: SquishProcessBase(parent)
{
connect(&m_process, &Utils::Process::readyReadStandardOutput,
this, &SquishServerProcess::onStandardOutput);
}
void SquishServerProcess::start(const Utils::CommandLine &commandLine,
const Utils::Environment &environment)
{
QTC_ASSERT(m_process.state() == QProcess::NotRunning, return);
m_serverPort = -1;
SquishProcessBase::start(commandLine, environment);
}
void SquishServerProcess::stop()
{
if (m_process.state() != QProcess::NotRunning && m_serverPort > 0) {
Utils::Process serverKiller;
QStringList args;
args << "--stop" << "--port" << QString::number(m_serverPort);
serverKiller.setCommand({m_process.commandLine().executable(), args});
serverKiller.setEnvironment(m_process.environment());
serverKiller.start();
if (!serverKiller.waitForFinished()) {
qWarning() << "Could not shutdown server within 30s";
setState(StopFailed);
}
} else {
qWarning() << "either no process running or port < 1?"
<< m_process.state() << m_serverPort;
setState(StopFailed);
}
}
void SquishServerProcess::onStandardOutput()
{
const QByteArray output = m_process.readAllRawStandardOutput();
const QList<QByteArray> lines = output.split('\n');
for (const QByteArray &line : lines) {
const QByteArray trimmed = line.trimmed();
if (trimmed.isEmpty())
continue;
if (trimmed.startsWith("Port:")) {
if (m_serverPort == -1) {
bool ok;
int port = trimmed.mid(6).toInt(&ok);
if (ok) {
m_serverPort = port;
emit portRetrieved();
} else {
qWarning() << "could not get port number" << trimmed.mid(6);
setState(StartFailed);
}
} else {
qWarning() << "got a Port output - don't know why...";
}
}
emit logOutputReceived(QString("Server: ") + QLatin1String(trimmed));
}
}
void SquishServerProcess::onErrorOutput()
{
// output that must be sent to the Runner/Server Log
const QByteArray output = m_process.readAllRawStandardError();
const QList<QByteArray> lines = output.split('\n');
for (const QByteArray &line : lines) {
const QByteArray trimmed = line.trimmed();
if (!trimmed.isEmpty())
emit logOutputReceived(QString("Server: ") + QLatin1String(trimmed));
}
}
void SquishServerProcess::onDone()
{
m_serverPort = -1;
setState(Stopped);
}
} // namespace Squish::Internal
|
