LocationServicePacketBuffer.cpp

Go to the documentation of this file.

#include "LocationServicePacketBuffer.h"

int LocationServicePacketBuffer::nbLSForwardingPacketQueued = 0;

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

LocationServicePacketBuffer::LocationServicePacketBuffer(const LocationServicePacketBuffer& other)
{
    this->m_mutex = other.m_mutex;
    this->m_lsPacketBuffer = other.m_lsPacketBuffer;
}

void LocationServicePacketBuffer::addPacket(GnAddr destination, gnDataRequest_t packet, quint32 timestamp)
{
    LocationServicePacketEntry lspe(destination, packet, timestamp);

    printf("LSPB add toLOCK\n");
    m_mutex->lock();
    printf("LSPB add locked\n");
    /* 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(nbLSForwardingPacketQueued >= itsGnLocationServicePacketBufferSize)
    {
        m_lsPacketBuffer.pop_front();
        nbLSForwardingPacketQueued -= 1;
    }

    m_lsPacketBuffer.push_back(lspe);
    nbLSForwardingPacketQueued += 1;
    printf("LSPB add toUNLOCK\n");
    m_mutex->unlock();
    printf("LSPB add UNLOCKED\n");
}

bool LocationServicePacketBuffer::find(GnAddr destination)
{
    printf("LSPB find toLOCK\n");
    m_mutex->lock();
    printf("LSPB find locked\n");
    for(QList<LocationServicePacketEntry>::Iterator i = m_lsPacketBuffer.begin();i != m_lsPacketBuffer.end(); ++i)
    {
        if(i->destination() == destination)
        {
            printf("LSPB find if toUNLOCK\n");
            m_mutex->unlock();
            printf("LSPB find if UNLOCKED\n");
            return true;
        }
    }
    printf("LSPB find toUNLOCK\n");
    m_mutex->unlock();
    printf("LSPB find UNLOCKED\n");
    return false;
}

void LocationServicePacketBuffer::erase(GnAddr destination)
{
    printf("LSPB erase toLOCK\n");
    m_mutex->lock();
    printf("LSPB erase locked\n");
    int cpt = 0;
    for(int i = 0 ; i < nbLSForwardingPacketQueued ; i++)
    {
        if(m_lsPacketBuffer.at(i).destination() == destination)
        {
            m_lsPacketBuffer.removeAt(i--);
            nbLSForwardingPacketQueued--;
            cpt++;
        }
    }
//    nbLSForwardingPacketQueued -= cpt;
    printf("LSPB erase toUNLOCK\n");
    m_mutex->unlock();
    printf("LSPB erase untoLOCKed\n");
}

void LocationServicePacketBuffer::remove(LocationServicePacketEntry lspe)
{
    printf("LSPB remove toLOCK\n");
    m_mutex->lock();
    printf("LSPB remove locked\n");
    m_lsPacketBuffer.removeOne(lspe);
    printf("LSPB remove toUNLOCK\n");
    m_mutex->unlock();
    printf("LSPB remove untoLOCKed\n");
}

void LocationServicePacketBuffer::clear()
{
    printf("LSPB clear toLOCK\n");
    m_mutex->lock();
    printf("LSPB clear locked\n");
    m_lsPacketBuffer.clear();
    nbLSForwardingPacketQueued = 0;
    printf("LSPB clear toUNLOCK\n");
    m_mutex->unlock();
    printf("LSPB clear UNLOCKED\n");
}