RepetitionPacketEntry.cpp

Go to the documentation of this file.

#include "RepetitionPacketEntry.h"

RepetitionPacketEntry::RepetitionPacketEntry()
{
    m_timer = new QTimer(this);
    m_elapsed = new QElapsedTimer();
}

RepetitionPacketEntry::RepetitionPacketEntry(gnDataRequest_t gnDR)
{
    m_gnDR = gnDR;
    if(m_gnDR.repetitionInterval == NULL)
        m_gnDR.repetitionInterval = (quint16*) calloc(1, sizeof(quint16));
    if(m_gnDR.maximumRepetitionTime == NULL)
        m_gnDR.maximumRepetitionTime = (quint16*) calloc(1, sizeof(quint16));
    m_timer = new QTimer(this);
    m_elapsed = new QElapsedTimer();
}

RepetitionPacketEntry::RepetitionPacketEntry(const RepetitionPacketEntry& other) : QObject()
{
    m_gnDR = other.m_gnDR;
    m_timer = other.m_timer;
    m_elapsed = other.m_elapsed;
}

bool RepetitionPacketEntry::operator==(const RepetitionPacketEntry &other)
{
    bool b = true;
    if(m_gnDR.payload.toHex() != other.m_gnDR.payload.toHex())
        b = false;
    if(m_gnDR.destinationPort != other.m_gnDR.destinationPort)
        b = false;
    if(m_gnDR.packetTransportType != other.m_gnDR.packetTransportType)
        b = false;
    if(m_gnDR.packetTransportSubType!= other.m_gnDR.packetTransportSubType)
        b = false;
    if(m_gnDR.destinationAddress.present != other.m_gnDR.destinationAddress.present)
        b = false;
    else if(m_gnDR.destinationAddress.present == destinationAddress_PR_MID)
    {
        if(m_gnDR.destinationAddress.choice.gnAddr.stationType_StationCountryCode != other.m_gnDR.destinationAddress.choice.gnAddr.stationType_StationCountryCode)
            b = false;
        for(int i=0; i < 6; i++)
            if(m_gnDR.destinationAddress.choice.gnAddr.mid[i] != other.m_gnDR.destinationAddress.choice.gnAddr.mid[i])
                b = false;
    }
    return b;
}

RepetitionPacketEntry& RepetitionPacketEntry::operator=(const RepetitionPacketEntry &other)
{
    m_gnDR = other.m_gnDR;

    return *this;
}

void RepetitionPacketEntry::execute()
{
    m_timer->setInterval(*m_gnDR.repetitionInterval);
    m_timer->setSingleShot(false);
    connect(m_timer, SIGNAL(timeout()), this, SLOT(repeat()));
    m_elapsed->start();
    m_timer->start();
}

void RepetitionPacketEntry::repeat()
{
    if(m_elapsed->elapsed() >= *m_gnDR.maximumRepetitionTime)
    {
        emit isOver();
        kill();
    }
    else if(m_timer->isActive())
        emit sendPacket(m_gnDR);
}

void RepetitionPacketEntry::kill()
{
    m_timer->stop();
    this->deleteLater();
}