RepetitionPacketBuffer.cpp

Go to the documentation of this file.

#include "RepetitionPacketBuffer.h"

static QVector<RepetitionPacketEntry> m_repetitionPacketBuffer;

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

void RepetitionPacketBuffer::addPacket(gnDataRequest_t gnDR)
{
    if(gnDR.maximumRepetitionTime == 0 || gnDR.repetitionInterval == 0)
        return;

    printf("RPB add toLOCK\n");
    m_mutex->lock();
    printf("RPB add locked\n");
    RepetitionPacketEntry* rpe = new RepetitionPacketEntry(gnDR);
    QObject::connect(rpe, SIGNAL(isOver()), this, SLOT(erase()));
    QObject::connect(rpe, SIGNAL(sendPacket(gnDataRequest_t)), this, SLOT(sendPacketIndication(gnDataRequest_t)));
    QObject::connect(this, SIGNAL(killAll()), rpe, SLOT(kill()));
    m_repetitionPacketBuffer.push_back(rpe);
    printf("RPB add toUNLOCK\n");
    m_mutex->unlock();
    printf("RPB add UNLOCKED\n");

    QThread* th = new QThread;
    rpe->moveToThread(th);
    QObject::connect(th, SIGNAL(started()), rpe, SLOT(execute()));
    th->start();
}

void RepetitionPacketBuffer::clear()
{
    emit killAll();
    printf("RPB clear toLOCK\n");
    m_mutex->lock();
    printf("RPB clear locked\n");
    m_repetitionPacketBuffer.clear();
    printf("RPB clear toUNLOCK\n");
    m_mutex->unlock();
    printf("RPB clear UNLOCKED\n");
}

void RepetitionPacketBuffer::erase()
{
    int j = 0;
    printf("RPB erase toLOCK\n");
    m_mutex->lock();
    printf("RPB erase locked\n");
    for(QVector<RepetitionPacketEntry*>::Iterator i = m_repetitionPacketBuffer.begin();j < m_repetitionPacketBuffer.size(); ++i, j++)
        if(!(*i)->timer()->isActive())
            m_repetitionPacketBuffer.erase(i);
    printf("RPB erase toUNLOCK\n");
    m_mutex->unlock();
    printf("RPB erase UNLOCKED\n");
}

void RepetitionPacketBuffer::sendPacketIndication(gnDataRequest_t packet)
{
    emit sendPacketToGn(packet);
}