ThreadDataTransfert.h

/**
* @headerfile ThreadDataTransfert.cpp
* @author   Ulrich Kemloh <kemlohulrich@gmail.com>
* @version 0.1
* Copyright (C) <2009-2010>
*
* @section LICENSE
* This file is part of OpenPedSim.
*
* OpenPedSim is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* any later version.
*
* OpenPedSim 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 General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with OpenPedSim. If not, see <http://www.gnu.org/licenses/>.
*
* @section DESCRIPTION
* This class provides a thread utility that is charged of
* asynchronously receive trajectories (streaming)
* and  put them in the adequate data structure to be read by the Visualisation Thread.
*
* \brief Thread that reads data from the socket and parse it
*
*
*  Created on: 24.05.2009
*
*/



#ifndef THREADDATATRANSFERT_H_
#define THREADDATATRANSFERT_H_

#include <QThread>
#include <QObject>
#include <QtNetwork/QtNetwork>

class QThread;
class QObject;
class SyncData;
class QDomNode;
class QString;
class QDomNodeList;
class FacilityGeometry;

extern SyncData extern_trajectories_firstSet;
extern bool extern_shutdown_visual_thread;

class ThreadDataTransfer: public QThread {

    Q_OBJECT

public:
    ThreadDataTransfer(QObject *parent = 0);
    virtual ~ThreadDataTransfer();
    void run();
    void setListeningPort(int port);

    /// \brief force the thread to do some cleaning work and shutdown
    void shutdown();

    /// parse a shape node
    void parseShapeNode(QDomNode shapes);

    /// parse a geometry node
    void parseHeaderNode(QDomNode header);

    /// parse data node
    void parseDataNode(QDomNodeList data);

    //old and new geometry format
    void InitHeader(int major, int minor, int patch);


private:
    QString getTagValueFromElement(QDomNode node,
                                   const char * tagName);

Q_SIGNALS:
    void signal_start();
    void signal_stop();
    void signal_controlSequence(const char* sex);

    void signal_CurrentAction(QString msg);

    /// connect to the setFrameRateSlot
    /// of the visualisation Thread
    //void signal_frameRate(float fps);

    /// start the visual thread,
    /// once header has been received
    void signal_startVisualisationThread(QString data, int numberOfAgents,float frameRate);

    /// shutdown the visio thread
    void signal_stopVisualisationThread(bool clearAndStop);

    void signal_errorMessage(QString geometry);

public Q_SLOTS:
    //udp
    void slotProcessPendingDatagrams();
    //tcp
    void slotHandleConnection();
    void slotReadMessage();
    void slotProcessMessage(QString& data);
    void slotConnectionClosed();
    void slotDisplayError(QAbstractSocket::SocketError socketError);


private:
    int m_port;
    QUdpSocket* udpSocket;
    QTcpServer* tcpServer;
    bool headerParsed;
    long errNr;
    QString geoData;
    int numberOfAgents;
    float frameRate;
    bool finished;

    // temp variables to be removed in the next versions
    //header dependant variables
    QString _jps_xPos;
    QString _jps_yPos;
    QString _jps_zPos;
    QString _jps_radiusA;
    QString _jps_radiusB;
    QString _jps_ellipseOrientation;
    QString _jps_ellipseColor;
};

#endif /* THREADDATATRANSFERT_H_ */