You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
107 lines
2.4 KiB
107 lines
2.4 KiB
/***************************************************************************
|
|
KInputChildProcess.cpp - description
|
|
-------------------
|
|
begin : Tue May 2 2000
|
|
copyright : (C) 2000 by Martin Heni
|
|
email : martin@heni-online.de
|
|
***************************************************************************/
|
|
#include <unistd.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <tqstring.h>
|
|
|
|
#include "KInputChildProcess.h"
|
|
#include "KInputChildProcess.moc"
|
|
|
|
|
|
KInputChildProcess::~KInputChildProcess()
|
|
{
|
|
delete buffer;
|
|
delete childConnect;
|
|
}
|
|
KInputChildProcess::KInputChildProcess(int size_buffer)
|
|
: TQObject(0,0)
|
|
{
|
|
buffersize=size_buffer;
|
|
if (buffersize<1) buffersize=1024;
|
|
buffer=new char[buffersize];
|
|
inputbuffer="";
|
|
terminateChild=false;
|
|
}
|
|
bool KInputChildProcess::exec()
|
|
{
|
|
int pos;
|
|
TQString s;
|
|
|
|
childConnect=new KChildConnect;
|
|
if (!childConnect) return false;
|
|
connect(childConnect,TQ_SIGNAL(signalReceiveMsg(KEMessage *,int)),
|
|
this,TQ_SLOT(slotReceiveMsg(KEMessage *,int)));
|
|
do
|
|
{
|
|
// Wait for input
|
|
if (feof(stdin))
|
|
{
|
|
sleep(1);
|
|
continue;
|
|
}
|
|
|
|
if (!fgets(buffer,buffersize,stdin) )
|
|
{
|
|
continue;
|
|
}
|
|
s=buffer;
|
|
s=inputbuffer+s;
|
|
// printf("ChildABC '%s'\n",(const char *)s);
|
|
// fflush(stdout);
|
|
pos=s.findRev(KEMESSAGE_CR);
|
|
if (pos<0)
|
|
{
|
|
inputbuffer=s;
|
|
}
|
|
else if (pos+KEMESSAGE_CR.length()==s.length())
|
|
{
|
|
// CR at the end...calling receive
|
|
childConnect->Receive(s);
|
|
}
|
|
else
|
|
{
|
|
inputbuffer=s.right(s.length()-pos-KEMESSAGE_CR.length());
|
|
s=s.left(pos+KEMESSAGE_CR.length());
|
|
// printf("s='%s' in='%s'\n",(const char *)s,(const char *)inputbuffer);
|
|
childConnect->Receive(s);
|
|
}
|
|
}while(!terminateChild);
|
|
return true;
|
|
}
|
|
|
|
void KInputChildProcess::Terminate()
|
|
{
|
|
terminateChild=true;
|
|
}
|
|
bool KInputChildProcess::IsTerminated()
|
|
{
|
|
return terminateChild;
|
|
}
|
|
|
|
bool KInputChildProcess::ReceiveMsg(KEMessage *,int )
|
|
{
|
|
return false;
|
|
}
|
|
void KInputChildProcess::slotReceiveMsg(KEMessage *msg,int id)
|
|
{
|
|
if (!ReceiveMsg(msg,id)) // made for virtual override
|
|
{
|
|
// otherwise emit signal
|
|
emit signalReceiveMsg(msg,id);
|
|
}
|
|
}
|
|
bool KInputChildProcess::SendMsg(KEMessage *msg)
|
|
{
|
|
if (childConnect) return childConnect->SendMsg(msg);
|
|
return false;
|
|
}
|
|
|
|
|