/*
 *  $Id: readerthread.cpp 54 2008-01-10 00:24:52Z mbroeker $
 * $URL: http://localhost/svn/cpp/qMonitor/trunk/readerthread.cpp $
 */

#include "include/readerthread.h"
#include <exception>

readerThread::readerThread (Monitor * parent)
{
    handle = parent;
}

void readerThread::run ()
{
    std::string s;
    DataChangeEvent *dce;

    try {
        PacketParser reader (-1);

        for (;;) {
            while (reader.dataAvailable ()) {
                reader.setProtocol (handle->getProtocol ());
                reader.setPort (handle->getPort ());

                s = reader.read ();

                if (s != "") {
                    dce = new DataChangeEvent (s.c_str ());
                    QApplication::postEvent ((QObject *) handle, (QEvent *) dce);
                }
            }
        }
    } catch (std::exception const &e) {
        dce = new DataChangeEvent (e.what ());
        QApplication::postEvent ((QObject *) handle, (QEvent *) dce);
        std::cerr << e.what () << std::endl;
    }
}