diff options
Diffstat (limited to 'tdecore/tdeprocio.cpp')
| -rw-r--r-- | tdecore/tdeprocio.cpp | 276 |
1 files changed, 276 insertions, 0 deletions
diff --git a/tdecore/tdeprocio.cpp b/tdecore/tdeprocio.cpp new file mode 100644 index 000000000..e614148c5 --- /dev/null +++ b/tdecore/tdeprocio.cpp @@ -0,0 +1,276 @@ +/* This file is part of the KDE libraries + Copyright (C) 1997 David Sweet <dsweet@kde.org> + + This library is free software; you can redistribute it and/or + modify it under the terms of the GNU Library General Public + License version 2 as published by the Free Software Foundation. + + This library is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + Library General Public License for more details. + + You should have received a copy of the GNU Library General Public License + along with this library; see the file COPYING.LIB. If not, write to + the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + Boston, MA 02110-1301, USA. +*/ + +// $Id$ + +#ifdef HAVE_CONFIG_H +#include <config.h> +#endif + +#include <stdio.h> + +#include "tdeprocio.h" + +#include <kdebug.h> +#include <tqtextcodec.h> + +class TDEProcIOPrivate { +public: + TDEProcIOPrivate() : comm(TDEProcess::All) {} + TDEProcess::Communication comm; +}; + +TDEProcIO::TDEProcIO ( TQTextCodec *_codec) + : codec(_codec), d(new TDEProcIOPrivate) +{ + rbi=0; + readsignalon=writeready=true; + outbuffer.setAutoDelete(true); + + if (!codec) + { + codec = TQTextCodec::codecForName("ISO 8859-1"); + if (!codec) + { + kdError(174) << "Can't create ISO 8859-1 codec!" << endl; + } + } +} + +TDEProcIO::~TDEProcIO() +{ + delete d; +} + +void +TDEProcIO::resetAll () +{ + if (isRunning()) + kill(); + + clearArguments(); + rbi=0; + readsignalon=writeready=true; + + disconnect (this, TQ_SIGNAL (receivedStdout (TDEProcess *, char *, int)), + this, TQ_SLOT (received (TDEProcess *, char *, int))); + + disconnect (this, TQ_SIGNAL (receivedStderr (TDEProcess *, char *, int)), + this, TQ_SLOT (received (TDEProcess *, char *, int))); + + disconnect (this, TQ_SIGNAL (wroteStdin(TDEProcess *)), + this, TQ_SLOT (sent (TDEProcess *))); + + outbuffer.clear(); + +} + +void TDEProcIO::setComm (Communication comm) +{ + d->comm = comm; +} + +bool TDEProcIO::start (RunMode runmode, bool includeStderr) +{ + connect (this, TQ_SIGNAL (receivedStdout (TDEProcess *, char *, int)), + this, TQ_SLOT (received (TDEProcess *, char *, int))); + + if (includeStderr) + { + connect (this, TQ_SIGNAL (receivedStderr (TDEProcess *, char *, int)), + this, TQ_SLOT (received (TDEProcess *, char *, int))); + } + + connect (this, TQ_SIGNAL (wroteStdin(TDEProcess *)), + this, TQ_SLOT (sent (TDEProcess *))); + + return TDEProcess::start (runmode, d->comm); +} + +bool TDEProcIO::writeStdin (const TQString &line, bool appendnewline) +{ + return writeStdin(TQCString(codec->fromUnicode(line)), appendnewline); +} + +bool TDEProcIO::writeStdin (const TQCString &line, bool appendnewline) +{ + TQCString *qs = new TQCString(line); + + if (appendnewline) + { + *qs += '\n'; + } + + int l = qs->length(); + if (!l) + { + delete qs; + return true; + } + + TQByteArray *b = (TQByteArray *) qs; + b->truncate(l); // Strip trailing null + + outbuffer.append(b); + + if (writeready) + { + writeready=false; + return TDEProcess::writeStdin( b->data(), b->size() ); + } + return true; +} + +bool TDEProcIO::writeStdin(const TQByteArray &data) +{ + if (!data.size()) + return true; + TQByteArray *b = new TQByteArray(data); + outbuffer.append(b); + + if (writeready) + { + writeready=false; + return TDEProcess::writeStdin( b->data(), b->size() ); + } + return true; +} + +void TDEProcIO::closeWhenDone() +{ + if (writeready) + { + closeStdin(); + return; + } + outbuffer.append(0); + + return; +} + +void TDEProcIO::sent(TDEProcess *) +{ + outbuffer.removeFirst(); + + if (outbuffer.count()==0) + { + writeready=true; + } + else + { + TQByteArray *b = outbuffer.first(); + if (!b) + { + closeStdin(); + } + else + { + TDEProcess::writeStdin(b->data(), b->size()); + } + } + +} + +void TDEProcIO::received (TDEProcess *, char *buffer, int buflen) +{ + recvbuffer += TQCString(buffer, buflen+1); + + controlledEmission(); +} + +void TDEProcIO::ackRead () +{ + readsignalon=true; + if (needreadsignal || recvbuffer.length()!=0) + controlledEmission(); +} + +void TDEProcIO::controlledEmission () +{ + if (readsignalon) + { + needreadsignal=false; + readsignalon=false; //will stay off until read is acknowledged + emit readReady (this); + } + else + { + needreadsignal=true; + } +} + +void TDEProcIO::enableReadSignals (bool enable) +{ + readsignalon=enable; + + if (enable && needreadsignal) + emit readReady (this); +} + +int TDEProcIO::readln (TQString &line, bool autoAck, bool *partial) +{ + int len; + + if (autoAck) + readsignalon=true; + + //need to reduce the size of recvbuffer at some point... + + len=recvbuffer.find ('\n',rbi)-rbi; + + //kdDebug(174) << "KPIO::readln" << endl; + + //in case there's no '\n' at the end of the buffer + if ((len<0) && + ((unsigned int)rbi<recvbuffer.length())) + { + recvbuffer=recvbuffer.mid (rbi); + rbi=0; + if (partial) + { + len = recvbuffer.length(); + line = recvbuffer; + recvbuffer = ""; + *partial = true; + return len; + } + return -1; + } + + if (len>=0) + { + line = codec->toUnicode(recvbuffer.mid(rbi,len), len); + rbi += len+1; + if (partial) + *partial = false; + return len; + } + + recvbuffer=""; + rbi=0; + + //-1 on return signals "no more data" not error + return -1; + +} + +void TDEProcIO::virtual_hook( int id, void* data ) +{ TDEProcess::virtual_hook( id, data ); } + +#include "tdeprocio.moc" + |