collecteursocket.cpp

Aller à la documentation de ce fichier.

#include "collecteursocket.h"



CollecteurSocket::CollecteurSocket() :
    QTcpSocket()
{
    this->tailleDonnees = 0;

    connect(this, SIGNAL(readyRead()), this, SLOT(recevoirDonnees()));
}



void CollecteurSocket::connexion(QString host, quint16 port){    
    this->abort();
    this->tailleDonnees = 0;
    this->connectToHost(host, port);
}



bool CollecteurSocket::envoyerCommande(QString commande){
    if(this->state() != QAbstractSocket::ConnectedState) return false;

    quint8  reserv = 0;
    quint32 number = commande.size();
    QByteArray ba;
    QDataStream out(&ba, QIODevice::ReadWrite);
    out.setByteOrder(QDataStream::BigEndian);
    out << number;
    out << reserv;
    bool ok1 = (this->write(ba) == ba.size());
    bool ok2 = (this->write(commande.toAscii()) == commande.size());

    return (ok1 && ok2);
}



void CollecteurSocket::recevoirDonnees(){
    //QDataStream in(this);

    if(this->tailleDonnees == 0){
        if(this->bytesAvailable() < ((int)sizeof(quint32)+(int)sizeof(quint8)) ) return;
        QByteArray ba = this->read((int)sizeof(quint32));
        this->tailleDonnees = ba.toHex().toUInt(0, 16);
        this->read((int)sizeof(quint8));
    }
    if(this->bytesAvailable() < this->tailleDonnees) return;

    QByteArray ba = this->read(this->tailleDonnees);

    //qDebug() << "Données recues: " << QString(ba);

    emit nouvellesDonnees(QString(ba));

    this->tailleDonnees = 0;

    //qDebug() << QThread::currentThreadId() << ": " << this->peerAddress().toString();
}