BroadcastForwardingPacketBuffer.cpp

Go to the documentation of this file.

#include "BroadcastForwardingPacketBuffer.h"

int BroadcastForwardingPacketBuffer::nbBCForwardingPacketQueued = 0;

BroadcastForwardingPacketBuffer::BroadcastForwardingPacketBuffer()
{
    m_mutex = new QMutex;
}

BroadcastForwardingPacketBuffer::BroadcastForwardingPacketBuffer(const BroadcastForwardingPacketBuffer& other)
{
    this->m_bcForwardPacketBuffer = other.m_bcForwardPacketBuffer;
}

void BroadcastForwardingPacketBuffer::addPacket(BasicHeader bh, CommonHeader ch, GACPacket gac, QByteArray payload, QByteArray sender, uchar* destination, uchar* forwarder)
{
    QMutexLocker locker(m_mutex);
    BroadcastForwardingPacketEntry bfpe(bh, ch, gac, payload, sender, destination, forwarder);

    /* If the number of packet exceed the max buffer size, the first packet will be dropped and the packet will be added to the end of the queue */
    if(nbBCForwardingPacketQueued >= itsGnBcForwardingPacketBufferSize)
    {
        m_bcForwardPacketBuffer.pop_front();
        nbBCForwardingPacketQueued -= 1;
    }

    /* If packet is already in the buffer, replace the old one with the new one */
    if(int pos = m_bcForwardPacketBuffer.indexOf(bfpe) >= 0)
        m_bcForwardPacketBuffer.replace(pos, bfpe);
    else
    {
        bfpe.m_elapsed.start();
        m_bcForwardPacketBuffer.push_back(bfpe);
        nbBCForwardingPacketQueued += 1;
    }
}

void BroadcastForwardingPacketBuffer::addPacket(BasicHeader bh, CommonHeader ch, GBCPacket gbc, QByteArray payload, QByteArray sender, uchar* destination, uchar* forwarder)
{
    QMutexLocker locker(m_mutex);
    BroadcastForwardingPacketEntry bfpe(bh, ch, gbc, payload, sender, destination, forwarder);

    /* If the number of packet exceed the max buffer size, the first packet will be dropped and the packet will be added to the end of the queue */
    if(nbBCForwardingPacketQueued >= itsGnBcForwardingPacketBufferSize)
    {
        m_bcForwardPacketBuffer.pop_front();
        nbBCForwardingPacketQueued -= 1;
    }

    /* If packet is already in the buffer, replace the old one with the new one */
    int pos = m_bcForwardPacketBuffer.indexOf(bfpe);
    if(pos >= 0)
        m_bcForwardPacketBuffer.replace(pos, bfpe);
    else
    {
        bfpe.m_elapsed.start();
        m_bcForwardPacketBuffer.push_back(bfpe);
        nbBCForwardingPacketQueued += 1;
    }
}

void BroadcastForwardingPacketBuffer::addPacket(BasicHeader bh, CommonHeader ch, TSBPacket tsb, QByteArray payload, QByteArray sender)
{
    QMutexLocker locker(m_mutex);
    BroadcastForwardingPacketEntry bfpe(bh, ch, tsb, payload, sender);

    /* If the number of packet exceed the max buffer size, the first packet will be dropped and the packet will be added to the end of the queue */
    if(nbBCForwardingPacketQueued >= itsGnBcForwardingPacketBufferSize)
    {
        m_bcForwardPacketBuffer.pop_front();
        nbBCForwardingPacketQueued -= 1;
    }

    /* If packet is already in the buffer, replace the old one with the new one */
    if(int pos = m_bcForwardPacketBuffer.indexOf(bfpe) >= 0)
        m_bcForwardPacketBuffer.replace(pos, bfpe);
    else
    {
        bfpe.m_elapsed.start();
        m_bcForwardPacketBuffer.push_back(bfpe);
        nbBCForwardingPacketQueued += 1;
    }
}

