Russian Qt Forum

/* stdInReader.h
  under [GNU GPL v.2] from Denjs
  Простой класс-обертка для работы с потоками STDIN|STDOUT|STDERR.
  ver.2009.09.14 (естественно альфа, но работает и это главное) 

  UTF-8 russian encoded file
 
*/
#include <QtCore> 
#include <QThread> 
#include <QFile> 

class stdInReader : public QThread
 {
 Q_OBJECT

 public:
	stdInReader(QObject * parent = 0);
//	void run();
	int init();//opend threads and became ready to work. 
	/*
	      return 
		1 if some errors was happened
		0 of all ok
		-1 if can`t oopen stdIn
		-2 if can`t oopen stdOut
		-3 if can`t oopen stdErr
	*/
	void run();
 signals:
        void received_StdIn(const QByteArray &data);

 public slots:
	int send_StdOut(const QByteArray &_data);
	int send_StdErr(const QByteArray &_data);
 private: 
	QFile stdIn;
	QFile stdOut;
	QFile stdErr;
	QByteArray data;
	bool inited;
 };

/*  stdInReader.cpp :

  UTF-8 russian encoded file

*/
#include <stdInReader.h>

stdInReader::stdInReader(QObject * parent)
	: QThread (parent)
 {
	inited=false;
 }

int stdInReader::init()
 {
   inited=false;
   if (! stdIn.open(stdin, QIODevice::ReadOnly)) return -1;
   if (! stdOut.open(stdout, QIODevice::WriteOnly)) return -2;
   if (! stdErr.open(stdout, QIODevice::WriteOnly)) return -3;
   inited=true;
   return 0;
 };

//-----------------------------------------------------
void stdInReader::run()
 {
	
    if (!inited) return;
    while (true)
      {
	/*/ while (stdIn.bytesAvailable()==0) //<------- ВНИМАНИЕ! так - НЕ работает... да) QT 4.5
			                    //почему-то пока не начнешь читать, размер буфера не обновится...
		this->msleep(1000);
	/* - */
	data=stdIn.read(1); //тут "блокирующее чтение"... потому никаких sleep не надо
	if (stdIn.bytesAvailable()>0)
	   data.append(stdIn.read(stdIn.bytesAvailable()));//и только тут буфер покажет сколько нам послупило данных. лол)
	emit received_StdIn(data);
	
	/*-/
	////------ далее - демо код для примера ----------
	//// что бы оно заработало - надо stdOut.open... раскомментировать выше...
		stdOut.write(QByteArray().append(QString("[")));
		stdOut.write(data);
		stdOut.write(QByteArray().append(QString("]")));
		stdOut.flush();//отправим сразу...
	/* - */
      };
    return;
 }

//-----------------------------------------------------
int stdInReader::send_StdOut(const QByteArray &_data)
  {
	int rz=stdOut.write(_data);
	stdOut.flush();
	return rz;
  }

//-----------------------------------------------------
int stdInReader::send_StdErr(const QByteArray &_data)
  {
	int rz=stdErr.write(_data);
	stdErr.flush();
	return rz;
  }

#!/bin/bash

./testcon.bin <<ENDSS
hello!
how are you!
ENDSS

QFile stdIn;
stdIn.open(stdin, QIODevice::ReadOnly)

	data=stdIn.read(1); //тут "блокирующее чтение"... потому никаких sleep не надо
	if (stdIn.bytesAvailable()>0)
	   data.append(stdIn.read(stdIn.bytesAvailable()));//и только тут буфер покажет сколько нам послупило данных. лол)

class Receiver : public QObject
{
 Q_OBJECT
slots:
void readyRead()
{
QTextStream input(stdin);
QString msg = input.read(256);
// TODO
}
}

Receiver recevier;
QSocketNotifier *noti = new QSocketNotifier(STDIN_FILENO, QSocketNotifier::Read, qApp);

    noti->connect(noti, SIGNAL(activated(int)), &recevier, SLOT(readyRead()));