VFS_udp_socket.cpp

Go to the documentation of this file.

 
#include <QNetworkDatagram>
 
#include "VFS_udp_socket.h"
 
#include "VFS.h"
 
VFS_udp_socket::VFS_udp_socket(QHostAddress multicast, quint16 port, QString mode)
: VFS_node()
, _address(multicast)
, _port(port)
, _socket(this)
, _mode(mode)
{
        if (_mode == "w" || _mode == "rw")
        {
                //connect(this,SIGNAL(mounted()),this,SLOT(listen()));
                connect(VFS::root(),SIGNAL(initialized()),this,SLOT(listen()));
 
                connect(        &_socket,       SIGNAL( error(QAbstractSocket::SocketError) ),
                                this,           SLOT( socketError(QAbstractSocket::SocketError) )       );
        }
        else
                VFS::ERROR( QString("%1 bad mode: %2").arg(className()).arg(_mode) );
}
 
VFS_udp_socket::~VFS_udp_socket()
{
        _socket.close();
}
 
bool VFS_udp_socket::isContainer()
{
        return false;
}
 
bool VFS_udp_socket::listen()
{
        if (_mode.contains("r"))
        {
                //bool l = _socket.bind( _address, _port);
                //bool l = _socket.bind( _port, QUdpSocket::ShareAddress );
 
                bool l = _socket.bind(QHostAddress::AnyIPv4, _port, QUdpSocket::ShareAddress);
                _socket.joinMulticastGroup(_address);
 
                if (!l)
                        VFS::WARN( QString("%1 could not bind on UDP %2:%3.  Is it already in use?").arg(className()).arg(_address.toString()).arg(_port) );
                else
                {
                        if (_port == 0)
                                _port = _socket.localPort();
 
                        //_address = _socket.localAddress();
 
                        connect(&_socket,SIGNAL(readyRead()),this,SLOT(readyRead()));
                        VFS::LOG( QString("%1 listening on UDP multicast group %2:%3 (insecure)").arg(className()).arg(_address.toString()).arg(_port), 2 );
                }
 
                return l;
        }
        else
        {
                VFS::LOG( QString("%1 created on UDP multicast group %2:%3 (insecure)").arg(className()).arg(_address.toString()).arg(_port), 2 );
                return true;
        }
}
 
 
void VFS_udp_socket::readyRead()
{
        while (_socket.hasPendingDatagrams())
        {
                QNetworkDatagram datagram = _socket.receiveDatagram();
                VFS::WARN( QString("Datagram: %1").arg( qUtf8Printable(datagram.data()) ) );
        }
}
 
void VFS_udp_socket::socketError(QAbstractSocket::SocketError error)
{
        VFS::ERROR( QString("%1: (%2) %3").arg(className()).arg(error).arg(_socket.errorString()) );
        VFS::WARN( QString("(%1) Seems like something should happen here.").arg(className()) );
}
 
void VFS_udp_socket::write(VFS_request *r)
{
        r->_success = true;
 
        QNetworkDatagram d(r->toJson(), _address, _port);
 
        qint64 l = _socket.writeDatagram(d);
 
        if (l > -1)
                r->_success = true;
        else
        {       r->_success = false;
                r->_reason = "Could not send datagram";
        }
}
 
QString VFS_udp_socket::reportDetails()
{
        return QString("address: %1\nport: %2\nstate: %3").arg(_address.toString()).arg(_port).arg(_socket.isOpen() ? "open" : "closed");
}