UnicastForwardingPacketBuffer.cpp

Go to the documentation of this file.

#include "UnicastForwardingPacketBuffer.h"

int UnicastForwardingPacketBuffer::nbUCForwardingPacketQueued = 0;

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

UnicastForwardingPacketBuffer::UnicastForwardingPacketBuffer(const UnicastForwardingPacketBuffer& other)
{
    this->m_mutex = other.m_mutex;
    this->m_ucForwardPacketBuffer = other.m_ucForwardPacketBuffer;
}

void UnicastForwardingPacketBuffer::addPacket(BasicHeader bh, CommonHeader ch, GUCPacket guc, QByteArray payload, QByteArray sender)
{
    m_mutex->lock();
    UnicastForwardingPacketEntry bfpe(bh, ch, guc, 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(nbUCForwardingPacketQueued >= itsGnUcForwardingPacketBufferSize)
    {
        m_ucForwardPacketBuffer.pop_front();
        nbUCForwardingPacketQueued -= 1;
    }

    /* If packet is already in the buffer, replace the old one with the new one */

    bfpe.m_elapsed.start();
    m_ucForwardPacketBuffer.push_back(bfpe);
    nbUCForwardingPacketQueued += 1;
    m_mutex->unlock();
}

bool UnicastForwardingPacketBuffer::erase(GUCPacket packet)
{
    bool b = false;
    int j = 0;
    for(QVector<UnicastForwardingPacketEntry>::Iterator i = m_ucForwardPacketBuffer.begin();j < m_ucForwardPacketBuffer.size(); ++i, j++)
        if(isDuplicatePacketDetectionTimestampSN(i->gucPacket().soPv().timestamp(), packet.soPv().timestamp(), i->gucPacket().sequenceNumber(), packet.sequenceNumber()))
        {
            m_ucForwardPacketBuffer.erase(i);
            nbUCForwardingPacketQueued -= 1;
            b = true;
        }
    return b;
}

bool UnicastForwardingPacketBuffer::isDuplicateTimestamp(GUCPacket packet)
{
    bool b = false;
    m_mutex->lock();
    for(QVector<UnicastForwardingPacketEntry>::Iterator i = m_ucForwardPacketBuffer.begin();i != m_ucForwardPacketBuffer.end(); ++i)
        if(isDuplicatePacketDetectionTimestampSN(i->gucPacket().soPv().timestamp(), packet.soPv().timestamp(), i->gucPacket().sequenceNumber(), packet.sequenceNumber()))
            b = true;
    m_mutex->unlock();
    return b;
}

void UnicastForwardingPacketBuffer::clear()
{
    m_mutex->lock();
    m_ucForwardPacketBuffer.clear();
    nbUCForwardingPacketQueued = 0;
    m_mutex->unlock();
}