inet::bgp::BGPSession Class Reference

#include <BGPSession.h>

Inheritance diagram for inet::bgp::BGPSession:

Public Member Functions
	BGPSession (BGPRouting &_bgpRouting)
virtual	~BGPSession ()
void	startConnection ()
void	restartsHoldTimer ()
void	restartsKeepAliveTimer ()
void	restartsConnectRetryTimer (bool start=true)
void	sendOpenMessage ()
void	sendKeepAliveMessage ()
void	addUpdateMsgSent ()
void	listenConnectionFromPeer ()
void	openTCPConnectionToPeer ()
SessionID	findAndStartNextSession (BGPSessionType type)
void	setInfo (SessionInfo info)
void	setTimers (simtime_t *delayTab)
void	setlinkIntf (InterfaceEntry *intf)
void	setSocket (TCPSocket *socket)
void	setSocketListen (TCPSocket *socket)
void	getStatistics (unsigned int *statTab)
bool	isEstablished ()
SessionID	getSessionID ()
BGPSessionType	getType ()
InterfaceEntry *	getLinkIntf ()
IPv4Address	getPeerAddr ()
TCPSocket *	getSocket ()
TCPSocket *	getSocketListen ()
IIPv4RoutingTable *	getIPRoutingTable ()
std::vector< RoutingTableEntry * >	getBGPRoutingTable ()
Macho::Machine< fsm::TopState > &	getFSM ()
bool	checkExternalRoute (const IPv4Route *ospfRoute)
void	updateSendProcess (RoutingTableEntry *entry)

Private Attributes
SessionInfo	_info
BGPRouting &	_bgpRouting
simtime_t	_StartEventTime
cMessage *	_ptrStartEvent
unsigned int	_connectRetryCounter
simtime_t	_connectRetryTime
cMessage *	_ptrConnectRetryTimer
simtime_t	_holdTime
cMessage *	_ptrHoldTimer
simtime_t	_keepAliveTime
cMessage *	_ptrKeepAliveTimer
unsigned int	_openMsgSent
unsigned int	_openMsgRcv
unsigned int	_keepAliveMsgSent
unsigned int	_keepAliveMsgRcv
unsigned int	_updateMsgSent
unsigned int	_updateMsgRcv
fsm::TopState::Box *	_box
Macho::Machine< fsm::TopState > *	_fsm

Static Private Attributes
static const int	BGP_RETRY_TIME = 120
static const int	BGP_HOLD_TIME = 180
static const int	BGP_KEEP_ALIVE = 60
static const int	NB_SEC_START_EGP_SESSION = 1

Friends
struct	fsm::Idle
struct	fsm::Connect
struct	fsm::Active
struct	fsm::OpenSent
struct	fsm::OpenConfirm
struct	fsm::Established

Constructor & Destructor Documentation

inet::bgp::BGPSession::BGPSession

(

BGPRouting &

_bgpRouting

)

    : _bgpRouting(_bgpRouting), _ptrStartEvent(nullptr), _connectRetryCounter(0)
    , _connectRetryTime(BGP_RETRY_TIME), _ptrConnectRetryTimer(nullptr)
    , _holdTime(BGP_HOLD_TIME), _ptrHoldTimer(nullptr)
    , _keepAliveTime(BGP_KEEP_ALIVE), _ptrKeepAliveTimer(nullptr)
    , _openMsgSent(0), _openMsgRcv(0), _keepAliveMsgSent(0)
    , _keepAliveMsgRcv(0), _updateMsgSent(0), _updateMsgRcv(0)
{
    _box = new fsm::TopState::Box(*this);
    _fsm = new Macho::Machine<fsm::TopState>(_box);
    _info.sessionEstablished = false;
};

inet::bgp::BGPSession::~BGPSession ( )

virtual

{
    _bgpRouting.getCancelAndDelete(_ptrConnectRetryTimer);
    _bgpRouting.getCancelAndDelete(_ptrStartEvent);
    _bgpRouting.getCancelAndDelete(_ptrHoldTimer);
    _bgpRouting.getCancelAndDelete(_ptrKeepAliveTimer);
    delete _info.socket;
    delete _info.socketListen;
    delete _fsm;
}

Member Function Documentation

void inet::bgp::BGPSession::addUpdateMsgSent ( )

inline

{ _updateMsgSent++; }

bool inet::bgp::BGPSession::checkExternalRoute ( const IPv4Route *  ospfRoute )

inline

{ return _bgpRouting.checkExternalRoute(ospfRoute); }

SessionID inet::bgp::BGPSession::findAndStartNextSession ( BGPSessionType  type )

inline

{ return _bgpRouting.findNextSession(type, true); }

std::vector<RoutingTableEntry *> inet::bgp::BGPSession::getBGPRoutingTable ( )

inline

{ return _bgpRouting.getBGPRoutingTable(); }

Macho::Machine<fsm::TopState>& inet::bgp::BGPSession::getFSM ( )