void BroadcastForwardingPacketBuffer::addPacket(BasicHeader bh, CommonHeader ch, SHBPacket shb, QByteArray payload, QByteArray sender)
{
    QMutexLocker locker(m_mutex);
    BroadcastForwardingPacketEntry bfpe(bh, ch, shb, payload, sender);

    /* If the number of packet exceed the max buffer size, the first packet will be dropped and the packet will be added to the end of the queue */
    if(nbBCForwardingPacketQueued >= itsGnBcForwardingPacketBufferSize)
    {
        m_bcForwardPacketBuffer.pop_front();
        nbBCForwardingPacketQueued -= 1;
    }

    /* If packet is already in the buffer, replace the old one with the new one */
    if(int pos = m_bcForwardPacketBuffer.indexOf(bfpe) >= 0)
        m_bcForwardPacketBuffer.replace(pos, bfpe);
    else
    {
        bfpe.m_elapsed.start();
        m_bcForwardPacketBuffer.push_back(bfpe);
        nbBCForwardingPacketQueued += 1;
    }
}

bool BroadcastForwardingPacketBuffer::isDuplicateTimestamp(GACPacket packet)
{
    bool b = false;
    QMutexLocker locker(m_mutex);
    for(QVector<BroadcastForwardingPacketEntry>::Iterator i = m_bcForwardPacketBuffer.begin();i != m_bcForwardPacketBuffer.end(); ++i)
        if(i->commonHeader().headerType() == CommonHeader::headerType_geoUnicast && isDuplicatePacketDetectionTimestampSN(i->gacPacket().soPv().timestamp(), packet.soPv().timestamp(), i->gacPacket().sequenceNumber(), packet.sequenceNumber()))
            b = true;
    return b;
}

bool BroadcastForwardingPacketBuffer::isDuplicateTimestamp(GBCPacket packet)
{
    bool b = false;
    QMutexLocker locker(m_mutex);
    for(QVector<BroadcastForwardingPacketEntry>::Iterator i = m_bcForwardPacketBuffer.begin();i != m_bcForwardPacketBuffer.end(); ++i)
        if(i->commonHeader().headerType() == CommonHeader::headerType_geoBroadcast && isDuplicatePacketDetectionTimestampSN(i->gbcPacket().soPv().timestamp(), packet.soPv().timestamp(), i->gbcPacket().sequenceNumber(), packet.sequenceNumber()))
            b = true;
    return b;
}

bool BroadcastForwardingPacketBuffer::isDuplicateTimestamp(TSBPacket packet)
{
    bool b = false;
    QMutexLocker locker(m_mutex);
    for(QVector<BroadcastForwardingPacketEntry>::Iterator i = m_bcForwardPacketBuffer.begin();i != m_bcForwardPacketBuffer.end(); ++i)
        if(i->commonHeader().headerType() == CommonHeader::headerType_topologicallyScopedBroadcast && i->commonHeader().headerSubType() == CommonHeader::headerSubTypeTopologicallyScopedBroadcast_multiHop && isDuplicatePacketDetectionTimestampSN(i->tsbPacket().soPv().timestamp(), packet.soPv().timestamp(), i->tsbPacket().sequenceNumber(), packet.sequenceNumber()))
            b = true;
    return b;
}

bool BroadcastForwardingPacketBuffer::isDuplicateTimestamp(SHBPacket packet)
{
    bool b = false;
    QMutexLocker locker(m_mutex);
    for(QVector<BroadcastForwardingPacketEntry>::Iterator i = m_bcForwardPacketBuffer.begin();i != m_bcForwardPacketBuffer.end(); ++i)
        if(i->commonHeader().headerType() == CommonHeader::headerType_topologicallyScopedBroadcast && i->commonHeader().headerSubType() == CommonHeader::headerSubTypeTopologicallyScopedBroadcast_singleHop && isDuplicatePacketDetectionTimestamp(i->tsbPacket().soPv().timestamp(), packet.soPv().timestamp()))
            b = true;
    return b;
}

void BroadcastForwardingPacketBuffer::clear()
{
    QMutexLocker locker(m_mutex);
    m_bcForwardPacketBuffer.clear();
    nbBCForwardingPacketQueued = 0;
}