denMessageTableSource.cpp

Go to the documentation of this file.

#include "denMessageTableSource.h"

denMessageTableSource::denMessageTableSource()
{
    memset(&m_denm, 0, sizeof m_denm);
    memset(&m_timestamp, 0, sizeof m_timestamp);
    asn_long2INTEGER((INTEGER_t*)&m_timestamp, 0);
    m_T_O_Validity = -1;
    m_T_RepetitionDuration = -1;
    m_T_Repetition = -1;
    m_thread = new QThread;
    QObject::connect(m_thread, SIGNAL(started()), this, SLOT(execute()));
}

denMessageTableSource::denMessageTableSource(const denMessageTableSource &messageTable) : QObject()
{
    setDENM(messageTable.denm());
    setStatus(messageTable.status());
    setTimestamp(messageTable.timestamp());
    setT_O_Validity(messageTable.T_O_Validity());
    setT_RepetitionDuration(messageTable.T_RepetitionDuration());
    setT_Repetition(messageTable.T_Repetition());
    setTrafficClass(messageTable.trafficClass());
    setActionID(messageTable.actionID());
    m_thread = messageTable.m_thread;
}

void denMessageTableSource::execute()
{
    qDebug() << "V" << m_T_O_Validity << "RD" << m_T_RepetitionDuration << "R" << m_T_Repetition;
    m_validity = new denMessageTableSourceThread(m_T_O_Validity);
    m_repetitionDuration = new denMessageTableSourceThread(m_T_RepetitionDuration);
    m_repetition = new denMessageTableSourceThread(m_T_Repetition);

    QObject::connect(m_validity, SIGNAL(T_O_ValiditySignal()), this, SLOT(endOfT_O_Validity()));
    QObject::connect(m_repetitionDuration, SIGNAL(T_RepetitionDurationSignal()), this, SLOT(endOfT_RepetitionDuration()));
    QObject::connect(m_repetition, SIGNAL(T_RepetitionSignal()), this, SLOT(endOfT_Repetition()));

    if(m_validity->timer() > -1)
    {
        m_validity->m_T_O_Validity_timer.start();
        QTimer::singleShot(m_validity->timer(), m_validity, SLOT(endOfT_O_Validity()));
        qDebug() << "singleshot V" << m_validity->timer();
    }
    if(m_repetitionDuration->timer() > -1)
    {
        m_repetitionDuration->m_T_RepetitionDuration_timer.start();
        QTimer::singleShot(m_repetitionDuration->timer(), m_repetitionDuration, SLOT(endOfT_RepetitionDuration()));
        qDebug() << "singleshot RD" << m_repetitionDuration->timer();
    }
    if(m_repetition->timer() > -1)
    {
        m_repetition->m_T_Repetition_timer.start();
        QTimer::singleShot(m_repetition->timer(), m_repetition, SLOT(endOfT_Repetition()));
        qDebug() << "singleshot R" << m_repetition->timer();
    }
}

denMessageTableSource& denMessageTableSource::operator =(const denMessageTableSource& other)
{
    this->m_destination = other.destinationArea();
    this->setDENM(other.denm());
    this->setStatus(other.status());
    this->setTimestamp(other.timestamp());
    this->setT_O_Validity(other.T_O_Validity());
    this->setT_RepetitionDuration(other.T_RepetitionDuration());
    this->setT_Repetition(other.T_Repetition());
    this->setTrafficClass(other.trafficClass());
    this->setActionID(other.actionID());
    this->m_validity = other.m_validity;
    this->m_repetitionDuration = other.m_repetitionDuration;
    this->m_repetition = other.m_repetition;

    return *this;
}

denMessageTableSource::~denMessageTableSource()
{
    setT_O_Validity(-1);
    setT_RepetitionDuration(-1);
    setT_Repetition(-1);
    m_repetition->stopTimer();
    m_repetitionDuration->stopTimer();
    m_validity->stopTimer();
}

void denMessageTableSource::endOfT_O_Validity()
{
    /* 1) Stop timer T_Repetition if exists. */
    printf("Repetition Termination in DMTS::endOfTOV\n");
    m_repetition->setTimer(-1);
    m_repetition->stopTimer();

    /* 2) Stop timer T_RepetitionDuration if exists. */
    printf("RepetitionDuration Termination in DMTS::endOfTOV\n");
    m_repetitionDuration->setTimer(-1);
    m_repetitionDuration->stopTimer();

    /* 3) Discard the expired DENM entry from the originating ITS-S message table. */
    printf("EMIT TOVSignal\n");
    emit T_O_ValiditySignal(m_denm.denm.management.actionID);
}

void denMessageTableSource::endOfT_RepetitionDuration()
{
    /* 1) Stop timer T_Repetition. */
    printf("Repetition Termination in DMTS::endOfRD\n");
    m_repetition->setTimer(-1);
    m_repetition->stopTimer();
}

void denMessageTableSource::endOfT_Repetition()
{

    /* 1) Pass the DENM to ITS networking & transport layer. */
    printf("EMIT TRSignal\n");
    emit T_RepetitionSignal(m_denm.denm.management.actionID);

    if(m_repetition->timer() > -1)
    {
        /* 2) Restart timer T_Repetition. */
        printf("Start Repetition timer\n");
        qDebug() << m_repetition->timer();
        m_repetition->m_T_Repetition_timer.start();
        m_repetition->m_t.singleShot(m_repetition->timer(), m_repetition, SLOT(endOfT_Repetition()));
        printf("EndOfR\n");
//        emit DENMrepeated();
    }

}