author | zecke <zecke> | 2002-10-15 01:14:17 (UTC) |
---|---|---|
committer | zecke <zecke> | 2002-10-15 01:14:17 (UTC) |
commit | e0efd37513192d9a17fa9a9f46bbaed0ca38029c (patch) (unidiff) | |
tree | 04163d93fc4c4185d322912e9430eff9b36b71cc | |
parent | b12b38a00c66ddc100f3fff75478539b8b797928 (diff) | |
download | opie-e0efd37513192d9a17fa9a9f46bbaed0ca38029c.zip opie-e0efd37513192d9a17fa9a9f46bbaed0ca38029c.tar.gz opie-e0efd37513192d9a17fa9a9f46bbaed0ca38029c.tar.bz2 |
The right way to deal with the pipe
-rw-r--r-- | noncore/apps/opie-console/MyPty.cpp | 10 | ||||
-rw-r--r-- | noncore/apps/opie-console/MyPty.h | 2 |
2 files changed, 9 insertions, 3 deletions
diff --git a/noncore/apps/opie-console/MyPty.cpp b/noncore/apps/opie-console/MyPty.cpp index cacb4ce..ae01392 100644 --- a/noncore/apps/opie-console/MyPty.cpp +++ b/noncore/apps/opie-console/MyPty.cpp | |||
@@ -95,49 +95,51 @@ | |||
95 | Informs the client program about the | 95 | Informs the client program about the |
96 | actual size of the window. | 96 | actual size of the window. |
97 | */ | 97 | */ |
98 | 98 | ||
99 | void MyPty::setSize(int lines, int columns) | 99 | void MyPty::setSize(int lines, int columns) |
100 | { | 100 | { |
101 | struct winsize wsize; | 101 | struct winsize wsize; |
102 | wsize.ws_row = (unsigned short)lines; | 102 | wsize.ws_row = (unsigned short)lines; |
103 | wsize.ws_col = (unsigned short)columns; | 103 | wsize.ws_col = (unsigned short)columns; |
104 | if(m_fd < 0) return; | 104 | if(m_fd < 0) return; |
105 | ioctl(m_fd,TIOCSWINSZ,(char *)&wsize); | 105 | ioctl(m_fd,TIOCSWINSZ,(char *)&wsize); |
106 | } | 106 | } |
107 | 107 | ||
108 | 108 | ||
109 | void MyPty::donePty() | 109 | void MyPty::donePty() |
110 | { | 110 | { |
111 | // This is code from the Qt DumbTerminal example | 111 | // This is code from the Qt DumbTerminal example |
112 | int status = 0; | 112 | int status = 0; |
113 | 113 | ||
114 | ::close(m_fd); | 114 | ::close(m_fd); |
115 | 115 | ||
116 | if (m_cpid) { | 116 | if (m_cpid) { |
117 | qWarning("killing!!!"); | 117 | qWarning("killing!!!"); |
118 | kill(m_cpid, SIGHUP); | 118 | kill(m_cpid, SIGHUP); |
119 | waitpid(m_cpid, &status, 0); | 119 | //waitpid(m_cpid, &status, 0); |
120 | delete m_sn_e; | ||
121 | m_sn_e = 0l; | ||
120 | } | 122 | } |
121 | 123 | ||
122 | m_cpid = 0; | 124 | m_cpid = 0; |
123 | // emit done(status); | 125 | // emit done(status); |
124 | } | 126 | } |
125 | 127 | ||
126 | 128 | ||
127 | const char* MyPty::deviceName() | 129 | const char* MyPty::deviceName() |
128 | { | 130 | { |
129 | return m_ttynam; | 131 | return m_ttynam; |
130 | } | 132 | } |
131 | 133 | ||
132 | 134 | ||
133 | void MyPty::error() | 135 | void MyPty::error() |
134 | { | 136 | { |
135 | qWarning("error"); | 137 | qWarning("error"); |
136 | // This is code from the Qt DumbTerminal example | 138 | // This is code from the Qt DumbTerminal example |
137 | donePty(); | 139 | donePty(); |
138 | } | 140 | } |
139 | 141 | ||
140 | void MyPty::start() { | 142 | void MyPty::start() { |
141 | char* cmd = "/bin/sh"; | 143 | char* cmd = "/bin/sh"; |
142 | QStrList lis; | 144 | QStrList lis; |
143 | int r =run(cmd, lis, 0, 0); | 145 | int r =run(cmd, lis, 0, 0); |
@@ -165,94 +167,96 @@ int MyPty::run(const char* cmd, QStrList &, const char*, int) | |||
165 | perror( "failed to set process group" ); | 167 | perror( "failed to set process group" ); |
166 | #if defined (TIOCSCTTY) | 168 | #if defined (TIOCSCTTY) |
167 | // grabbed from APUE by Stevens | 169 | // grabbed from APUE by Stevens |
168 | ioctl(STDIN_FILENO, TIOCSCTTY, 0); | 170 | ioctl(STDIN_FILENO, TIOCSCTTY, 0); |
169 | #endif | 171 | #endif |
170 | tcgetattr( STDIN_FILENO, &ttmode ); | 172 | tcgetattr( STDIN_FILENO, &ttmode ); |
171 | ttmode.c_cc[VINTR] = 3; | 173 | ttmode.c_cc[VINTR] = 3; |
172 | ttmode.c_cc[VERASE] = 8; | 174 | ttmode.c_cc[VERASE] = 8; |
173 | tcsetattr( STDIN_FILENO, TCSANOW, &ttmode ); | 175 | tcsetattr( STDIN_FILENO, TCSANOW, &ttmode ); |
174 | setenv("TERM","vt100",1); | 176 | setenv("TERM","vt100",1); |
175 | setenv("COLORTERM","0",1); | 177 | setenv("COLORTERM","0",1); |
176 | 178 | ||
177 | if (getuid() == 0) { | 179 | if (getuid() == 0) { |
178 | char msg[] = "WARNING: You are running this shell as root!\n"; | 180 | char msg[] = "WARNING: You are running this shell as root!\n"; |
179 | write(ttyfd, msg, sizeof(msg)); | 181 | write(ttyfd, msg, sizeof(msg)); |
180 | } | 182 | } |
181 | execl(cmd, cmd, 0); | 183 | execl(cmd, cmd, 0); |
182 | 184 | ||
183 | donePty(); | 185 | donePty(); |
184 | exit(-1); | 186 | exit(-1); |
185 | } | 187 | } |
186 | 188 | ||
187 | // parent - continue as a widget | 189 | // parent - continue as a widget |
188 | QSocketNotifier* sn_r = new QSocketNotifier(m_fd,QSocketNotifier::Read,this); | 190 | QSocketNotifier* sn_r = new QSocketNotifier(m_fd,QSocketNotifier::Read,this); |
189 | // QSocketNotifier* sn_e = new QSocketNotifier(m_fd,QSocketNotifier::Exception,this); | 191 | delete m_sn_e; |
192 | m_sn_e = new QSocketNotifier(m_fd,QSocketNotifier::Exception,this); | ||
190 | connect(sn_r,SIGNAL(activated(int)),this,SLOT(readPty())); | 193 | connect(sn_r,SIGNAL(activated(int)),this,SLOT(readPty())); |
191 | // connect(sn_e,SIGNAL(activated(int)),this,SLOT(error())); | 194 | connect(m_sn_e,SIGNAL(activated(int)),this,SLOT(error())); |
192 | 195 | ||
193 | return 0; | 196 | return 0; |
194 | } | 197 | } |
195 | 198 | ||
196 | int MyPty::openPty() | 199 | int MyPty::openPty() |
197 | { | 200 | { |
198 | // This is code from the Qt DumbTerminal example | 201 | // This is code from the Qt DumbTerminal example |
199 | int ptyfd = -1; | 202 | int ptyfd = -1; |
200 | 203 | ||
201 | #ifdef HAVE_OPENPTY | 204 | #ifdef HAVE_OPENPTY |
202 | int ttyfd; | 205 | int ttyfd; |
203 | if ( openpty(&ptyfd,&ttyfd,ttynam,0,0) ) | 206 | if ( openpty(&ptyfd,&ttyfd,ttynam,0,0) ) |
204 | ptyfd = -1; | 207 | ptyfd = -1; |
205 | else | 208 | else |
206 | close(ttyfd); // we open the ttynam ourselves. | 209 | close(ttyfd); // we open the ttynam ourselves. |
207 | #else | 210 | #else |
208 | for (const char* c0 = "pqrstuvwxyzabcde"; ptyfd < 0 && *c0 != 0; c0++) { | 211 | for (const char* c0 = "pqrstuvwxyzabcde"; ptyfd < 0 && *c0 != 0; c0++) { |
209 | for (const char* c1 = "0123456789abcdef"; ptyfd < 0 && *c1 != 0; c1++) { | 212 | for (const char* c1 = "0123456789abcdef"; ptyfd < 0 && *c1 != 0; c1++) { |
210 | sprintf(m_ptynam,"/dev/pty%c%c",*c0,*c1); | 213 | sprintf(m_ptynam,"/dev/pty%c%c",*c0,*c1); |
211 | sprintf(m_ttynam,"/dev/tty%c%c",*c0,*c1); | 214 | sprintf(m_ttynam,"/dev/tty%c%c",*c0,*c1); |
212 | if ((ptyfd = ::open(m_ptynam,O_RDWR)) >= 0) { | 215 | if ((ptyfd = ::open(m_ptynam,O_RDWR)) >= 0) { |
213 | if (geteuid() != 0 && !access(m_ttynam,R_OK|W_OK) == 0) { | 216 | if (geteuid() != 0 && !access(m_ttynam,R_OK|W_OK) == 0) { |
214 | ::close(ptyfd); | 217 | ::close(ptyfd); |
215 | ptyfd = -1; | 218 | ptyfd = -1; |
216 | } | 219 | } |
217 | } | 220 | } |
218 | } | 221 | } |
219 | } | 222 | } |
220 | #endif | 223 | #endif |
221 | 224 | ||
222 | if ( ptyfd < 0 ) { | 225 | if ( ptyfd < 0 ) { |
223 | qApp->exit(1); | 226 | qApp->exit(1); |
224 | return -1; | 227 | return -1; |
225 | } | 228 | } |
226 | 229 | ||
227 | return ptyfd; | 230 | return ptyfd; |
228 | } | 231 | } |
229 | 232 | ||
230 | /*! | 233 | /*! |
231 | Create an instance. | 234 | Create an instance. |
232 | */ | 235 | */ |
233 | MyPty::MyPty(const Profile&) : m_cpid(0) | 236 | MyPty::MyPty(const Profile&) : m_cpid(0) |
234 | { | 237 | { |
238 | m_sn_e = 0l; | ||
235 | m_fd = openPty(); | 239 | m_fd = openPty(); |
236 | ProcCtl* ctl = ProcCtl::self(); | 240 | ProcCtl* ctl = ProcCtl::self(); |
237 | } | 241 | } |
238 | 242 | ||
239 | /*! | 243 | /*! |
240 | Destructor. | 244 | Destructor. |
241 | Note that the related client program is not killed | 245 | Note that the related client program is not killed |
242 | (yet) when a instance is deleted. | 246 | (yet) when a instance is deleted. |
243 | */ | 247 | */ |
244 | MyPty::~MyPty() | 248 | MyPty::~MyPty() |
245 | { | 249 | { |
246 | donePty(); | 250 | donePty(); |
247 | } | 251 | } |
248 | QString MyPty::identifier()const { | 252 | QString MyPty::identifier()const { |
249 | return QString::fromLatin1("term"); | 253 | return QString::fromLatin1("term"); |
250 | } | 254 | } |
251 | QString MyPty::name()const{ | 255 | QString MyPty::name()const{ |
252 | return identifier(); | 256 | return identifier(); |
253 | } | 257 | } |
254 | bool MyPty::open() { | 258 | bool MyPty::open() { |
255 | start(); | 259 | start(); |
256 | return true; | 260 | return true; |
257 | } | 261 | } |
258 | void MyPty::close() { | 262 | void MyPty::close() { |
diff --git a/noncore/apps/opie-console/MyPty.h b/noncore/apps/opie-console/MyPty.h index 9231a8a..3166fa0 100644 --- a/noncore/apps/opie-console/MyPty.h +++ b/noncore/apps/opie-console/MyPty.h | |||
@@ -7,48 +7,49 @@ | |||
7 | /* Copyright (c) 1997,1998 by Lars Doelle <lars.doelle@on-line.de> */ | 7 | /* Copyright (c) 1997,1998 by Lars Doelle <lars.doelle@on-line.de> */ |
8 | /* */ | 8 | /* */ |
9 | /* This file is part of Konsole - an X terminal for KDE */ | 9 | /* This file is part of Konsole - an X terminal for KDE */ |
10 | /* */ | 10 | /* */ |
11 | /* -------------------------------------------------------------------------- */ | 11 | /* -------------------------------------------------------------------------- */ |
12 | /* */ | 12 | /* */ |
13 | /* Ported Konsole to Qt/Embedded */ | 13 | /* Ported Konsole to Qt/Embedded */ |
14 | /* */ | 14 | /* */ |
15 | /* Copyright (C) 2000 by John Ryland <jryland@trolltech.com> */ | 15 | /* Copyright (C) 2000 by John Ryland <jryland@trolltech.com> */ |
16 | /* */ | 16 | /* */ |
17 | /* -------------------------------------------------------------------------- */ | 17 | /* -------------------------------------------------------------------------- */ |
18 | 18 | ||
19 | /*! \file | 19 | /*! \file |
20 | */ | 20 | */ |
21 | 21 | ||
22 | #ifndef MY_PTY_H | 22 | #ifndef MY_PTY_H |
23 | #define MY_PTY_H | 23 | #define MY_PTY_H |
24 | 24 | ||
25 | #include <qobject.h> | 25 | #include <qobject.h> |
26 | #include <qstrlist.h> | 26 | #include <qstrlist.h> |
27 | 27 | ||
28 | #include "io_layer.h" | 28 | #include "io_layer.h" |
29 | 29 | ||
30 | class Profile; | 30 | class Profile; |
31 | class QSocketNotifier; | ||
31 | class MyPty : public IOLayer | 32 | class MyPty : public IOLayer |
32 | { | 33 | { |
33 | Q_OBJECT | 34 | Q_OBJECT |
34 | public: | 35 | public: |
35 | 36 | ||
36 | MyPty(const Profile&); | 37 | MyPty(const Profile&); |
37 | ~MyPty(); | 38 | ~MyPty(); |
38 | 39 | ||
39 | 40 | ||
40 | 41 | ||
41 | QString identifier()const; | 42 | QString identifier()const; |
42 | QString name()const; | 43 | QString name()const; |
43 | 44 | ||
44 | public slots: | 45 | public slots: |
45 | /*! | 46 | /*! |
46 | having a `run' separate from the constructor allows to make | 47 | having a `run' separate from the constructor allows to make |
47 | the necessary connections to the signals and slots of the | 48 | the necessary connections to the signals and slots of the |
48 | instance before starting the execution of the client. | 49 | instance before starting the execution of the client. |
49 | */ | 50 | */ |
50 | void start(); | 51 | void start(); |
51 | int run(const char* pgm, QStrList & args , const char* term, int addutmp); | 52 | int run(const char* pgm, QStrList & args , const char* term, int addutmp); |
52 | bool open(); | 53 | bool open(); |
53 | void close(); | 54 | void close(); |
54 | void reload( const Profile& ); | 55 | void reload( const Profile& ); |
@@ -69,27 +70,28 @@ public: | |||
69 | \param len - the length of the block | 70 | \param len - the length of the block |
70 | */ | 71 | */ |
71 | void received(const QByteArray&); | 72 | void received(const QByteArray&); |
72 | 73 | ||
73 | public slots: | 74 | public slots: |
74 | 75 | ||
75 | void send(const QByteArray& ); | 76 | void send(const QByteArray& ); |
76 | 77 | ||
77 | private: | 78 | private: |
78 | const char* deviceName(); | 79 | const char* deviceName(); |
79 | 80 | ||
80 | protected slots: | 81 | protected slots: |
81 | void readPty(); | 82 | void readPty(); |
82 | void donePty(); | 83 | void donePty(); |
83 | 84 | ||
84 | private: | 85 | private: |
85 | int openPty(); | 86 | int openPty(); |
86 | 87 | ||
87 | private: | 88 | private: |
88 | 89 | ||
89 | char m_ptynam[16]; // "/dev/ptyxx" | "/dev/ptmx" | 90 | char m_ptynam[16]; // "/dev/ptyxx" | "/dev/ptmx" |
90 | char m_ttynam[16]; // "/dev/ttyxx" | "/dev/pts/########..." | 91 | char m_ttynam[16]; // "/dev/ttyxx" | "/dev/pts/########..." |
91 | int m_fd; | 92 | int m_fd; |
92 | int m_cpid; | 93 | int m_cpid; |
94 | QSocketNotifier* m_sn_e; | ||
93 | }; | 95 | }; |
94 | 96 | ||
95 | #endif | 97 | #endif |