inline

Referenced by inet::bgp::BGPRouting::handleTimer().

{ return *_fsm; }

IIPv4RoutingTable* inet::bgp::BGPSession::getIPRoutingTable ( )

inline

{ return _bgpRouting.getIPRoutingTable(); }

InterfaceEntry* inet::bgp::BGPSession::getLinkIntf ( )

inline

{ return _info.linkIntf; }

IPv4Address inet::bgp::BGPSession::getPeerAddr ( )

inline

{ return _info.peerAddr; }

SessionID inet::bgp::BGPSession::getSessionID ( )

inline

{ return _info.sessionID; }

TCPSocket* inet::bgp::BGPSession::getSocket ( )

inline

{ return _info.socket; }

TCPSocket* inet::bgp::BGPSession::getSocketListen ( )

inline

{ return _info.socketListen; }

void inet::bgp::BGPSession::getStatistics

(

unsigned int *

statTab

)

{
    statTab[0] += _openMsgSent;
    statTab[1] += _openMsgRcv;
    statTab[2] += _keepAliveMsgSent;
    statTab[3] += _keepAliveMsgRcv;
    statTab[4] += _updateMsgSent;
    statTab[5] += _updateMsgRcv;
}

BGPSessionType inet::bgp::BGPSession::getType ( )

inline

{ return _info.sessionType; }

bool inet::bgp::BGPSession::isEstablished ( )

inline

{ return _info.sessionEstablished; }

void inet::bgp::BGPSession::listenConnectionFromPeer ( )

inline

{ _bgpRouting.listenConnectionFromPeer(_info.sessionID); }

void inet::bgp::BGPSession::openTCPConnectionToPeer ( )

inline

{ _bgpRouting.openTCPConnectionToPeer(_info.sessionID); }

void inet::bgp::BGPSession::restartsConnectRetryTimer

(

bool

start = true

)

{
    _bgpRouting.getCancelEvent(_ptrConnectRetryTimer);
    if (!start) {
        _bgpRouting.getScheduleAt(_bgpRouting.getSimTime() + _connectRetryTime, _ptrConnectRetryTimer);
    }
}

void inet::bgp::BGPSession::restartsHoldTimer

(

)

{
    if (_holdTime != 0) {
        _bgpRouting.getCancelEvent(_ptrHoldTimer);
        _bgpRouting.getScheduleAt(_bgpRouting.getSimTime() + _holdTime, _ptrHoldTimer);
    }
}

void inet::bgp::BGPSession::restartsKeepAliveTimer

(

)

{
    _bgpRouting.getCancelEvent(_ptrKeepAliveTimer);
    _bgpRouting.getScheduleAt(_bgpRouting.getSimTime() + _keepAliveTime, _ptrKeepAliveTimer);
}

void inet::bgp::BGPSession::sendKeepAliveMessage

(

)

{
    BGPKeepAliveMessage *keepAliveMsg = new BGPKeepAliveMessage("BGPKeepAlive");
    _info.socket->send(keepAliveMsg);
    _keepAliveMsgSent++;
}

void inet::bgp::BGPSession::sendOpenMessage

(

)

{
    BGPOpenMessage *openMsg = new BGPOpenMessage("BGPOpen");
    openMsg->setMyAS(_info.ASValue);
    openMsg->setHoldTime(_holdTime);
    openMsg->setBGPIdentifier(_info.socket->getLocalAddress().toIPv4());
    _info.socket->send(openMsg);
    _openMsgSent++;
}

void inet::bgp::BGPSession::setInfo

(

SessionInfo

info

)

Referenced by inet::bgp::BGPRouting::createSession().

{
    _info.sessionType = info.sessionType;
    _info.ASValue = info.ASValue;
    _info.routerID = info.routerID;
    _info.peerAddr = info.peerAddr;
    _info.sessionID = info.sessionID;
    _info.linkIntf = info.linkIntf;
    _info.socket = new TCPSocket();
}

void inet::bgp::BGPSession::setlinkIntf ( InterfaceEntry *  intf )

inline

{ _info.linkIntf = intf; }

void inet::bgp::BGPSession::setSocket ( TCPSocket *  socket )

inline

{ delete _info.socket; _info.socket = socket; }

void inet::bgp::BGPSession::setSocketListen ( TCPSocket *  socket )

inline

{ delete _info.socketListen; _info.socketListen = socket; }

void inet::bgp::BGPSession::setTimers

(

simtime_t *

delayTab

)

