UdpConnection.cpp

Go to the documentation of this file.

/*

Copyright (C) 2005-2007 by Peter Dimov.

This file is part of Calitko (http://www.calitko.org).

Calitko is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.

Calitko is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with Calitko; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

*/

#include "Qt.h"
#include "Imports.h"
#include "UdpConnection.h"
#include "UdpSwitch.h"

namespace Protocols {
namespace Transports {

// \todo Fix this warning:
// Protocols/Transports/UdpConnection.cpp(40): warning #1944: declaration of "udpSwitch" shadows a member of 'this'
class UdpConnectionPrivate
{
    REFERENCE_OBJECT (UdpConnectionPrivate)

public:
    UdpSwitch               *udpSwitch;
    QQueue <QByteArray>     readQueue;
    qint64                  headDatagramReadBytes;

    UdpConnectionPrivate (UdpSwitch *udpSwitch)
     :  udpSwitch (udpSwitch), readQueue(), headDatagramReadBytes (0)
    {}
};

} // namespace Transports;
} // namespace Protocols;

using namespace Protocols::Transports;

UdpConnection::UdpConnection (UdpSwitch *udpSwitch)
    : p (new UdpConnectionPrivate (udpSwitch))
{
    // \todo connect a signal telling that the udp swith is stopped?
}

UdpConnection::~UdpConnection()
{
    //Q_ASSERT (state() == DisconnectedState);
}

void UdpConnection::doConnectToNode (const NodeAddress &nodeAddress)
{
    Q_ASSERT (!nodeAddress.isNull());

    if (p->udpSwitch->openChannel (this, nodeAddress)) {
        setState (Connection::ConnectedState);
        setOpenMode (QIODevice::ReadWrite | QIODevice::Unbuffered);
        // \todo delay emiting these signals ?
        emit connectionEstablished();
    } else {
        emit connectionFailed();
    }
}

void UdpConnection::doDisconnectFromNode()
{
    p->udpSwitch->closeChannel (this);
    setOpenMode (QIODevice::NotOpen);
    // \todo Delay emiting this signal?
    emit connectionClosed();
}

void UdpConnection::datagramRead (const QByteArray &datagram)
{
    p->readQueue.enqueue (datagram);
    emit readyRead();
}

qint64 UdpConnection::readData (char * data, qint64 maxSize)
{
    // \todo This implementation, as already noted in another todo in the class
    // description is not consistent with the documentation. Changing it would
    // require changing PacketReader as well and this is not necessary yet.
    if (p->readQueue.isEmpty())
        return 0;

    if (p->readQueue.head().length() - p->headDatagramReadBytes >= maxSize) {
        memcpy (data, p->readQueue.head().data() + p->headDatagramReadBytes, maxSize);
        p->headDatagramReadBytes += maxSize;
        if (p->headDatagramReadBytes == p->readQueue.head().length()) {
            p->headDatagramReadBytes = 0;
            p->readQueue.dequeue();
        }
        return maxSize;
    } else {
        // \todo emit readError()
        return -1;
    }
}

qint64 UdpConnection::writeData (const char * data, qint64 maxSize)
{
    if (p->udpSwitch->writeDatagram (this, data, maxSize)) {
        // do a delayed emit bytesWritten (maxSize);
        QMetaObject::invokeMethod (this, "bytesWritten", Qt::QueuedConnection,
                                   QGenericReturnArgument(),
                                   Q_ARG (qint64, maxSize));
        return maxSize;
    } else {
        //\tood emit writeError();
        return -1;
    }
}

Copyright © 2006 Peter Dimov.
Powered by Doxygen.