User Manual, Developers Guide and API Documentation

UpperConvergence.hpp

Go to the documentation of this file.

/******************************************************************************
 * DLLBase (DLL Base classes to create FUN-based DLL)                         *
 * __________________________________________________________________________ *
 *                                                                            *
 * Copyright (C) 2006                                                         *
 * Chair of Communication Networks (ComNets)                                  *
 * Kopernikusstr. 16, D-52074 Aachen, Germany                                 *
 * phone: ++49-241-80-27910 (phone), fax: ++49-241-80-22242                   *
 * email: wns@comnets.rwth-aachen.de                                          *
 * www: http://wns.comnets.rwth-aachen.de                                     *
 ******************************************************************************/

#ifndef DLL_UPPERCONVERGENCE_HPP
#define DLL_UPPERCONVERGENCE_HPP

#include <WNS/ldk/CommandTypeSpecifier.hpp>
#include <WNS/ldk/Forwarding.hpp>
#include <WNS/ldk/FUNConfigCreator.hpp>
#include <WNS/ldk/HasConnector.hpp>
#include <WNS/ldk/HasReceptor.hpp>
#include <WNS/ldk/HasDeliverer.hpp>
#include <WNS/ldk/Forwarding.hpp>
#include <WNS/ldk/FirstServeConnector.hpp>
#include <WNS/logger/Logger.hpp>

#include <WNS/service/dll/DataTransmission.hpp>
#include <WNS/service/dll/FlowEstablishmentAndRelease.hpp>
#include <WNS/service/dll/Handler.hpp>
#include <WNS/service/dll/FlowID.hpp>
#include <WNS/service/qos/QoSClasses.hpp>
#include <WNS/pyconfig/View.hpp>

namespace dll {
    class RANG;

    class UpperCommand :
        public wns::ldk::Command
    {
    public:
        UpperCommand()
        {
            peer.sourceMACAddress = wns::service::dll::UnicastAddress();
            peer.targetMACAddress = wns::service::dll::UnicastAddress();
        }

        struct {
            wns::service::dll::FlowID dllFlowID;
        } local;
        struct {
            wns::service::dll::UnicastAddress sourceMACAddress;
            wns::service::dll::UnicastAddress targetMACAddress;
        } peer; 
        struct {} magic;
    };

    class UpperConvergence :
        virtual public wns::ldk::FunctionalUnit,
        virtual public wns::service::dll::UnicastDataTransmission,
        virtual public wns::service::dll::Notification,
        public wns::ldk::CommandTypeSpecifier<UpperCommand>,
        public wns::ldk::HasReceptor<>,
        public wns::ldk::HasConnector<wns::ldk::FirstServeConnector>,
        public wns::ldk::HasDeliverer<>
    {
    public:
        UpperConvergence(wns::ldk::fun::FUN* fun, const wns::pyconfig::View& config);
        virtual ~UpperConvergence();

        virtual void
        registerFlowHandler(wns::service::dll::FlowHandler*){};

        virtual void
        registerIRuleControl(wns::service::dll::IRuleControl*){};

        // DataTransmission service
        virtual void
        sendData(
            const wns::service::dll::UnicastAddress& _peer,
            const wns::osi::PDUPtr& _data,
            wns::service::dll::protocolNumber protocol,
            wns::service::dll::FlowID _dllFlowID = 0);

        virtual std::string
        getSubnetIdentifier() { return "DLLBase";}

        virtual void
        setMACAddress(const wns::service::dll::UnicastAddress& _sourceMACAddress);

        virtual wns::service::dll::UnicastAddress
        getMACAddress() const;

        virtual void
        onFUNCreated();

        virtual wns::ldk::CommandPool*
        createReply(const wns::ldk::CommandPool* original) const;

    protected:
        wns::service::dll::UnicastAddress sourceMACAddress;
        wns::logger::Logger logger;
    };


    class UTUpperConvergence :
        public UpperConvergence,
        public wns::ldk::Forwarding<UTUpperConvergence>,
        public wns::service::dll::FlowEstablishmentAndRelease,
        public wns::Cloneable<UTUpperConvergence>
    {
    public:
        UTUpperConvergence(wns::ldk::fun::FUN* fun, const wns::pyconfig::View& config);
        virtual ~UTUpperConvergence(){};
        virtual void processIncoming(const wns::ldk::CompoundPtr& compound);
        // Notification Service
        virtual void
        registerHandler(wns::service::dll::protocolNumber protocol,
                wns::service::dll::Handler* _dh);

        virtual void
        registerFlowHandler(wns::service::dll::FlowHandler*) {}

        virtual void
        establishFlow(wns::service::tl::FlowID flowID, wns::service::qos::QoSClass qosClass);

        virtual void
        releaseFlow(wns::service::tl::FlowID flowID);
    protected:
        typedef wns::container::Registry<wns::service::dll::protocolNumber, wns::service::dll::Handler*> DataHandlerRegistry;

        DataHandlerRegistry dataHandlerRegistry;
    };

    class APUpperConvergence :
        public UpperConvergence,
        public wns::ldk::Forwarding<APUpperConvergence>,
        public wns::Cloneable<APUpperConvergence>
    {
    public:
        APUpperConvergence(wns::ldk::fun::FUN* fun, const wns::pyconfig::View& config);
        virtual ~APUpperConvergence(){};
        virtual void processIncoming(const wns::ldk::CompoundPtr& compound);
        // Notification Service
        virtual void
        registerHandler(wns::service::dll::protocolNumber protocol,
                wns::service::dll::Handler* _dh);

        virtual void
        registerFlowHandler(wns::service::dll::FlowHandler*){};

        bool hasRANG();
        dll::RANG* getRANG();
    protected:
        RANG* dataHandler;
    };

    class NoUpperConvergence :
        public UpperConvergence,
        public wns::ldk::Forwarding<NoUpperConvergence>,
        public wns::Cloneable<NoUpperConvergence>
    {
    public:
        NoUpperConvergence(wns::ldk::fun::FUN* fun, const wns::pyconfig::View& config) :
            UpperConvergence(fun,config),
            wns::ldk::Forwarding<NoUpperConvergence>(),
            wns::Cloneable<NoUpperConvergence>()
        {}
        virtual void
        registerHandler(wns::service::dll::protocolNumber /*protocol*/, wns::service::dll::Handler* /*_dh*/){};

        virtual void
        registerFlowHandler(wns::service::dll::FlowHandler*){};

/*      wns::service::dll::UnicastAddress
        getMACAddress() const { return wns::service::dll::UnicastAddress(); }*/
    };
}

#endif // NOT defined DLL_UPPERCONVERGENCE_HPP

---