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
132
133
134
135
136
137
138
139
140
141
142
143
|
/***************************************************************************
* Copyright (C) 2005 Nicolas Hadacek <[email protected]> *
* *
* This program is free software; you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation; either version 2 of the License, or *
* (at your option) any later version. *
***************************************************************************/
#ifndef PROCESS_H
#define PROCESS_H
#include <signal.h>
#include <tqstringlist.h>
#include <tqobject.h>
#include <tqtimer.h>
class TDEProcess;
#include "global.h"
namespace PURL { class Directory; }
namespace Process
{
enum State { Stopped, StartFailed, Running, Exited, Timedout };
class Base;
enum RunAction { NoRunAction = 0, Start = 1 };
TQ_DECLARE_FLAGS(RunActions, RunAction)
TQ_DECLARE_OPERATORS_FOR_FLAGS(RunActions)
extern State runSynchronously(Base &process, RunActions actions, uint timeout); // in ms (0 == no timeout)
//----------------------------------------------------------------------------
class Base : public TQObject
{
TQ_OBJECT
public:
Base(TQObject *parent, const char *name);
virtual ~Base();
void setup(const TQString &executable, const TQStringList &options, bool withWine);
TQStringList arguments() const;
void setWorkingDirectory(const PURL::Directory &dir);
void setUseShell(bool useShell);
virtual bool start(uint timeout); // in ms (0 == no timeout)
TQString prettyCommand() const { return arguments().join(" "); }
void writeToStdin(const TQString &s);
bool signal(int n);
bool isRunning() const;
State state() const { return _state; }
int exitCode() const;
signals:
void requestSynchronousStop();
void done(int code);
void timeout();
void stdoutDataReceived();
void stderrDataReceived();
protected slots:
void exited();
void timeoutSlot();
virtual void receivedStdout(TDEProcess*, char *buffer, int len) = 0;
virtual void receivedStderr(TDEProcess*, char *buffer, int len) = 0;
friend State runSynchronously(Base &, RunActions, uint);
protected:
State _state;
TDEProcess *_process;
TQTimer *_timer;
TQString _stdout, _stderr;
static bool isFilteredLine(const TQString &line);
};
//----------------------------------------------------------------------------
class StringOutput : public Base
{
TQ_OBJECT
public:
StringOutput(TQObject *parent = 0, const char *name = 0) : Base(parent, name) {}
TQString sout() const { return _stdout; }
TQString serr() const { return _stderr; }
private slots:
virtual void receivedStdout(TDEProcess *, char *buffer, int len);
virtual void receivedStderr(TDEProcess *, char *buffer, int len);
};
//----------------------------------------------------------------------------
class LineBase : public Base
{
TQ_OBJECT
public:
LineBase(TQObject *parent = 0, const char *name = 0) : Base(parent, name) {}
private slots:
virtual void receivedStdout(TDEProcess *, char *buffer, int len);
virtual void receivedStderr(TDEProcess *, char *buffer, int len);
private:
virtual void addStdoutLine(const TQString &line) = 0;
virtual void addStderrLine(const TQString &line) = 0;
};
//----------------------------------------------------------------------------
class LineOutput : public LineBase
{
TQ_OBJECT
public:
LineOutput(TQObject *parent = 0, const char *name = 0) : LineBase(parent, name) {}
virtual bool start(uint timeout);
TQStringList sout() const { return _stdoutLines; }
TQStringList serr() const { return _stderrLines; }
protected:
TQStringList _stdoutLines, _stderrLines;
virtual void addStdoutLine(const TQString &line) { _stdoutLines += line; }
virtual void addStderrLine(const TQString &line) { _stderrLines += line; }
};
//----------------------------------------------------------------------------
class LineSignal : public LineBase
{
TQ_OBJECT
public:
LineSignal(TQObject *parent = 0, const char *name = 0) : LineBase(parent, name) {}
signals:
void logStdoutLine(const TQString &line);
void logStderrLine(const TQString &line);
private:
virtual void addStdoutLine(const TQString &line) { emit logStdoutLine(line); }
virtual void addStderrLine(const TQString &line) { emit logStderrLine(line); }
};
} // namespace
#endif
|
