summaryrefslogtreecommitdiffstats
path: root/kdecore/kprocio.cpp
diff options
context:
space:
mode:
authortoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
committertoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
commitce4a32fe52ef09d8f5ff1dd22c001110902b60a2 (patch)
tree5ac38a06f3dde268dc7927dc155896926aaf7012 /kdecore/kprocio.cpp
downloadtdelibs-ce4a32fe52ef09d8f5ff1dd22c001110902b60a2.tar.gz
tdelibs-ce4a32fe52ef09d8f5ff1dd22c001110902b60a2.zip
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
Diffstat (limited to 'kdecore/kprocio.cpp')
-rw-r--r--kdecore/kprocio.cpp276
1 files changed, 276 insertions, 0 deletions
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 <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 "kprocio.h"
+
+#include <kdebug.h>
+#include <qtextcodec.h>
+
+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<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 KProcIO::virtual_hook( int id, void* data )
+{ KProcess::virtual_hook( id, data ); }
+
+#include "kprocio.moc"
+