ConnectReaSE.h

Go to the documentation of this file.

//
// Copyright (C) 2010 Institut fuer Telematik, Karlsruher Institut fuer Technologie (KIT)
//
// This program 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.
//
// This program 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 this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
//

#ifndef CONNECTREASE_H_
#define CONNECTREASE_H_

#include <omnetpp.h>

#include <InitStages.h>


class IInterfaceTable;
class InterfaceEntry;
class IRoutingTable;
class IPRoute;



struct edgeRoutes
{
public:
        int countPPPInterfaces;
        IInterfaceTable* interfaceTable; 
        IRoutingTable* routingTable; 
        uint32 IPAddress; 
        uint32 lastIP;  
        cModule* Router;
        std::vector<uint32> IPAddresses; 
        std::string channelTypeRxStr; 
        std::string channelTypeTxStr; 
};

struct autoSystem
{
public:
    //cModule* AS;
    std::vector<edgeRoutes> edgeRouter;
    uint32 edgeShift;
};

struct topologyProperty
{
public:
    cModule* pModule;
    const char* property;
};

struct edgePool
{
public:
    edgeRoutes* edge;
    uint32 indexAS;
};


class terminalInfo
{
public:
    uint32 IPAddress; 
    cModule* module;
    IInterfaceTable* interfaceTable; 
    IRoutingTable* routingTable; 
    cModule* PPPInterface; 
    cModule* remotePPPInterface; 
    InterfaceEntry* interfaceEntry; 
    InterfaceEntry* remoteInterfaceEntry; 
    IInterfaceTable* remoteInterfaceTable; 
    IPRoute* routingEntry; 
    IPRoute* remoteRoutingEntry;
    edgeRoutes* edgeRouter; 
    int ASindex; // deleteable?
    simtime_t createdAt; 

    friend std::ostream& operator<<(std::ostream& os, terminalInfo& n);
};

class AccessInfo
{
public:
    edgeRoutes* edge;
    cModule* terminal;
    uint32 IPAddress;
    int ASindex;
};

class ConnectReaSE : public cSimpleModule
{

public:
    virtual int addOverlayNode(AccessInfo* overlayNode, bool migrate = false);
    virtual AccessInfo getAccessNode();
    virtual cModule* removeOverlayNode(int ID);
    virtual cModule* getOverlayNode(int ID);
    /*
     * migrates given node to a different edge router
     */
    virtual AccessInfo migrateNode(int ID);

protected:
        virtual int numInitStages() const
        {
            return MAX_STAGE_UNDERLAY + 1;
        }

        virtual void initialize(int stage);

        virtual void handleMessage(cMessage* msg);

        virtual void updateDisplayString();

        std::vector<std::string> channelTypesRx; 

        std::vector<std::string> channelTypesTx; 


        std::vector<terminalInfo> overlayTerminal; 

        // statistics
        cOutVector lifetimeVector; 

        std::vector<autoSystem> AS_Pool; //<! list of autonomous systems of the topology
        std::vector<edgePool> globalEdgePool; //<!  dedicated list of all connectable routers
        uint32 totalCountOfAS, nextPow, ASShift;
        double channelDiversity; //<! percentage that a channel delay can differ

private:
    cGate* firstUnusedGate(cModule* owner, const char* name, cGate::Type type = cGate::NONE);
    void setUpAS(cModule* currAS);
    static bool extractFromParentModule(cModule* currModule, void * properties);

};


#endif /* CONNECTREASE_H_ */