Rename class KProcIO to TDEProcIOHEADmaster

Signed-off-by: Michele Calgaro <michele.calgaro@yahoo.it>

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"
+