IpPort.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 "IpPort.h"
#include "Gnutella/Packets/Extensions/GgepBlock.h"
#include "Gnutella/Packets/Packet.h"

using Gnutella::Packets::Extensions::Ggep;
using Gnutella::Packets::Extensions::GgepBlock;
using Gnutella::Packets::Extensions::Ggeps::IpPort;
using Protocols::Transports::NodeAddress;

const Ggep::GgepId IpPort::Id ("IPP", 3);

IpPort::IpPort (const GgepId &id, int flags, int dataSize)
: Ggep (id, flags, dataSize)
{
}

IpPort::IpPort (const QList <NodeAddress> &addresses)
: Ggep (Id)
{
    p.addresses = addresses;
}

const IpPort * IpPort::findIn (const GgepBlock &ggepBlock)
{
    const IpPort *res = 0;
    foreach (const Ggep *extension, ggepBlock.extensions()) {
        res = dynamic_cast <const IpPort *> (extension);
        if (res != 0)
            return res;
    }
    return 0;
}

IpPort * IpPort::copy() const
{
    return new IpPort (*this);
}

bool IpPort::prepareReadData (const QByteArray &rawBytes)
{
    return rawBytes.length() % 6 == 0; // Each IpPort should be 6 bytes!
}

void IpPort::readData (QDataStream &stream)
{
    using namespace Gnutella::Packets;

    int count = dataLength() / 6;
    for (int i = 0; i < count; i++) {
        QHostAddress ip;
        quint16 port;
        Gnutella::Packets::operator>> (stream, ip);
        stream >> port;
        p.addresses.append (NodeAddress (ip, port));
    }
}

int IpPort::prepareWriteData() const
{
    return p.addresses.size() * 6;
}

void IpPort::writeData (QDataStream &stream) const
{
    using namespace Gnutella::Packets;

    foreach (NodeAddress address, p.addresses) {
        Gnutella::Packets::operator<< (stream, address.hostAddress());
        stream << address.hostPort();
    }
}

Copyright © 2006 Peter Dimov.
Powered by Doxygen.