unixforum.org

Код: Выделить всё

#ifndef CLASS1_H
#define CLASS1_H

#include <QThread>
#include <QReadWriteLock>

class Class1 : public QThread
{
    Q_OBJECT
    public:
        Class1(QString group, QString iface, int id);
        void stop();
        void setMulticast();
        u_char buf[0xffff];
    signals:
        void recvPack(int id, int size);
    protected:
        void run();
    private:
        void initNet();
        bool stopped;
        int ident;
        QReadWriteLock lock;
        QString group;
        QString iface;
        int port;
        int sock;
};

#endif

Код: Выделить всё

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#include "class1.h"

Class1::Class1(QString g, QString i, int id)
{
    stopped = false;
    group = g;
    iface = i;
    ident = id;
    port = 50138;
    initNet();
    start();
}

void Class1::run()
{
    while (1)
    {
        lock.lockForWrite();
        if (stopped)
        {
            stopped = false;
            break;
        }
        lock.unlock();

        sockaddr_in cli;
        int recvbyte;
        socklen_t addrsize;
        addrsize = sizeof(cli);

        recvbyte = recvfrom(sock, buf, 0xffff, 0, (struct sockaddr *)&cli, &addrsize);
        emit recvPack(ident, recvbyte);
    }
}

void Class1::stop()
{
    lock.lockForWrite();
    stopped = true;
    close(sock);
    lock.unlock();
}

void Class1::setMulticast()
{
    struct ip_mreq mreq;
    bzero(&mreq, sizeof(mreq));
    inet_aton((const char *)(group.toLocal8Bit()), &mreq.imr_multiaddr);
    inet_aton((const char *)(iface.toLocal8Bit()), &mreq.imr_interface);
    setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq));
}

void Class1::initNet()
{
    struct sockaddr_in srv;
    bzero(&srv, sizeof(srv));
    srv.sin_family = AF_INET;
    srv.sin_port = htons(port);
    inet_aton((const char *)(group.toLocal8Bit()), &srv.sin_addr);

    sock = socket(AF_INET, SOCK_DGRAM, 0);

    bind(sock, (struct sockaddr *)&srv, sizeof(srv));
}

Код: Выделить всё

#ifndef CLASS2_H
#define CLASS2_H

#include <QObject>
#include <QString>

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#include "class1.h"

class Class2 : public QObject
{
    Q_OBJECT
    public:
        Class2(QString group, QString iface, QObject *parent = 0);
        u_char data[0xffff];
    private slots:
        void recvPack(int id, int size);
    private:
        Class1 *multicastThread;
        Class1 *ifaceThread;
};

#endif

Код: Выделить всё

#include "class2.h"

Class2::Class2(QString group, QString iface, QObject *parent) : QObject(parent)
{
    multicastThread = new Class1(group, iface, 1);
    multicastThread->setMulticast();

    ifaceThread = new Class1(iface, "", 2);

    connect(multicastThread, SIGNAL(recvPack(int, int)), this, SLOT(recvPack(int, int)));
    connect(ifaceThread, SIGNAL(recvPack(int, int)), this, SLOT(recvPack(int, int)));
}

void Class2::recvPack(int id, int size)
{
    if (id == 1)
    {
        memcpy(data, multicastThread->buf, size);
    }
    else if (id == 2)
    {
        memcpy(data, ifaceThread->buf, size);
    }

    for (int i=0; i<size; i++)
    {
        if ((i % 16) == 0)
        {
            fprintf(stderr,"\n");
        }

        if (data[i] < 16)
        {
            fprintf(stderr,"0x0%x, ",data[i]);
        }
        else
        {
            fprintf(stderr,"0x%x, ",data[i]);
        }
    }
    fprintf(stderr,"\n");
}