inet::bgp::Bgp Class Reference

#include <Bgp.h>

Inheritance diagram for inet::bgp::Bgp:

Public Member Functions
	Bgp ()
virtual	~Bgp ()
Public Member Functions inherited from inet::LifecycleUnsupported
virtual bool	handleOperationStage (LifecycleOperation *operation, IDoneCallback *doneCallback) override
	Perform one stage of a lifecycle operation. More...
Public Member Functions inherited from inet::ILifecycle
virtual	~ILifecycle ()

Protected Member Functions
virtual int	numInitStages () const override
virtual void	initialize (int stage) override
virtual void	handleMessage (cMessage *msg) override
void	createBgpRouter ()
void	handleTimer (cMessage *timer)
virtual void	finish () override

Private Attributes
ModuleRefByPar< IIpv4RoutingTable >	rt
ModuleRefByPar< IInterfaceTable >	ift
bool	isUp = false
BgpRouter *	bgpRouter = nullptr
cMessage *	startupTimer = nullptr

Constructor & Destructor Documentation

Bgp()

inet::bgp::Bgp::Bgp

(

)

{
}

~Bgp()

inet::bgp::Bgp::~Bgp ( )

virtual

{
    cancelAndDelete(startupTimer);
    delete bgpRouter;
}

Member Function Documentation

createBgpRouter()

void inet::bgp::Bgp::createBgpRouter ( )

protected

{
    bgpRouter = new BgpRouter(this, ift, rt);
 
    // read BGP configuration
    cXMLElement *bgpConfig = par("bgpConfig");
    BgpConfigReader configReader(this, ift);
    configReader.loadConfigFromXML(bgpConfig, bgpRouter);
 
    bgpRouter->printSessionSummary();
    bgpRouter->addWatches();
}

Referenced by handleMessage(), and initialize().

finish()

void inet::bgp::Bgp::finish ( )

overrideprotectedvirtual

{
    if (!isUp) {
        EV_ERROR << "Protocol is turned off. \n";
        return;
    }
 
    bgpRouter->recordStatistics();
}

handleMessage()

void inet::bgp::Bgp::handleMessage ( cMessage *  msg )

overrideprotectedvirtual

{
    if (!isUp) {
        if (msg->isSelfMessage())
            throw cRuntimeError("Model error: self msg '%s' received when protocol is down", msg->getName());
        EV_ERROR << "Protocol is turned off, dropping '" << msg->getName() << "' message\n";
        delete msg;
        return;
    }
 
    if (msg == startupTimer)
        createBgpRouter();
    else if (msg->isSelfMessage()) // BGP level
        handleTimer(msg);
    else if (!strcmp(msg->getArrivalGate()->getName(), "socketIn")) // TCP level
        bgpRouter->processMessageFromTCP(msg);
    else
        delete msg;
}

handleTimer()

void inet::bgp::Bgp::handleTimer ( cMessage *  timer )

protected

{
    BgpSession *pSession = (BgpSession *)timer->getContextPointer();
    if (pSession) {
        switch (timer->getKind()) {
            case START_EVENT_KIND:
                EV_INFO << "Processing Start Event" << std::endl;
                pSession->getFSM()->ManualStart();
                break;
 
            case CONNECT_RETRY_KIND:
                EV_INFO << "Expiring Connect Retry Timer" << std::endl;
                pSession->getFSM()->ConnectRetryTimer_Expires();
                break;
 
            case HOLD_TIME_KIND:
                EV_INFO << "Expiring Hold Timer" << std::endl;
                pSession->getFSM()->HoldTimer_Expires();
                break;
 
            case KEEP_ALIVE_KIND:
                EV_INFO << "Expiring Keep Alive timer" << std::endl;
                pSession->getFSM()->KeepaliveTimer_Expires();
                break;
 
            default:
                throw cRuntimeError("Invalid timer kind %d", timer->getKind());
        }
    }
}

Referenced by handleMessage().

initialize()

void inet::bgp::Bgp::initialize ( int  stage )

overrideprotectedvirtual

{
    cSimpleModule::initialize(stage);
 
    if (stage == INITSTAGE_LOCAL) {
        ift.reference(this, "interfaceTableModule", true);
        rt.reference(this, "routingTableModule", true);
 
        startupTimer = new cMessage("BGP-startup");
    }
    else if (stage == INITSTAGE_ROUTING_PROTOCOLS) { // interfaces and static routes are already initialized
        cModule *node = findContainingNode(this);
        NodeStatus *nodeStatus = node ? check_and_cast_nullable<NodeStatus *>(node->getSubmodule("status")) : nullptr;
        isUp = !nodeStatus || nodeStatus->getState() == NodeStatus::UP;
        if (isUp) {
            simtime_t startupTime = par("startupTime");
            if (startupTime == 0)
                createBgpRouter();
            else
                scheduleAfter(startupTime, startupTimer);
        }
    }
}

numInitStages()

virtual int inet::bgp::Bgp::numInitStages ( ) const

inlineoverrideprotectedvirtual

{ return NUM_INIT_STAGES; }

Member Data Documentation

bgpRouter

BgpRouter* inet::bgp::Bgp::bgpRouter = nullptr

private

Referenced by createBgpRouter(), finish(), handleMessage(), and ~Bgp().

ift

ModuleRefByPar<IInterfaceTable> inet::bgp::Bgp::ift

private

Referenced by createBgpRouter(), and initialize().

isUp

bool inet::bgp::Bgp::isUp = false

private

Referenced by finish(), handleMessage(), and initialize().

rt

ModuleRefByPar<IIpv4RoutingTable> inet::bgp::Bgp::rt

private

Referenced by createBgpRouter(), and initialize().

startupTimer

cMessage* inet::bgp::Bgp::startupTimer = nullptr

private

Referenced by handleMessage(), initialize(), and ~Bgp().

---

The documentation for this class was generated from the following files:

• Bgp.h
• Bgp.cc