denMessageTableSource.h

Go to the documentation of this file.

#ifndef denMessageTableSource_H
#define denMessageTableSource_H

#include <QObject>
#include <QThread>
#include <QTimer>
#include <QElapsedTimer>

#include <DestinationAreaData.h>
#include <denMessageTableSourceThread.h>

#include <DENM.h>
#include <ActionIDData.h>

#include <facilitiesApi.h>

#define MAX_TIMEOUT 86400001

class denMessageTableSource : public QObject
{
    Q_OBJECT

public:

    enum
    {
        state_NONE,
        state_ACTIVE,
        state_CANCELED,
        state_NEGATED
    };

    /* Public members */
    denMessageTableSourceThread *m_validity;
    denMessageTableSourceThread *m_repetitionDuration;
    denMessageTableSourceThread *m_repetition;
    QThread *m_thread;
    /* Constructors */
    denMessageTableSource();
    explicit denMessageTableSource(const denMessageTableSource& messageTable);
    ~denMessageTableSource();

    /* Getters */
    DENM_t denm() const{return m_denm;}
    int status() const{return m_status;}
    TimestampIts_t timestamp() const{return m_timestamp;}
    qint64 T_O_Validity() const{return m_T_O_Validity;}
    qint32 T_RepetitionDuration() const{return m_T_RepetitionDuration;}
    qint32 T_Repetition() const{return m_T_Repetition;}
    quint8 trafficClass() const{return m_trafficClass;}
    ActionID_t actionID() const{return m_actionID;}
    DestinationAreaData destinationArea() const{return m_destination;}

    /* Setters */
    void setStatus(int s){m_status = s;}
    void setTimestamp(TimestampIts_t t)
    {
        unsigned long l;
        asn_INTEGER2ulong((INTEGER_t*)&t, &l);
        memset(&m_timestamp, 0, sizeof m_timestamp);
        asn_ulong2INTEGER((INTEGER_t*)&m_timestamp, l);
    }
    void setDENM(DENM_t d)
    {
        m_denm.header = setItsPduHeader(d.header);
        m_denm.denm = setDecentralizedEnvironmentalNotificationMessage(d.denm);
    }
    void setT_O_Validity(qint64 t){m_T_O_Validity = t;}
    void setT_RepetitionDuration(qint32 t){m_T_RepetitionDuration = t;}
    void setT_Repetition(qint32 t){m_T_Repetition = t;}
    void setTrafficClass(quint8 t){m_trafficClass = t;}
    void setActionID(ActionID_t a)
    {
        m_actionID.originatingStationID = setStationID(a.originatingStationID);
        m_actionID.sequenceNumber = setSequenceNumber(a.sequenceNumber);
    }
    void setDestinationArea(DestinationAreaData d){m_destination = d;}

    /* Operators */
    denMessageTableSource& operator=(const denMessageTableSource& other);

signals:
    void T_O_ValiditySignal(ActionID_t);
    void T_RepetitionSignal(ActionID_t);
    void DENMrepeated();

private:
    DestinationAreaData m_destination;
    DENM_t m_denm;
    int m_status;
    TimestampIts_t m_timestamp;
    qint64 m_T_O_Validity;
    qint32 m_T_RepetitionDuration;
    qint32 m_T_Repetition;
    quint8 m_trafficClass;
    ActionID_t m_actionID;
public slots:
    void endOfT_O_Validity();
    void endOfT_RepetitionDuration();
    void endOfT_Repetition();
    void execute();

};

#endif // denMessageTableSource_H