Page History

#include "sender.h"

SenderReceiver::SenderReceiver(QObject \*parent) :
       QObject(parent)
{
       sendUdpSocket = new QUdpSocket(0);
       receiveUdpSocket = new QUdpSocket(0);
       receiveUdpSocket->bind(45455,QUdpSocket::ShareAddress);
       connect(receiveUdpSocket, SIGNAL(readyRead()), this, SLOT(processPendingDatagrams()));
}

//viestien lahetys
void SenderReceiver::broadcastDatagram(QVector<float> v)
{
   &nbsp;&nbsp;&nbsp; int error,i;
   &nbsp;&nbsp;&nbsp; QByteArray datagram;
   &nbsp;&nbsp;&nbsp; qDebug() << v;
   &nbsp;&nbsp;&nbsp; QDataStream out (&datagram,QIODevice::WriteOnly);
   &nbsp;&nbsp;&nbsp; foreach(float f,v)
   &nbsp;&nbsp;&nbsp; {
       &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; out << f;
   &nbsp;&nbsp;&nbsp; }
   &nbsp;&nbsp;&nbsp; //kirjoitetaan udp-viesti, mahdollinen virhe kannattaisi tarkastaa
   &nbsp;&nbsp;&nbsp; error=sendUdpSocket->writeDatagram(datagram.data(), datagram.size(), QHostAddress::Broadcast, 45455);
}

//viestien vastaanotto
void SenderReceiver::processPendingDatagrams()
{
   &nbsp;&nbsp;&nbsp; float f;
   &nbsp;&nbsp;&nbsp; //onko vastaanotettu viesteja
   &nbsp;&nbsp;&nbsp; while (receiveUdpSocket->hasPendingDatagrams()) {
        &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; QByteArray datagram;
        &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; datagram.resize(receiveUdpSocket->pendingDatagramSize());
        &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; receiveUdpSocket->readDatagram(datagram.data(), datagram.size());
        &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; QDataStream in(datagram);
        &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while (\!in.atEnd()){
            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; in >> f;
             v2 << f;
         }
         qDebug() << v2;
         emit sendReceivedData(v2);
     }
}

 #include "sender.h"

SenderReceiver::SenderReceiver(QObject *parent) :
    QObject(parent)
{
    sendUdpSocket = new QUdpSocket(0);
    receiveUdpSocket = new QUdpSocket(0);
    receiveUdpSocket->bind(45455,QUdpSocket::ShareAddress);
    connect(receiveUdpSocket, SIGNAL(readyRead()), this, SLOT(processPendingDatagrams()));
}

void SenderReceiver::broadcastDatagram(QVector<float> v)
{
    int error,i;
    QByteArray datagram;
    qDebug() << v;
    QDataStream out (&datagram,QIODevice::WriteOnly);
    foreach(float f,v)
    {
        out << f;
    }
    //kirjoitetaan udp-viesti, mahdollinen virhe kannattaisi tarkastaa
    error=sendUdpSocket->writeDatagram(datagram.data(), datagram.size(), QHostAddress::Broadcast, 45455);
}

void SenderReceiver::processPendingDatagrams()
{
    float f;
    //onko vastaanotettu viesteja
    while (receiveUdpSocket->hasPendingDatagrams()) {
         QByteArray datagram;
         datagram.resize(receiveUdpSocket->pendingDatagramSize());
         receiveUdpSocket->readDatagram(datagram.data(), datagram.size());
         QDataStream in(datagram);
         while (!in.atEnd()){
             in >> f;
             v2 << f;
         }
         &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; v2 << f;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; qDebug() << v2;
        &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; emit sendReceivedData(v2);
    &nbsp;&nbsp;&nbsp;&nbsp; }
}