[Home]	[About]
[Screenshots]	[Download]
[News]	[Community]
[Documentation]	[Manual]
[Bugs & Requests]	[Wiki]

/home/tetron/hack/vos/libs/vos/vos/sitepeering.hh

Go to the documentation of this file.

#ifndef _SITEPEERING_HH_
#define _SITEPEERING_HH_

#include <stdexcept>
#include <set>

#include <vos/vos/siteextension.hh>
#include <vos/vos/remotesocketsite.hh>
#include <vos/vos/localsite.hh>
#include <vos/vos/iterator.hh>

namespace VOS {

    /** @class PortBindingError sitepeering.hh vos/vos/sitepeering.hh
        @ingroup libvos
    */
    class VOS_API PortBindingError : public std::runtime_error
    {
    public:
        PortBindingError(const std::string& s) : std::runtime_error(s) { };
    };

    /** @class SitePeeringThread localsocketsite.hh vos/vos/localsocketsite.hh
        @ingroup libvos

        This may be used one of two ways.  It may be started as a
        separate thread by ListenerThread to handle an incoming
        connection, or it may be called directly by vop://
        SocketProtocolHandler to do site peering for an outgoing
        connection.
    */
    class VOS_API SitePeeringThread
    {
    private:
        void sendHello(const std::string& gotAntiSpoof = "");
        bool verifyAlias(VUtil::URL& url, std::string& checkid);
        void handleHello(Message* hello);

    protected:
        RemoteSiteExtension* rsse;
        LocalSiteExtension* lsse;
        bool isClient;

    public:
        SitePeeringThread(LocalSiteExtension* l, bool isCl);

        /** Copy constructor, required because boost::thread makes a
            copy of the thread object it runs.
         */
        SitePeeringThread(const SitePeeringThread& spt);

        virtual ~SitePeeringThread() { };

        /** If initialized to be a client it will make an outgoing
            connection with the supplied host and port.  Otherwise it
            uses the supplied socket.  In either event this will
            create a new remote Site with RemoteSocketSiteExtension
            attached.

            The site peering process involves sending the "core:hello"
            message, looking at the host aliases sent by the other
            site, and performing the anti-spoof verification check to
            ensure that the site aliases are valid.

           @throw NoSuchSiteError if the site could not be connected
           to or something failed during the site peering handshake
        */
        void operator()();

        /** The remote site created in operator()(). */
        VUtil::vRef<Site> remotesite;

        static std::string getProtoVersion();
        static bool checkProtoVersion(const std::string& s);
        static bool checkProtoVersion(Message* m);

        virtual void init() = 0;
        virtual void done() = 0;
    };
}

#endif