BroadcastForwardingPacketEntry.cpp

Go to the documentation of this file.

#include "BroadcastForwardingPacketEntry.h"

BroadcastForwardingPacketEntry::BroadcastForwardingPacketEntry()
{
    m_bh = BasicHeader();
    m_ch = CommonHeader();
    m_payload = QByteArray();
    m_sender = QByteArray();
}

BroadcastForwardingPacketEntry::BroadcastForwardingPacketEntry(BasicHeader bh, CommonHeader ch, GACPacket packet, QByteArray payload, QByteArray sender, uchar* destination, uchar* forwarder)
{
    m_bh = bh;
    m_ch = ch;
    m_payload = payload;
    m_gac = packet;
    m_sender = sender;
    for(int i=0; i<6; i++)
    {
        m_destination[i] = destination[i];
        m_forwarder[i] = forwarder[i];
    }
}

BroadcastForwardingPacketEntry::BroadcastForwardingPacketEntry(BasicHeader bh, CommonHeader ch, GBCPacket packet, QByteArray payload, QByteArray sender, uchar* destination, uchar* forwarder)
{
    m_bh = bh;
    m_ch = ch;
    m_payload = payload;
    m_gbc = packet;
    m_sender = sender;
    for(int i=0; i<6; i++)
    {
        m_destination[i] = destination[i];
        m_forwarder[i] = forwarder[i];
    }
}

BroadcastForwardingPacketEntry::BroadcastForwardingPacketEntry(BasicHeader bh, CommonHeader ch, TSBPacket packet, QByteArray payload, QByteArray sender)
{
    m_bh = bh;
    m_ch = ch;
    m_payload = payload;
    m_tsb = packet;
    m_sender = sender;
}

BroadcastForwardingPacketEntry::BroadcastForwardingPacketEntry(BasicHeader bh, CommonHeader ch, SHBPacket packet, QByteArray payload, QByteArray sender)
{
    m_bh = bh;
    m_ch = ch;
    m_payload = payload;
    m_shb = packet;
    m_sender = sender;
}

bool BroadcastForwardingPacketEntry::operator==(const BroadcastForwardingPacketEntry& other)
{
    if(other.commonHeader().headerType() != m_ch.headerType())
        return false;

    switch(other.commonHeader().headerType())
    {
    case CommonHeader::headerType_geoAnycast:
        return isDuplicatePacketDetectionTimestampSN(m_gac.soPv().timestamp(), other.m_gac.soPv().timestamp(), m_gac.sequenceNumber(), other.m_gac.sequenceNumber());
        break;
    case CommonHeader::headerType_geoBroadcast:
        return isDuplicatePacketDetectionTimestampSN(m_gbc.soPv().timestamp(), other.m_gbc.soPv().timestamp(), m_gbc.sequenceNumber(), other.m_gbc.sequenceNumber());
        break;
    case CommonHeader::headerType_topologicallyScopedBroadcast:
        switch(other.commonHeader().headerType())
        {
        case CommonHeader::headerSubTypeTopologicallyScopedBroadcast_singleHop:
            return isDuplicatePacketDetectionTimestamp(m_shb.soPv().timestamp(), other.m_shb.soPv().timestamp());
            break;
        case CommonHeader::headerSubTypeTopologicallyScopedBroadcast_multiHop:
            return isDuplicatePacketDetectionTimestampSN(m_tsb.soPv().timestamp(), other.m_tsb.soPv().timestamp(), m_tsb.sequenceNumber(), other.m_tsb.sequenceNumber());
            break;
        }
    }
    return false;
}

BroadcastForwardingPacketEntry::BroadcastForwardingPacketEntry(const BroadcastForwardingPacketEntry& other) : PacketBuffersEntry()
{
    m_gac = other.m_gac;
    m_gbc = other.m_gbc;
    m_shb = other.m_shb;
    m_tsb = other.m_tsb;
    m_payload = other.m_payload;
    m_sender = other.m_sender;
    for(int i=0; i<6; i++)
    {
        m_destination[i] = other.m_destination[i];
        m_forwarder[i] = other.m_forwarder[i];
    }
}

void BroadcastForwardingPacketEntry::updateSourcePacketSoPv(LongPositionVector lpv)
{
    switch(m_ch.headerType())
    {
    case CommonHeader::headerType_geoAnycast:
        if(m_gac.soPv().gnAddr() == lpv.gnAddr())
            m_gac.setSoPv(lpv);
        break;
    case CommonHeader::headerType_geoBroadcast:
        if(m_gbc.soPv().gnAddr() == lpv.gnAddr())
            m_gbc.setSoPv(lpv);
        break;
    case CommonHeader::headerType_topologicallyScopedBroadcast:
        switch (m_ch.headerSubType())
        {
        case CommonHeader::headerSubTypeTopologicallyScopedBroadcast_singleHop:
            if(m_shb.soPv().gnAddr() == lpv.gnAddr())
                m_shb.setSoPv(lpv);
            break;
        case CommonHeader::headerSubTypeTopologicallyScopedBroadcast_multiHop:
            if(m_tsb.soPv().gnAddr() == lpv.gnAddr())
                m_tsb.setSoPv(lpv);
            break;
        }
        break;
    }
}