From ce4a32fe52ef09d8f5ff1dd22c001110902b60a2 Mon Sep 17 00:00:00 2001 From: toma Date: Wed, 25 Nov 2009 17:56:58 +0000 Subject: Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features. BUG:215923 git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdelibs@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da --- kdecore/kprocio.cpp | 276 ++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 276 insertions(+) create mode 100644 kdecore/kprocio.cpp (limited to 'kdecore/kprocio.cpp') diff --git a/kdecore/kprocio.cpp b/kdecore/kprocio.cpp new file mode 100644 index 000000000..d6fe33d89 --- /dev/null +++ b/kdecore/kprocio.cpp @@ -0,0 +1,276 @@ +/* This file is part of the KDE libraries + Copyright (C) 1997 David Sweet + + 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 +#endif + +#include + +#include "kprocio.h" + +#include +#include + +class KProcIOPrivate { +public: + KProcIOPrivate() : comm(KProcess::All) {} + KProcess::Communication comm; +}; + +KProcIO::KProcIO ( QTextCodec *_codec) + : codec(_codec), d(new KProcIOPrivate) +{ + rbi=0; + readsignalon=writeready=true; + outbuffer.setAutoDelete(true); + + if (!codec) + { + codec = QTextCodec::codecForName("ISO 8859-1"); + if (!codec) + { + kdError(174) << "Can't create ISO 8859-1 codec!" << endl; + } + } +} + +KProcIO::~KProcIO() +{ + delete d; +} + +void +KProcIO::resetAll () +{ + if (isRunning()) + kill(); + + clearArguments(); + rbi=0; + readsignalon=writeready=true; + + disconnect (this, SIGNAL (receivedStdout (KProcess *, char *, int)), + this, SLOT (received (KProcess *, char *, int))); + + disconnect (this, SIGNAL (receivedStderr (KProcess *, char *, int)), + this, SLOT (received (KProcess *, char *, int))); + + disconnect (this, SIGNAL (wroteStdin(KProcess *)), + this, SLOT (sent (KProcess *))); + + outbuffer.clear(); + +} + +void KProcIO::setComm (Communication comm) +{ + d->comm = comm; +} + +bool KProcIO::start (RunMode runmode, bool includeStderr) +{ + connect (this, SIGNAL (receivedStdout (KProcess *, char *, int)), + this, SLOT (received (KProcess *, char *, int))); + + if (includeStderr) + { + connect (this, SIGNAL (receivedStderr (KProcess *, char *, int)), + this, SLOT (received (KProcess *, char *, int))); + } + + connect (this, SIGNAL (wroteStdin(KProcess *)), + this, SLOT (sent (KProcess *))); + + return KProcess::start (runmode, d->comm); +} + +bool KProcIO::writeStdin (const QString &line, bool appendnewline) +{ + return writeStdin(codec->fromUnicode(line), appendnewline); +} + +bool KProcIO::writeStdin (const QCString &line, bool appendnewline) +{ + QCString *qs = new QCString(line); + + if (appendnewline) + { + *qs += '\n'; + } + + int l = qs->length(); + if (!l) + { + delete qs; + return true; + } + + QByteArray *b = (QByteArray *) qs; + b->truncate(l); // Strip trailing null + + outbuffer.append(b); + + if (writeready) + { + writeready=false; + return KProcess::writeStdin( b->data(), b->size() ); + } + return true; +} + +bool KProcIO::writeStdin(const QByteArray &data) +{ + if (!data.size()) + return true; + QByteArray *b = new QByteArray(data); + outbuffer.append(b); + + if (writeready) + { + writeready=false; + return KProcess::writeStdin( b->data(), b->size() ); + } + return true; +} + +void KProcIO::closeWhenDone() +{ + if (writeready) + { + closeStdin(); + return; + } + outbuffer.append(0); + + return; +} + +void KProcIO::sent(KProcess *) +{ + outbuffer.removeFirst(); + + if (outbuffer.count()==0) + { + writeready=true; + } + else + { + QByteArray *b = outbuffer.first(); + if (!b) + { + closeStdin(); + } + else + { + KProcess::writeStdin(b->data(), b->size()); + } + } + +} + +void KProcIO::received (KProcess *, char *buffer, int buflen) +{ + recvbuffer += QCString(buffer, buflen+1); + + controlledEmission(); +} + +void KProcIO::ackRead () +{ + readsignalon=true; + if (needreadsignal || recvbuffer.length()!=0) + controlledEmission(); +} + +void KProcIO::controlledEmission () +{ + if (readsignalon) + { + needreadsignal=false; + readsignalon=false; //will stay off until read is acknowledged + emit readReady (this); + } + else + { + needreadsignal=true; + } +} + +void KProcIO::enableReadSignals (bool enable) +{ + readsignalon=enable; + + if (enable && needreadsignal) + emit readReady (this); +} + +int KProcIO::readln (QString &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=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 KProcIO::virtual_hook( int id, void* data ) +{ KProcess::virtual_hook( id, data ); } + +#include "kprocio.moc" + -- cgit v1.2.1