{
    _connectRetryTime = delayTab[0];
    _holdTime = delayTab[1];
    _keepAliveTime = delayTab[2];
    if (_info.sessionType == IGP) {
        _StartEventTime = delayTab[3];
    }
    else if (delayTab[3] != SIMTIME_ZERO) {
        _StartEventTime = delayTab[3];
        _ptrStartEvent = new cMessage("BGP Start", START_EVENT_KIND);
        _bgpRouting.getScheduleAt(_bgpRouting.getSimTime() + _StartEventTime, _ptrStartEvent);
        _ptrStartEvent->setContextPointer(this);
    }
    _ptrConnectRetryTimer = new cMessage("BGP Connect Retry", CONNECT_RETRY_KIND);
    _ptrHoldTimer = new cMessage("BGP Hold Timer", HOLD_TIME_KIND);
    _ptrKeepAliveTimer = new cMessage("BGP Keep Alive Timer", KEEP_ALIVE_KIND);

    _ptrConnectRetryTimer->setContextPointer(this);
    _ptrHoldTimer->setContextPointer(this);
    _ptrKeepAliveTimer->setContextPointer(this);
}

void inet::bgp::BGPSession::startConnection

(

)

{
    if (_ptrStartEvent == nullptr) {
        _ptrStartEvent = new cMessage("BGP Start", START_EVENT_KIND);
    }
    if (_info.sessionType == IGP) {
        if (_bgpRouting.getSimTime() > _StartEventTime) {
            _StartEventTime = _bgpRouting.getSimTime();
        }
        _bgpRouting.getScheduleAt(_StartEventTime, _ptrStartEvent);
        _ptrStartEvent->setContextPointer(this);
    }
}

void inet::bgp::BGPSession::updateSendProcess ( RoutingTableEntry *  entry )

inline

{ return _bgpRouting.updateSendProcess(NEW_SESSION_ESTABLISHED, _info.sessionID, entry); }

Friends And Related Function Documentation

friend struct fsm::Active

friend

friend struct fsm::Connect

friend

friend struct fsm::Established

friend

friend struct fsm::Idle

friend

friend struct fsm::OpenConfirm

friend

friend struct fsm::OpenSent

friend

Member Data Documentation

BGPRouting& inet::bgp::BGPSession::_bgpRouting

private

Referenced by restartsConnectRetryTimer(), restartsHoldTimer(), restartsKeepAliveTimer(), setTimers(), startConnection(), and ~BGPSession().

fsm::TopState::Box* inet::bgp::BGPSession::_box

private

Referenced by BGPSession().

unsigned int inet::bgp::BGPSession::_connectRetryCounter

private

simtime_t inet::bgp::BGPSession::_connectRetryTime

private

Referenced by restartsConnectRetryTimer(), and setTimers().

Macho::Machine<fsm::TopState>* inet::bgp::BGPSession::_fsm

private

Referenced by BGPSession(), and ~BGPSession().

simtime_t inet::bgp::BGPSession::_holdTime

private

Referenced by restartsHoldTimer(), sendOpenMessage(), and setTimers().

SessionInfo inet::bgp::BGPSession::_info

private

Referenced by BGPSession(), sendKeepAliveMessage(), sendOpenMessage(), setInfo(), setTimers(), startConnection(), and ~BGPSession().

unsigned int inet::bgp::BGPSession::_keepAliveMsgRcv

private

Referenced by getStatistics().

unsigned int inet::bgp::BGPSession::_keepAliveMsgSent

private

Referenced by getStatistics(), and sendKeepAliveMessage().

simtime_t inet::bgp::BGPSession::_keepAliveTime

private

Referenced by restartsKeepAliveTimer(), and setTimers().

unsigned int inet::bgp::BGPSession::_openMsgRcv

private

Referenced by getStatistics().

unsigned int inet::bgp::BGPSession::_openMsgSent

private

Referenced by getStatistics(), and sendOpenMessage().

cMessage* inet::bgp::BGPSession::_ptrConnectRetryTimer

private

Referenced by restartsConnectRetryTimer(), setTimers(), and ~BGPSession().

cMessage* inet::bgp::BGPSession::_ptrHoldTimer

private

Referenced by restartsHoldTimer(), setTimers(), and ~BGPSession().

cMessage* inet::bgp::BGPSession::_ptrKeepAliveTimer

private

Referenced by restartsKeepAliveTimer(), setTimers(), and ~BGPSession().

cMessage* inet::bgp::BGPSession::_ptrStartEvent

private

Referenced by setTimers(), startConnection(), and ~BGPSession().

simtime_t inet::bgp::BGPSession::_StartEventTime

private

Referenced by setTimers(), and startConnection().

unsigned int inet::bgp::BGPSession::_updateMsgRcv

private

Referenced by getStatistics().

unsigned int inet::bgp::BGPSession::_updateMsgSent

private

Referenced by getStatistics().

const int inet::bgp::BGPSession::BGP_HOLD_TIME = 180

staticprivate

const int inet::bgp::BGPSession::BGP_KEEP_ALIVE = 60

staticprivate

const int inet::bgp::BGPSession::BGP_RETRY_TIME = 120

staticprivate

const int inet::bgp::BGPSession::NB_SEC_START_EGP_SESSION = 1

staticprivate

---

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

• BGPSession.h
• BGPSession.cc