PingHandler.cpp

Go to the documentation of this file.

/*

Copyright (C) 2006-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 "PingHandler.h"
#include "UdpHostCache.h"
#include "Imports.cpp"

using namespace Gnutella::Bootstrapping;

namespace Gnutella {
namespace Bootstrapping {

enum Constants
{
    IPPAddresses    = 20
};

} // namespace Bootstrapping;
} // namespace Gnutella;

PingHandler::PingHandler (LocalPeer *localPeer)
 :  d()
{
    d.localPeer         = localPeer;
    d.packetProcessor   = localPeer->packetProcessor();
    d.nodeCache         = localPeer->nodeCache();
}

PingHandler::~PingHandler()
{
}

Pong PingHandler::makePongFor (const Ping &ping)
{
    // Extract some info from the ping:
    const SupportsCachedPongs *scp = SupportsCachedPongs::findIn (ping.ggepBlock());
    int ttl = ping.hops() + ping.ttl(); // \todo Make sure ttl is not bigger than a maximum?
    int hops = 0;
    QList <Pong> pongs;

    // \todo Return a cached pong no older than some time. UHC makes no cacheing itself!
    Pong ownPong;
    // \todo Use constants instead of fixed numbers:
    ownPong.setTtl (ttl);
    ownPong.setHops (hops);
    ownPong.setSharedKilobytes (1 << 21); // \todo Square of two means we are an ultrapeer.
    ownPong.setSharedFiles (1<<10); // \todo Get from FileManager?

    GgepBlock ggepBlock;
    Ultrapeer ultrapeer (true, 10, 10); // \todo Ask SlotAllocator

    Packets::VendorCode myVendorCode ("CLTK");
    Version myVersion (0, 5); // \todo Get version from LocalPeer
    Packets::Extensions::Ggeps::VendorCode vendorCode (myVendorCode, myVersion);

    DailyUptime dailyUptime (34345); // \todo Calculate and store it.

    ggepBlock.addExtension (ultrapeer);
    ggepBlock.addExtension (vendorCode);
    ggepBlock.addExtension (dailyUptime);
    if (scp) {
        // \todo read the scp and use a predicate in getNodes! Move the predicates to a header!!!
        NodeSet nodes = d.nodeCache->getNodes (IPPAddresses,
                                              NodeCache::NodeAvailable,
                                              true);
        IpPort ipp (nodes.toList());
        ggepBlock.addExtension (ipp);
        // Should we return a list of UHCs?
    }
    ownPong.setGgepBlock (ggepBlock);
    return ownPong;
}

void PingHandler::processPing (const Ping &ping)
{
    Pong pong = makePongFor (ping);
    d.packetProcessor->sendPacket (pong);
}

Copyright © 2006 Peter Dimov.
Powered by Doxygen.