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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
/*
SPDX-FileCopyrightText: 2002 John Firebaugh <jfirebaugh@kde.org>
SPDX-FileCopyrightText: 2007 Andreas Pakulat <apaku@gmx.de>
SPDX-FileCopyrightText: 2007 Oswald Buddenhagen <ossi@kde.org>
SPDX-License-Identifier: LGPL-2.0-or-later
*/
#include "processlinemaker.h"
#include <QProcess>
#include <QStringList>
namespace KDevelop {
class ProcessLineMakerPrivate
{
public:
QByteArray stdoutbuf;
QByteArray stderrbuf;
ProcessLineMaker* p;
QProcess* m_proc;
explicit ProcessLineMakerPrivate(ProcessLineMaker* maker)
: p(maker)
{
}
void slotReadyReadStdout()
{
stdoutbuf += m_proc->readAllStandardOutput();
processStdOut();
}
static QStringList streamToStrings(QByteArray& data)
{
QStringList lineList;
int pos;
while ((pos = data.indexOf('\n')) != -1) {
if (pos > 0 && data.at(pos - 1) == '\r')
lineList << QString::fromLocal8Bit(data.constData(), pos - 1);
else
lineList << QString::fromLocal8Bit(data.constData(), pos);
data.remove(0, pos + 1);
}
return lineList;
}
void processStdOut()
{
emit p->receivedStdoutLines(streamToStrings(stdoutbuf));
}
void slotReadyReadStderr()
{
stderrbuf += m_proc->readAllStandardError();
processStdErr();
}
void processStdErr()
{
emit p->receivedStderrLines(streamToStrings(stderrbuf));
}
};
ProcessLineMaker::ProcessLineMaker(QObject* parent)
: QObject(parent)
, d_ptr(new ProcessLineMakerPrivate(this))
{
}
ProcessLineMaker::ProcessLineMaker(QProcess* proc, QObject* parent)
: QObject(parent)
, d_ptr(new ProcessLineMakerPrivate(this))
{
Q_D(ProcessLineMaker);
d->m_proc = proc;
connect(proc, &QProcess::readyReadStandardOutput,
this, [this] {
Q_D(ProcessLineMaker);
d->slotReadyReadStdout();
});
connect(proc, &QProcess::readyReadStandardError,
this, [this] {
Q_D(ProcessLineMaker);
d->slotReadyReadStderr();
});
}
ProcessLineMaker::~ProcessLineMaker() = default;
void ProcessLineMaker::slotReceivedStdout(const QByteArray& buffer)
{
Q_D(ProcessLineMaker);
d->stdoutbuf += buffer;
d->processStdOut();
}
void ProcessLineMaker::slotReceivedStderr(const QByteArray& buffer)
{
Q_D(ProcessLineMaker);
d->stderrbuf += buffer;
d->processStdErr();
}
void ProcessLineMaker::discardBuffers()
{
Q_D(ProcessLineMaker);
d->stderrbuf.truncate(0);
d->stdoutbuf.truncate(0);
}
void ProcessLineMaker::flushBuffers()
{
Q_D(ProcessLineMaker);
if (!d->stdoutbuf.isEmpty())
emit receivedStdoutLines(QStringList(QString::fromLocal8Bit(d->stdoutbuf)));
if (!d->stderrbuf.isEmpty())
emit receivedStderrLines(QStringList(QString::fromLocal8Bit(d->stderrbuf)));
discardBuffers();
}
}
#include "moc_processlinemaker.cpp"
|
