hyperviseurudpsocket.cpp

Aller à la documentation de ce fichier.

#include "hyperviseurudpsocket.h"



HyperviseurUDPSocket::HyperviseurUDPSocket(quint16 port, QObject *parent) :
    QUdpSocket(parent)
{
    this->bind(QHostAddress::Any, port);
    connect(this, SIGNAL(readyRead()), this, SLOT(lireDatagrammes()));
}



void HyperviseurUDPSocket::lireDatagrammes(){
    while(this->hasPendingDatagrams()){
        QByteArray datagramme;
        QHostAddress source;
        QString sourceStr;
        quint32 seqNb;

        datagramme.resize(this->pendingDatagramSize());
        this->readDatagram(datagramme.data(), datagramme.size(), &source);

        sourceStr = source.toString();
        seqNb = datagramme.left(4).toHex().toUInt(0, 16);

        if(this->seqNbTable.contains(sourceStr)){
            if(seqNb != this->seqNbTable.value(sourceStr)+1 && seqNb != 0){
                int temp = ((int)seqNb) - ((int)(this->seqNbTable.value(sourceStr)))+1;
                if(temp > 0){
                    emit paquetsPerdus( seqNb - (this->seqNbTable.value(sourceStr)+1) );
                }
                qDebug() << sourceStr << ": " << QString::number(temp)+" paquet(s) perdu(s).";
            }
        }
        this->seqNbTable.insert(sourceStr, seqNb);

        emit nouvellesDonnes(QString(datagramme.mid(4)));

        qDebug() << "Réception de " << sourceStr+"  SeqNb:"+QString::number(seqNb);//+"\n\t"+QString(datagramme.mid(4));
    }
}