HistoryPacketBuffer.cpp

Go to the documentation of this file.

#include "HistoryPacketBuffer.h"

HistoryPacketBuffer::HistoryPacketBuffer(GnAddr* gnAddr)
{
    m_gnAddr = gnAddr;
}

HistoryPacketBuffer::HistoryPacketBuffer(const HistoryPacketBuffer& other) : QObject()
{
    for(int i = 0; i < NB_PACKET_TYPE; i++)
        this->m_historyPacketBuffer[i] = other.m_historyPacketBuffer[i];
    for(int i = 0; i < NB_PACKET_TYPE-2; i++)
        this->m_historyPacketBufferSN[i] = other.m_historyPacketBufferSN[i];
}

void HistoryPacketBuffer::addPacket(LSRequestPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
    {
        m_historyPacketBuffer[LSREQUEST] = packet.soPv().timestamp();
        m_historyPacketBufferSN[LSREQUEST] = packet.sequenceNumber();
    }
}

void HistoryPacketBuffer::addPacket(LSReplyPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
    {
        m_historyPacketBuffer[LSREPLY] = packet.soPv().timestamp();
        m_historyPacketBufferSN[LSREPLY] = packet.sequenceNumber();
    }
}

void HistoryPacketBuffer::addPacket(GACPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
    {
        m_historyPacketBuffer[GAC] = packet.soPv().timestamp();
        m_historyPacketBufferSN[GAC] = packet.sequenceNumber();
    }
}

void HistoryPacketBuffer::addPacket(GBCPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
    {
        m_historyPacketBuffer[GBC] = packet.soPv().timestamp();
        m_historyPacketBufferSN[GBC] = packet.sequenceNumber();
    }
}

void HistoryPacketBuffer::addPacket(GUCPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
    {
        m_historyPacketBuffer[GUC] = packet.soPv().timestamp();
        m_historyPacketBufferSN[GUC] = packet.sequenceNumber();
    }
}

void HistoryPacketBuffer::addPacket(TSBPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
    {
        m_historyPacketBuffer[TSB] = packet.soPv().timestamp();
        m_historyPacketBufferSN[TSB] = packet.sequenceNumber();
    }
}

void HistoryPacketBuffer::addPacket(SHBPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        m_historyPacketBuffer[SHB] = packet.soPv().timestamp();
}

void HistoryPacketBuffer::addPacket(BeaconPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        m_historyPacketBuffer[BEACON] = packet.soPv().timestamp();
}

bool HistoryPacketBuffer::isDuplicateTimestamp(LSRequestPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        return isDuplicatePacketDetectionTimestampSN(m_historyPacketBuffer[LSREQUEST], packet.soPv().timestamp(), m_historyPacketBufferSN[LSREQUEST], packet.sequenceNumber());
    else
        return false;
}

bool HistoryPacketBuffer::isDuplicateTimestamp(LSReplyPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        return isDuplicatePacketDetectionTimestampSN(m_historyPacketBuffer[LSREPLY], packet.soPv().timestamp(), m_historyPacketBufferSN[LSREPLY], packet.sequenceNumber());
    else
        return false;
}

bool HistoryPacketBuffer::isDuplicateTimestamp(GACPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        return isDuplicatePacketDetectionTimestampSN(m_historyPacketBuffer[GAC], packet.soPv().timestamp(), m_historyPacketBufferSN[GAC], packet.sequenceNumber());
    else
        return false;
}

bool HistoryPacketBuffer::isDuplicateTimestamp(GBCPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        return isDuplicatePacketDetectionTimestampSN(m_historyPacketBuffer[GBC], packet.soPv().timestamp(), m_historyPacketBufferSN[GBC], packet.sequenceNumber());
    else
        return false;
}

bool HistoryPacketBuffer::isDuplicateTimestamp(GUCPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        return isDuplicatePacketDetectionTimestampSN(m_historyPacketBuffer[GUC], packet.soPv().timestamp(), m_historyPacketBufferSN[GUC], packet.sequenceNumber());
    else
        return false;
}

bool HistoryPacketBuffer::isDuplicateTimestamp(TSBPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        return isDuplicatePacketDetectionTimestampSN(m_historyPacketBuffer[TSB], packet.soPv().timestamp(), m_historyPacketBufferSN[TSB], packet.sequenceNumber());
    else
        return false;
}

bool HistoryPacketBuffer::isDuplicateTimestamp(SHBPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        return isDuplicatePacketDetectionTimestamp(m_historyPacketBuffer[SHB], packet.soPv().timestamp());
    else
        return false;
}

bool HistoryPacketBuffer::isDuplicateTimestamp(BeaconPacket packet)
{
    if(packet.soPv().gnAddr() == *m_gnAddr)
        return isDuplicatePacketDetectionTimestamp(m_historyPacketBuffer[BEACON], packet.soPv().timestamp());
    else
        return false;
}

void HistoryPacketBuffer::clear()
{
    for(int i = 0; i < NB_PACKET_TYPE; i++)
        m_historyPacketBuffer[i] = 0;
    for(int i = 0; i < NB_PACKET_TYPE-2; i++)
        m_historyPacketBufferSN[i] = 0;
}