#include <OSPFNeighbor.h>

Classes
struct	DDPacketID

struct	TransmittedLSA

Public Types
enum	NeighborEventType { HELLO_RECEIVED = 0, START = 1, TWOWAY_RECEIVED = 2, NEGOTIATION_DONE = 3, EXCHANGE_DONE = 4, BAD_LINK_STATE_REQUEST = 5, LOADING_DONE = 6, IS_ADJACENCY_OK = 7, SEQUENCE_NUMBER_MISMATCH = 8, ONEWAY_RECEIVED = 9, KILL_NEIGHBOR = 10, INACTIVITY_TIMER = 11, POLL_TIMER = 12, LINK_DOWN = 13, DD_RETRANSMISSION_TIMER = 14, UPDATE_RETRANSMISSION_TIMER = 15, REQUEST_RETRANSMISSION_TIMER = 16 }

enum	NeighborStateType { DOWN_STATE = 0, ATTEMPT_STATE = 1, INIT_STATE = 2, TWOWAY_STATE = 4, EXCHANGE_START_STATE = 8, EXCHANGE_STATE = 16, LOADING_STATE = 32, FULL_STATE = 64 }

enum	DatabaseExchangeRelationshipType { MASTER = 0, SLAVE = 1 }

Public Member Functions
	Neighbor (RouterID neighbor=NULL_ROUTERID)

virtual	~Neighbor ()

void	processEvent (NeighborEventType event)

void	reset ()

void	initFirstAdjacency ()

NeighborStateType	getState () const

void	sendDatabaseDescriptionPacket (bool init=false)

bool	retransmitDatabaseDescriptionPacket ()

void	createDatabaseSummary ()

void	sendLinkStateRequestPacket ()

void	retransmitUpdatePacket ()

bool	needAdjacency ()

void	addToRetransmissionList (OSPFLSA *lsa)
	If the LSA is already on the retransmission list then it is replaced, else a copy of the LSA is added to the end of the retransmission list. More...

void	removeFromRetransmissionList (LSAKeyType lsaKey)

bool	isLinkStateRequestListEmpty (LSAKeyType lsaKey) const

OSPFLSA *	findOnRetransmissionList (LSAKeyType lsaKey)

void	startUpdateRetransmissionTimer ()

void	clearUpdateRetransmissionTimer ()

void	addToRequestList (OSPFLSAHeader *lsaHeader)

void	removeFromRequestList (LSAKeyType lsaKey)

bool	isLSAOnRequestList (LSAKeyType lsaKey) const

OSPFLSAHeader *	findOnRequestList (LSAKeyType lsaKey)

void	startRequestRetransmissionTimer ()

void	clearRequestRetransmissionTimer ()

void	addToTransmittedLSAList (LSAKeyType lsaKey)

bool	isOnTransmittedLSAList (LSAKeyType lsaKey) const

void	ageTransmittedLSAList ()

unsigned long	getUniqueULong ()

void	deleteLastSentDDPacket ()

void	setNeighborID (RouterID id)

RouterID	getNeighborID () const

void	setPriority (unsigned char priority)

unsigned char	getPriority () const

void	setAddress (IPv4Address address)

IPv4Address	getAddress () const

void	setDesignatedRouter (DesignatedRouterID routerID)

DesignatedRouterID	getDesignatedRouter () const

void	setBackupDesignatedRouter (DesignatedRouterID routerID)

DesignatedRouterID	getBackupDesignatedRouter () const

void	setRouterDeadInterval (short interval)

short	getRouterDeadInterval () const

void	setDDSequenceNumber (unsigned long sequenceNumber)

unsigned long	getDDSequenceNumber () const

void	setOptions (OSPFOptions options)

OSPFOptions	getOptions () const

void	setLastReceivedDDPacket (DDPacketID packetID)

DDPacketID	getLastReceivedDDPacket () const

void	setDatabaseExchangeRelationship (DatabaseExchangeRelationshipType relation)

DatabaseExchangeRelationshipType	getDatabaseExchangeRelationship () const

void	setInterface (Interface *intf)

Interface *	getInterface ()

const Interface *	getInterface () const

cMessage *	getInactivityTimer ()

cMessage *	getPollTimer ()

cMessage *	getDDRetransmissionTimer ()

cMessage *	getUpdateRetransmissionTimer ()

bool	isUpdateRetransmissionTimerActive () const

bool	isRequestRetransmissionTimerActive () const

bool	isFirstAdjacencyInited () const

bool	designatedRoutersAreSetUp () const

void	setupDesignatedRouters (bool setUp)

unsigned long	getDatabaseSummaryListCount () const

void	incrementDDSequenceNumber ()

bool	isLinkStateRequestListEmpty () const

bool	isLinkStateRetransmissionListEmpty () const

void	popFirstLinkStateRequest ()

Static Public Member Functions
static const char *	getStateString (NeighborStateType stateType)

Private Member Functions
void	changeState (NeighborState newState, NeighborState currentState)

Private Attributes
NeighborState *	state = nullptr

NeighborState *	previousState = nullptr

cMessage *	inactivityTimer = nullptr

cMessage *	pollTimer = nullptr

cMessage *	ddRetransmissionTimer = nullptr

cMessage *	updateRetransmissionTimer = nullptr

bool	updateRetransmissionTimerActive = false

cMessage *	requestRetransmissionTimer = nullptr

bool	requestRetransmissionTimerActive = false

DatabaseExchangeRelationshipType	databaseExchangeRelationship = (DatabaseExchangeRelationshipType)-1

bool	firstAdjacencyInited = false

unsigned long	ddSequenceNumber = 0

DDPacketID	lastReceivedDDPacket

RouterID	neighborID

unsigned char	neighborPriority = 0

IPv4Address	neighborIPAddress

OSPFOptions	neighborOptions

DesignatedRouterID	neighborsDesignatedRouter

DesignatedRouterID	neighborsBackupDesignatedRouter

bool	designatedRoutersSetUp = false

short	neighborsRouterDeadInterval = 0

std::list< OSPFLSA * >	linkStateRetransmissionList

std::list< OSPFLSAHeader * >	databaseSummaryList

std::list< OSPFLSAHeader * >	linkStateRequestList

std::list< TransmittedLSA >	transmittedLSAs

OSPFDatabaseDescriptionPacket *	lastTransmittedDDPacket = nullptr

Interface *	parentInterface = nullptr

Static Private Attributes
static unsigned long	ddSequenceNumberInitSeed = 0

Friends
class	NeighborState

Member Enumeration Documentation

enum inet::ospf::Neighbor::DatabaseExchangeRelationshipType

Enumerator
MASTER
SLAVE

                                           {
         MASTER = 0,
         SLAVE = 1
     };

enum inet::ospf::Neighbor::NeighborEventType

Enumerator
HELLO_RECEIVED
START
TWOWAY_RECEIVED
NEGOTIATION_DONE
EXCHANGE_DONE
BAD_LINK_STATE_REQUEST
LOADING_DONE
IS_ADJACENCY_OK
SEQUENCE_NUMBER_MISMATCH
ONEWAY_RECEIVED
KILL_NEIGHBOR
INACTIVITY_TIMER
POLL_TIMER
LINK_DOWN
DD_RETRANSMISSION_TIMER
UPDATE_RETRANSMISSION_TIMER
REQUEST_RETRANSMISSION_TIMER

                            {
         HELLO_RECEIVED = 0,
         START = 1,
         TWOWAY_RECEIVED = 2,
         NEGOTIATION_DONE = 3,
         EXCHANGE_DONE = 4,
         BAD_LINK_STATE_REQUEST = 5,
         LOADING_DONE = 6,
         IS_ADJACENCY_OK = 7,
         SEQUENCE_NUMBER_MISMATCH = 8,
         ONEWAY_RECEIVED = 9,
         KILL_NEIGHBOR = 10,
         INACTIVITY_TIMER = 11,
         POLL_TIMER = 12,
         LINK_DOWN = 13,
         DD_RETRANSMISSION_TIMER = 14,
         UPDATE_RETRANSMISSION_TIMER = 15,
         REQUEST_RETRANSMISSION_TIMER = 16
     };

enum inet::ospf::Neighbor::NeighborStateType

Enumerator
DOWN_STATE
ATTEMPT_STATE
INIT_STATE
TWOWAY_STATE
EXCHANGE_START_STATE
EXCHANGE_STATE
LOADING_STATE
FULL_STATE

                            {
         DOWN_STATE = 0,
         ATTEMPT_STATE = 1,
         INIT_STATE = 2,
         TWOWAY_STATE = 4,
         EXCHANGE_START_STATE = 8,
         EXCHANGE_STATE = 16,
         LOADING_STATE = 32,
         FULL_STATE = 64
     };

Constructor & Destructor Documentation

inet::ospf::Neighbor::Neighbor ( RouterID neighbor = NULL_ROUTERID )

                                     :
     neighborID(neighbor),
     neighborIPAddress(NULL_IPV4ADDRESS),
     neighborsDesignatedRouter(NULL_DESIGNATEDROUTERID),
     neighborsBackupDesignatedRouter(NULL_DESIGNATEDROUTERID),
     neighborsRouterDeadInterval(40)
 {
     memset(&lastReceivedDDPacket, 0, sizeof(Neighbor::DDPacketID));
     // setting only I and M bits is invalid -> good initializer
     lastReceivedDDPacket.ddOptions.I_Init = true;
     lastReceivedDDPacket.ddOptions.M_More = true;
     inactivityTimer = new cMessage();
     inactivityTimer->setKind(NEIGHBOR_INACTIVITY_TIMER);
     inactivityTimer->setContextPointer(this);
     inactivityTimer->setName("Neighbor::NeighborInactivityTimer");
     pollTimer = new cMessage();
     pollTimer->setKind(NEIGHBOR_POLL_TIMER);
     pollTimer->setContextPointer(this);
     pollTimer->setName("Neighbor::NeighborPollTimer");
     ddRetransmissionTimer = new cMessage();
     ddRetransmissionTimer->setKind(NEIGHBOR_DD_RETRANSMISSION_TIMER);
     ddRetransmissionTimer->setContextPointer(this);
     ddRetransmissionTimer->setName("Neighbor::NeighborDDRetransmissionTimer");
     updateRetransmissionTimer = new cMessage();
     updateRetransmissionTimer->setKind(NEIGHBOR_UPDATE_RETRANSMISSION_TIMER);
     updateRetransmissionTimer->setContextPointer(this);
     updateRetransmissionTimer->setName("Neighbor::Neighbor::NeighborUpdateRetransmissionTimer");
     requestRetransmissionTimer = new cMessage();
     requestRetransmissionTimer->setKind(NEIGHBOR_REQUEST_RETRANSMISSION_TIMER);
     requestRetransmissionTimer->setContextPointer(this);
     requestRetransmissionTimer->setName("Neighbor::NeighborRequestRetransmissionTimer");
     state = new NeighborStateDown;
     previousState = nullptr;
 }

inet::ospf::Neighbor::~Neighbor ( )

virtual

 {
     reset();
     MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
     messageHandler->clearTimer(inactivityTimer);
     messageHandler->clearTimer(pollTimer);
     delete inactivityTimer;
     delete pollTimer;
     delete ddRetransmissionTimer;
     delete updateRetransmissionTimer;
     delete requestRetransmissionTimer;
     if (previousState != nullptr) {
         delete previousState;
     }
     delete state;
 }

Member Function Documentation

void inet::ospf::Neighbor::addToRequestList ( OSPFLSAHeader * lsaHeader )

Referenced by inet::ospf::DatabaseDescriptionHandler::processDDPacket().

 {
     linkStateRequestList.push_back(new OSPFLSAHeader(*lsaHeader));
 }

void inet::ospf::Neighbor::addToRetransmissionList ( OSPFLSA * lsa )

If the LSA is already on the retransmission list then it is replaced, else a copy of the LSA is added to the end of the retransmission list.

Parameters

lsa	[in] The LSA to be added.

 {
     auto it = linkStateRetransmissionList.begin();
     for ( ; it != linkStateRetransmissionList.end(); it++) {
         if (((*it)->getHeader().getLinkStateID() == lsa->getHeader().getLinkStateID()) &&
             ((*it)->getHeader().getAdvertisingRouter().getInt() == lsa->getHeader().getAdvertisingRouter().getInt()))
         {
             break;
         }
     }
 
     OSPFLSA *lsaCopy = nullptr;
     switch (lsa->getHeader().getLsType()) {
         case ROUTERLSA_TYPE:
             lsaCopy = new OSPFRouterLSA(*(check_and_cast<OSPFRouterLSA *>(lsa)));
             break;
 
         case NETWORKLSA_TYPE:
             lsaCopy = new OSPFNetworkLSA(*(check_and_cast<OSPFNetworkLSA *>(lsa)));
             break;
 
         case SUMMARYLSA_NETWORKS_TYPE:
         case SUMMARYLSA_ASBOUNDARYROUTERS_TYPE:
             lsaCopy = new OSPFSummaryLSA(*(check_and_cast<OSPFSummaryLSA *>(lsa)));
             break;
 
         case AS_EXTERNAL_LSA_TYPE:
             lsaCopy = new OSPFASExternalLSA(*(check_and_cast<OSPFASExternalLSA *>(lsa)));
             break;
 
         default:
             ASSERT(false);    // error
             break;
     }
 
     if (it != linkStateRetransmissionList.end()) {
         delete (*it);
         *it = static_cast<OSPFLSA *>(lsaCopy);
     }
     else {
         linkStateRetransmissionList.push_back(static_cast<OSPFLSA *>(lsaCopy));
     }
 }

void inet::ospf::Neighbor::addToTransmittedLSAList ( LSAKeyType lsaKey )

Referenced by inet::ospf::Interface::floodLSA().

 {
     TransmittedLSA transmit;
 
     transmit.lsaKey = lsaKey;
     transmit.age = 0;
 
     transmittedLSAs.push_back(transmit);
 }

void inet::ospf::Neighbor::ageTransmittedLSAList ( )

 {
     auto it = transmittedLSAs.begin();
     while ((it != transmittedLSAs.end()) && (it->age == MIN_LS_ARRIVAL)) {
         transmittedLSAs.pop_front();
         it = transmittedLSAs.begin();
     }
     for (it = transmittedLSAs.begin(); it != transmittedLSAs.end(); it++) {
         it->age++;
     }
 }

void inet::ospf::Neighbor::changeState	(	NeighborState *	newState,
		NeighborState *	currentState
	)

private

Referenced by inet::ospf::NeighborState::changeState().

 {
     if (previousState != nullptr) {
         delete previousState;
     }
     state = newState;
     previousState = currentState;
 }

void inet::ospf::Neighbor::clearRequestRetransmissionTimer ( )

Referenced by inet::ospf::NeighborStateExchange::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::DatabaseDescriptionHandler::processPacket(), removeFromRequestList(), and reset().

 {
     MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
     messageHandler->clearTimer(requestRetransmissionTimer);
     requestRetransmissionTimerActive = false;
 }

void inet::ospf::Neighbor::clearUpdateRetransmissionTimer ( )

Referenced by inet::ospf::LinkStateAcknowledgementHandler::processPacket(), and reset().

 {
     MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
     messageHandler->clearTimer(updateRetransmissionTimer);
     updateRetransmissionTimerActive = false;
 }

void inet::ospf::Neighbor::createDatabaseSummary ( )

Referenced by inet::ospf::NeighborStateExchangeStart::processEvent().

 {
     Area *area = parentInterface->getArea();
     unsigned long routerLSACount = area->getRouterLSACount();
 
     /* Note: OSPF specification says:
      * "LSAs whose age is equal to MaxAge are instead added to the neighbor's
      *  Link state retransmission list."
      * But this task has been already done during the aging of the database. (???)
      * So we'll skip this.
      */
     for (unsigned long i = 0; i < routerLSACount; i++) {
         if (area->getRouterLSA(i)->getHeader().getLsAge() < MAX_AGE) {
             OSPFLSAHeader *routerLSA = new OSPFLSAHeader(area->getRouterLSA(i)->getHeader());
             databaseSummaryList.push_back(routerLSA);
         }
     }
 
     unsigned long networkLSACount = area->getNetworkLSACount();
     for (unsigned long j = 0; j < networkLSACount; j++) {
         if (area->getNetworkLSA(j)->getHeader().getLsAge() < MAX_AGE) {
             OSPFLSAHeader *networkLSA = new OSPFLSAHeader(area->getNetworkLSA(j)->getHeader());
             databaseSummaryList.push_back(networkLSA);
         }
     }
 
     unsigned long summaryLSACount = area->getSummaryLSACount();
     for (unsigned long k = 0; k < summaryLSACount; k++) {
         if (area->getSummaryLSA(k)->getHeader().getLsAge() < MAX_AGE) {
             OSPFLSAHeader *summaryLSA = new OSPFLSAHeader(area->getSummaryLSA(k)->getHeader());
             databaseSummaryList.push_back(summaryLSA);
         }
     }
 
     if ((parentInterface->getType() != Interface::VIRTUAL) &&
         (area->getExternalRoutingCapability()))
     {
         Router *router = area->getRouter();
         unsigned long asExternalLSACount = router->getASExternalLSACount();
 
         for (unsigned long m = 0; m < asExternalLSACount; m++) {
             if (router->getASExternalLSA(m)->getHeader().getLsAge() < MAX_AGE) {
                 OSPFLSAHeader *asExternalLSA = new OSPFLSAHeader(router->getASExternalLSA(m)->getHeader());
                 databaseSummaryList.push_back(asExternalLSA);
             }
         }
     }
 }

void inet::ospf::Neighbor::deleteLastSentDDPacket ( )

Referenced by inet::ospf::NeighborStateFull::processEvent(), and inet::ospf::NeighborStateLoading::processEvent().

 {
     if (lastTransmittedDDPacket != nullptr) {
         delete lastTransmittedDDPacket;
         lastTransmittedDDPacket = nullptr;
     }
 }

bool inet::ospf::Neighbor::designatedRoutersAreSetUp ( ) const

inline

Referenced by inet::ospf::HelloHandler::processPacket().

193 { return designatedRoutersSetUp; }

inet::ospf::Neighbor::designatedRoutersSetUp

bool designatedRoutersSetUp

Definition: OSPFNeighbor.h:111

OSPFLSAHeader * inet::ospf::Neighbor::findOnRequestList ( LSAKeyType lsaKey )

 {
     for (auto & elem : linkStateRequestList) {
         if (((elem)->getLinkStateID() == lsaKey.linkStateID) &&
             ((elem)->getAdvertisingRouter() == lsaKey.advertisingRouter))
         {
             return elem;
         }
     }
     return nullptr;
 }

OSPFLSA * inet::ospf::Neighbor::findOnRetransmissionList ( LSAKeyType lsaKey )

Referenced by inet::ospf::LinkStateAcknowledgementHandler::processPacket().

 {
     for (auto & elem : linkStateRetransmissionList) {
         if (((elem)->getHeader().getLinkStateID() == lsaKey.linkStateID) &&
             ((elem)->getHeader().getAdvertisingRouter() == lsaKey.advertisingRouter))
         {
             return elem;
         }
     }
     return nullptr;
 }

IPv4Address inet::ospf::Neighbor::getAddress ( ) const

inline

Referenced by inet::ospf::LinkStateUpdateHandler::acknowledgeLSA(), inet::ospf::Interface::addNeighbor(), inet::ospf::InterfaceState::calculateDesignatedRouter(), inet::ospf::Area::calculateNextHops(), inet::ospf::Area::originateRouterLSA(), inet::ospf::InterfaceStateNotDesignatedRouter::processEvent(), inet::ospf::InterfaceStateWaiting::processEvent(), inet::ospf::InterfaceStateBackup::processEvent(), inet::ospf::NeighborStateDown::processEvent(), inet::ospf::InterfaceStateDesignatedRouter::processEvent(), inet::ospf::InterfaceStatePointToPoint::processEvent(), inet::ospf::HelloHandler::processPacket(), inet::ospf::LinkStateRequestHandler::processPacket(), and inet::ospf::LinkStateUpdateHandler::processPacket().

165 { return neighborIPAddress; }

inet::ospf::Neighbor::neighborIPAddress

IPv4Address neighborIPAddress

Definition: OSPFNeighbor.h:107

DesignatedRouterID inet::ospf::Neighbor::getBackupDesignatedRouter ( ) const

inline

Referenced by inet::ospf::InterfaceState::calculateDesignatedRouter(), and inet::ospf::HelloHandler::processPacket().

169 { return neighborsBackupDesignatedRouter; }

inet::ospf::Neighbor::neighborsBackupDesignatedRouter

DesignatedRouterID neighborsBackupDesignatedRouter

Definition: OSPFNeighbor.h:110

DatabaseExchangeRelationshipType inet::ospf::Neighbor::getDatabaseExchangeRelationship ( ) const

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processDDPacket(), and inet::ospf::DatabaseDescriptionHandler::processPacket().

180 { return databaseExchangeRelationship; }

inet::ospf::Neighbor::databaseExchangeRelationship

DatabaseExchangeRelationshipType databaseExchangeRelationship

Definition: OSPFNeighbor.h:101

unsigned long inet::ospf::Neighbor::getDatabaseSummaryListCount ( ) const

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processDDPacket().

195 { return databaseSummaryList.size(); }

inet::ospf::Neighbor::databaseSummaryList

std::list< OSPFLSAHeader * > databaseSummaryList

Definition: OSPFNeighbor.h:114

cMessage* inet::ospf::Neighbor::getDDRetransmissionTimer ( )

inline

Referenced by inet::ospf::NeighborStateExchange::processEvent(), inet::ospf::NeighborStateTwoWay::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), and inet::ospf::NeighborStateExchangeStart::processEvent().

188 { return ddRetransmissionTimer; }

inet::ospf::Neighbor::ddRetransmissionTimer

cMessage * ddRetransmissionTimer

Definition: OSPFNeighbor.h:96

unsigned long inet::ospf::Neighbor::getDDSequenceNumber ( ) const

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processPacket().

173 { return ddSequenceNumber; }

inet::ospf::Neighbor::ddSequenceNumber

unsigned long ddSequenceNumber

Definition: OSPFNeighbor.h:103

DesignatedRouterID inet::ospf::Neighbor::getDesignatedRouter ( ) const

inline

Referenced by inet::ospf::InterfaceState::calculateDesignatedRouter(), and inet::ospf::HelloHandler::processPacket().

167 { return neighborsDesignatedRouter; }

inet::ospf::Neighbor::neighborsDesignatedRouter

DesignatedRouterID neighborsDesignatedRouter

Definition: OSPFNeighbor.h:109

cMessage* inet::ospf::Neighbor::getInactivityTimer ( )

inline

Referenced by inet::ospf::NeighborStateAttempt::processEvent(), inet::ospf::NeighborStateTwoWay::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), inet::ospf::NeighborStateExchangeStart::processEvent(), inet::ospf::NeighborStateExchange::processEvent(), and inet::ospf::NeighborStateDown::processEvent().

186 { return inactivityTimer; }

inet::ospf::Neighbor::inactivityTimer

cMessage * inactivityTimer

Definition: OSPFNeighbor.h:94

Interface* inet::ospf::Neighbor::getInterface ( )

inline

Referenced by inet::ospf::NeighborState::changeState(), inet::ospf::MessageHandler::handleTimer(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), inet::ospf::NeighborStateExchangeStart::processEvent(), inet::ospf::NeighborStateExchange::processEvent(), inet::ospf::NeighborStateDown::processEvent(), inet::ospf::NeighborStateAttempt::processEvent(), and inet::ospf::NeighborStateTwoWay::processEvent().

183 { return parentInterface; }

inet::ospf::Neighbor::parentInterface

Interface * parentInterface

Definition: OSPFNeighbor.h:119

const Interface* inet::ospf::Neighbor::getInterface ( ) const

inline

184 { return parentInterface; }

inet::ospf::Neighbor::parentInterface

Interface * parentInterface

Definition: OSPFNeighbor.h:119

DDPacketID inet::ospf::Neighbor::getLastReceivedDDPacket ( ) const

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processPacket().

177 { return lastReceivedDDPacket; }

inet::ospf::Neighbor::lastReceivedDDPacket

DDPacketID lastReceivedDDPacket

Definition: OSPFNeighbor.h:104

RouterID inet::ospf::Neighbor::getNeighborID ( ) const

inline

Referenced by inet::ospf::Interface::addNeighbor(), inet::ospf::InterfaceState::calculateDesignatedRouter(), inet::ospf::Area::calculateNextHops(), inet::ospf::Interface::floodLSA(), inet::ospf::Area::originateNetworkLSA(), inet::ospf::Area::originateRouterLSA(), inet::ospf::MessageHandler::printEvent(), inet::ospf::HelloHandler::processPacket(), and inet::ospf::DatabaseDescriptionHandler::processPacket().

161 { return neighborID; }

inet::ospf::Neighbor::neighborID

RouterID neighborID

Definition: OSPFNeighbor.h:105

OSPFOptions inet::ospf::Neighbor::getOptions ( ) const

inline

175 { return neighborOptions; }

inet::ospf::Neighbor::neighborOptions

OSPFOptions neighborOptions

Definition: OSPFNeighbor.h:108

cMessage* inet::ospf::Neighbor::getPollTimer ( )

inline

Referenced by inet::ospf::NeighborStateAttempt::processEvent(), inet::ospf::NeighborStateTwoWay::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), inet::ospf::NeighborStateExchangeStart::processEvent(), inet::ospf::NeighborStateExchange::processEvent(), and inet::ospf::NeighborStateDown::processEvent().

187 { return pollTimer; }

inet::ospf::Neighbor::pollTimer

cMessage * pollTimer

Definition: OSPFNeighbor.h:95

unsigned char inet::ospf::Neighbor::getPriority ( ) const

inline

Referenced by inet::ospf::InterfaceState::calculateDesignatedRouter(), inet::ospf::InterfaceStateWaiting::processEvent(), inet::ospf::InterfaceStateNotDesignatedRouter::processEvent(), inet::ospf::InterfaceStateDown::processEvent(), and inet::ospf::HelloHandler::processPacket().

163 { return neighborPriority; }

inet::ospf::Neighbor::neighborPriority

unsigned char neighborPriority

Definition: OSPFNeighbor.h:106

short inet::ospf::Neighbor::getRouterDeadInterval ( ) const

inline

Referenced by inet::ospf::NeighborStateAttempt::processEvent(), inet::ospf::NeighborStateTwoWay::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), inet::ospf::NeighborStateExchangeStart::processEvent(), inet::ospf::NeighborStateExchange::processEvent(), and inet::ospf::NeighborStateDown::processEvent().

171 { return neighborsRouterDeadInterval; }

inet::ospf::Neighbor::neighborsRouterDeadInterval

short neighborsRouterDeadInterval

Definition: OSPFNeighbor.h:112

Neighbor::NeighborStateType inet::ospf::Neighbor::getState ( ) const

Referenced by inet::ospf::InterfaceState::calculateDesignatedRouter(), inet::ospf::Area::originateNetworkLSA(), inet::ospf::Area::originateRouterLSA(), inet::ospf::MessageHandler::printEvent(), inet::ospf::HelloHandler::processPacket(), inet::ospf::LinkStateRequestHandler::processPacket(), inet::ospf::LinkStateAcknowledgementHandler::processPacket(), inet::ospf::DatabaseDescriptionHandler::processPacket(), inet::ospf::LinkStateUpdateHandler::processPacket(), and removeFromRequestList().

 {
     return state->getState();
 }

const char * inet::ospf::Neighbor::getStateString ( Neighbor::NeighborStateType stateType )

static

Referenced by inet::ospf::MessageHandler::printEvent().

 {
     switch (stateType) {
         case DOWN_STATE:
             return "Down";
 
         case ATTEMPT_STATE:
             return "Attempt";
 
         case INIT_STATE:
             return "Init";
 
         case TWOWAY_STATE:
             return "TwoWay";
 
         case EXCHANGE_START_STATE:
             return "ExchangeStart";
 
         case EXCHANGE_STATE:
             return "Exchange";
 
         case LOADING_STATE:
             return "Loading";
 
         case FULL_STATE:
             return "Full";
 
         default:
             ASSERT(false);
             break;
     }
     return "";
 }

unsigned long inet::ospf::Neighbor::getUniqueULong ( )

Referenced by initFirstAdjacency().

 {
     // FIXME!!! Should come from a global unique number generator module.
     return ddSequenceNumberInitSeed++;
 }

cMessage* inet::ospf::Neighbor::getUpdateRetransmissionTimer ( )

inline

189 { return updateRetransmissionTimer; }

inet::ospf::Neighbor::updateRetransmissionTimer

cMessage * updateRetransmissionTimer

Definition: OSPFNeighbor.h:97

void inet::ospf::Neighbor::incrementDDSequenceNumber ( )

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processDDPacket(), inet::ospf::NeighborStateTwoWay::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), and inet::ospf::NeighborStateExchange::processEvent().

197 { ddSequenceNumber++; }

inet::ospf::Neighbor::ddSequenceNumber

unsigned long ddSequenceNumber

Definition: OSPFNeighbor.h:103

void inet::ospf::Neighbor::initFirstAdjacency ( )

Referenced by inet::ospf::NeighborStateInit::processEvent(), and inet::ospf::NeighborStateTwoWay::processEvent().

 {
     ddSequenceNumber = getUniqueULong();
     firstAdjacencyInited = true;
 }

bool inet::ospf::Neighbor::isFirstAdjacencyInited ( ) const

inline

Referenced by inet::ospf::NeighborStateInit::processEvent(), and inet::ospf::NeighborStateTwoWay::processEvent().

192 { return firstAdjacencyInited; }

inet::ospf::Neighbor::firstAdjacencyInited

bool firstAdjacencyInited

Definition: OSPFNeighbor.h:102

bool inet::ospf::Neighbor::isLinkStateRequestListEmpty ( LSAKeyType lsaKey ) const

Referenced by inet::ospf::NeighborStateExchange::processEvent(), inet::ospf::DatabaseDescriptionHandler::processPacket(), and inet::ospf::LinkStateUpdateHandler::processPacket().

 {
     for (auto lsa : linkStateRetransmissionList) {
         if ((lsa->getHeader().getLinkStateID() == lsaKey.linkStateID) &&
             (lsa->getHeader().getAdvertisingRouter() == lsaKey.advertisingRouter))
         {
             return true;
         }
     }
     return false;
 }

bool inet::ospf::Neighbor::isLinkStateRequestListEmpty ( ) const

inline

198 { return linkStateRequestList.empty(); }

inet::ospf::Neighbor::linkStateRequestList

std::list< OSPFLSAHeader * > linkStateRequestList

Definition: OSPFNeighbor.h:115

bool inet::ospf::Neighbor::isLinkStateRetransmissionListEmpty ( ) const

inline

Referenced by inet::ospf::LinkStateAcknowledgementHandler::processPacket().

199 { return linkStateRetransmissionList.empty(); }

inet::ospf::Neighbor::linkStateRetransmissionList

std::list< OSPFLSA * > linkStateRetransmissionList

Definition: OSPFNeighbor.h:113

bool inet::ospf::Neighbor::isLSAOnRequestList ( LSAKeyType lsaKey ) const

Referenced by inet::ospf::LinkStateUpdateHandler::processPacket().

 {
     for (auto lsaHeader : linkStateRequestList) {
         if ((lsaHeader->getLinkStateID() == lsaKey.linkStateID) &&
             (lsaHeader->getAdvertisingRouter() == lsaKey.advertisingRouter))
         {
             return true;
         }
     }
     return false;
 }

bool inet::ospf::Neighbor::isOnTransmittedLSAList ( LSAKeyType lsaKey ) const

Referenced by inet::ospf::LinkStateUpdateHandler::processPacket().

 {
     for (const auto & elem : transmittedLSAs) {
         if ((elem.lsaKey.linkStateID == lsaKey.linkStateID) &&
             (elem.lsaKey.advertisingRouter == lsaKey.advertisingRouter))
         {
             return true;
         }
     }
     return false;
 }

bool inet::ospf::Neighbor::isRequestRetransmissionTimerActive ( ) const

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processPacket().

191 { return requestRetransmissionTimerActive; }

inet::ospf::Neighbor::requestRetransmissionTimerActive

bool requestRetransmissionTimerActive

Definition: OSPFNeighbor.h:100

bool inet::ospf::Neighbor::isUpdateRetransmissionTimerActive ( ) const

inline

Referenced by inet::ospf::Interface::floodLSA().

190 { return updateRetransmissionTimerActive; }

inet::ospf::Neighbor::updateRetransmissionTimerActive

bool updateRetransmissionTimerActive

Definition: OSPFNeighbor.h:98

bool inet::ospf::Neighbor::needAdjacency ( )

Referenced by inet::ospf::NeighborStateExchange::processEvent(), inet::ospf::NeighborStateTwoWay::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), and inet::ospf::NeighborStateExchangeStart::processEvent().

 {
     Interface::OSPFInterfaceType interfaceType = parentInterface->getType();
     RouterID routerID = parentInterface->getArea()->getRouter()->getRouterID();
     DesignatedRouterID dRouter = parentInterface->getDesignatedRouter();
     DesignatedRouterID backupDRouter = parentInterface->getBackupDesignatedRouter();
 
     if ((interfaceType == Interface::POINTTOPOINT) ||
         (interfaceType == Interface::POINTTOMULTIPOINT) ||
         (interfaceType == Interface::VIRTUAL) ||
         (dRouter.routerID == routerID) ||
         (backupDRouter.routerID == routerID) ||
         ((neighborsDesignatedRouter.routerID == dRouter.routerID) ||
          (!designatedRoutersSetUp &&
           (neighborsDesignatedRouter.ipInterfaceAddress == dRouter.ipInterfaceAddress))) ||
         ((neighborsBackupDesignatedRouter.routerID == backupDRouter.routerID) ||
          (!designatedRoutersSetUp &&
           (neighborsBackupDesignatedRouter.ipInterfaceAddress == backupDRouter.ipInterfaceAddress))))
     {
         return true;
     }
     else {
         return false;
     }
 }

void inet::ospf::Neighbor::popFirstLinkStateRequest ( )

inline

200 { linkStateRequestList.pop_front(); }

inet::ospf::Neighbor::linkStateRequestList

std::list< OSPFLSAHeader * > linkStateRequestList

Definition: OSPFNeighbor.h:115

void inet::ospf::Neighbor::processEvent ( Neighbor::NeighborEventType event )

Referenced by inet::ospf::MessageHandler::handleTimer(), inet::ospf::DatabaseDescriptionHandler::processDDPacket(), inet::ospf::InterfaceStateDown::processEvent(), inet::ospf::LinkStateRequestHandler::processPacket(), inet::ospf::HelloHandler::processPacket(), inet::ospf::DatabaseDescriptionHandler::processPacket(), inet::ospf::LinkStateUpdateHandler::processPacket(), and removeFromRequestList().

 {
     state->processEvent(this, event);
 }

void inet::ospf::Neighbor::removeFromRequestList ( LSAKeyType lsaKey )

 {
     auto it = linkStateRequestList.begin();
     while (it != linkStateRequestList.end()) {
         if (((*it)->getLinkStateID() == lsaKey.linkStateID) &&
             ((*it)->getAdvertisingRouter() == lsaKey.advertisingRouter))
         {
             delete (*it);
             it = linkStateRequestList.erase(it);
         }
         else {
             it++;
         }
     }
 
     if ((getState() == Neighbor::LOADING_STATE) && (linkStateRequestList.empty())) {
         clearRequestRetransmissionTimer();
         processEvent(Neighbor::LOADING_DONE);
     }
 }

void inet::ospf::Neighbor::removeFromRetransmissionList ( LSAKeyType lsaKey )

Referenced by inet::ospf::LinkStateAcknowledgementHandler::processPacket(), and inet::ospf::LinkStateUpdateHandler::processPacket().

 {
     auto it = linkStateRetransmissionList.begin();
     while (it != linkStateRetransmissionList.end()) {
         if (((*it)->getHeader().getLinkStateID() == lsaKey.linkStateID) &&
             ((*it)->getHeader().getAdvertisingRouter() == lsaKey.advertisingRouter))
         {
             delete (*it);
             it = linkStateRetransmissionList.erase(it);
         }
         else {
             it++;
         }
     }
 }

void inet::ospf::Neighbor::reset ( )

Referenced by inet::ospf::NeighborStateAttempt::processEvent(), inet::ospf::NeighborStateExchangeStart::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), inet::ospf::NeighborStateTwoWay::processEvent(), inet::ospf::NeighborStateExchange::processEvent(), and ~Neighbor().

 {
     for (auto & elem : linkStateRetransmissionList)
     {
         delete (elem);
     }
     linkStateRetransmissionList.clear();
 
     for (auto & elem : databaseSummaryList) {
         delete (elem);
     }
     databaseSummaryList.clear();
     for (auto & elem : linkStateRequestList) {
         delete (elem);
     }
     linkStateRequestList.clear();
 
     parentInterface->getArea()->getRouter()->getMessageHandler()->clearTimer(ddRetransmissionTimer);
     clearUpdateRetransmissionTimer();
     clearRequestRetransmissionTimer();
 
     if (lastTransmittedDDPacket != nullptr) {
         delete lastTransmittedDDPacket;
         lastTransmittedDDPacket = nullptr;
     }
 }

bool inet::ospf::Neighbor::retransmitDatabaseDescriptionPacket ( )

Referenced by inet::ospf::NeighborStateExchangeStart::processEvent(), and inet::ospf::DatabaseDescriptionHandler::processPacket().

 {
     if (lastTransmittedDDPacket != nullptr) {
         OSPFDatabaseDescriptionPacket *ddPacket = new OSPFDatabaseDescriptionPacket(*lastTransmittedDDPacket);
         MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
         int ttl = (parentInterface->getType() == Interface::VIRTUAL) ? VIRTUAL_LINK_TTL : 1;
 
         if (parentInterface->getType() == Interface::POINTTOPOINT) {
             messageHandler->sendPacket(ddPacket, IPv4Address::ALL_OSPF_ROUTERS_MCAST, parentInterface->getIfIndex(), ttl);
         }
         else {
             messageHandler->sendPacket(ddPacket, neighborIPAddress, parentInterface->getIfIndex(), ttl);
         }
 
         return true;
     }
     else {
         return false;
     }
 }

void inet::ospf::Neighbor::retransmitUpdatePacket ( )

Referenced by inet::ospf::NeighborStateExchange::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), and inet::ospf::NeighborStateFull::processEvent().

 {
     OSPFLinkStateUpdatePacket *updatePacket = new OSPFLinkStateUpdatePacket();
 
     updatePacket->setType(LINKSTATE_UPDATE_PACKET);
     updatePacket->setRouterID(IPv4Address(parentInterface->getArea()->getRouter()->getRouterID()));
     updatePacket->setAreaID(IPv4Address(parentInterface->getArea()->getAreaID()));
     updatePacket->setAuthenticationType(parentInterface->getAuthenticationType());
     AuthenticationKeyType authKey = parentInterface->getAuthenticationKey();
     for (int i = 0; i < 8; i++) {
         updatePacket->setAuthentication(i, authKey.bytes[i]);
     }
 
     bool packetFull = false;
     unsigned short lsaCount = 0;
     unsigned long packetLength = IP_MAX_HEADER_BYTES + OSPF_LSA_HEADER_LENGTH;
     auto it = linkStateRetransmissionList.begin();
 
     while (!packetFull && (it != linkStateRetransmissionList.end())) {
         LSAType lsaType = static_cast<LSAType>((*it)->getHeader().getLsType());
         OSPFRouterLSA *routerLSA = (lsaType == ROUTERLSA_TYPE) ? dynamic_cast<OSPFRouterLSA *>(*it) : nullptr;
         OSPFNetworkLSA *networkLSA = (lsaType == NETWORKLSA_TYPE) ? dynamic_cast<OSPFNetworkLSA *>(*it) : nullptr;
         OSPFSummaryLSA *summaryLSA = ((lsaType == SUMMARYLSA_NETWORKS_TYPE) ||
                                       (lsaType == SUMMARYLSA_ASBOUNDARYROUTERS_TYPE)) ? dynamic_cast<OSPFSummaryLSA *>(*it) : nullptr;
         OSPFASExternalLSA *asExternalLSA = (lsaType == AS_EXTERNAL_LSA_TYPE) ? dynamic_cast<OSPFASExternalLSA *>(*it) : nullptr;
         long lsaSize = 0;
         bool includeLSA = false;
 
         switch (lsaType) {
             case ROUTERLSA_TYPE:
                 if (routerLSA != nullptr) {
                     lsaSize = calculateLSASize(routerLSA);
                 }
                 break;
 
             case NETWORKLSA_TYPE:
                 if (networkLSA != nullptr) {
                     lsaSize = calculateLSASize(networkLSA);
                 }
                 break;
 
             case SUMMARYLSA_NETWORKS_TYPE:
             case SUMMARYLSA_ASBOUNDARYROUTERS_TYPE:
                 if (summaryLSA != nullptr) {
                     lsaSize = calculateLSASize(summaryLSA);
                 }
                 break;
 
             case AS_EXTERNAL_LSA_TYPE:
                 if (asExternalLSA != nullptr) {
                     lsaSize = calculateLSASize(asExternalLSA);
                 }
                 break;
 
             default:
                 break;
         }
 
         if (packetLength + lsaSize < parentInterface->getMTU()) {
             includeLSA = true;
             lsaCount++;
         }
         else {
             if ((lsaCount == 0) && (packetLength + lsaSize < IPV4_DATAGRAM_LENGTH)) {
                 includeLSA = true;
                 lsaCount++;
                 packetFull = true;
             }
         }
 
         if (includeLSA) {
             packetLength += lsaSize;
             switch (lsaType) {
                 case ROUTERLSA_TYPE:
                     if (routerLSA != nullptr) {
                         unsigned int routerLSACount = updatePacket->getRouterLSAsArraySize();
 
                         updatePacket->setRouterLSAsArraySize(routerLSACount + 1);
                         updatePacket->setRouterLSAs(routerLSACount, *routerLSA);
 
                         unsigned short lsAge = updatePacket->getRouterLSAs(routerLSACount).getHeader().getLsAge();
                         if (lsAge < MAX_AGE - parentInterface->getTransmissionDelay()) {
                             updatePacket->getRouterLSAs(routerLSACount).getHeader().setLsAge(lsAge + parentInterface->getTransmissionDelay());
                         }
                         else {
                             updatePacket->getRouterLSAs(routerLSACount).getHeader().setLsAge(MAX_AGE);
                         }
                     }
                     break;
 
                 case NETWORKLSA_TYPE:
                     if (networkLSA != nullptr) {
                         unsigned int networkLSACount = updatePacket->getNetworkLSAsArraySize();
 
                         updatePacket->setNetworkLSAsArraySize(networkLSACount + 1);
                         updatePacket->setNetworkLSAs(networkLSACount, *networkLSA);
 
                         unsigned short lsAge = updatePacket->getNetworkLSAs(networkLSACount).getHeader().getLsAge();
                         if (lsAge < MAX_AGE - parentInterface->getTransmissionDelay()) {
                             updatePacket->getNetworkLSAs(networkLSACount).getHeader().setLsAge(lsAge + parentInterface->getTransmissionDelay());
                         }
                         else {
                             updatePacket->getNetworkLSAs(networkLSACount).getHeader().setLsAge(MAX_AGE);
                         }
                     }
                     break;
 
                 case SUMMARYLSA_NETWORKS_TYPE:
                 case SUMMARYLSA_ASBOUNDARYROUTERS_TYPE:
                     if (summaryLSA != nullptr) {
                         unsigned int summaryLSACount = updatePacket->getSummaryLSAsArraySize();
 
                         updatePacket->setSummaryLSAsArraySize(summaryLSACount + 1);
                         updatePacket->setSummaryLSAs(summaryLSACount, *summaryLSA);
 
                         unsigned short lsAge = updatePacket->getSummaryLSAs(summaryLSACount).getHeader().getLsAge();
                         if (lsAge < MAX_AGE - parentInterface->getTransmissionDelay()) {
                             updatePacket->getSummaryLSAs(summaryLSACount).getHeader().setLsAge(lsAge + parentInterface->getTransmissionDelay());
                         }
                         else {
                             updatePacket->getSummaryLSAs(summaryLSACount).getHeader().setLsAge(MAX_AGE);
                         }
                     }
                     break;
 
                 case AS_EXTERNAL_LSA_TYPE:
                     if (asExternalLSA != nullptr) {
                         unsigned int asExternalLSACount = updatePacket->getAsExternalLSAsArraySize();
 
                         updatePacket->setAsExternalLSAsArraySize(asExternalLSACount + 1);
                         updatePacket->setAsExternalLSAs(asExternalLSACount, *asExternalLSA);
 
                         unsigned short lsAge = updatePacket->getAsExternalLSAs(asExternalLSACount).getHeader().getLsAge();
                         if (lsAge < MAX_AGE - parentInterface->getTransmissionDelay()) {
                             updatePacket->getAsExternalLSAs(asExternalLSACount).getHeader().setLsAge(lsAge + parentInterface->getTransmissionDelay());
                         }
                         else {
                             updatePacket->getAsExternalLSAs(asExternalLSACount).getHeader().setLsAge(MAX_AGE);
                         }
                     }
                     break;
 
                 default:
                     break;
             }
         }
 
         it++;
     }
 
     updatePacket->setByteLength(packetLength - IP_MAX_HEADER_BYTES);
 
     MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
     int ttl = (parentInterface->getType() == Interface::VIRTUAL) ? VIRTUAL_LINK_TTL : 1;
     messageHandler->sendPacket(updatePacket, neighborIPAddress, parentInterface->getIfIndex(), ttl);
 }

void inet::ospf::Neighbor::sendDatabaseDescriptionPacket ( bool init = false )

Referenced by inet::ospf::DatabaseDescriptionHandler::processDDPacket(), inet::ospf::NeighborStateExchangeStart::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateInit::processEvent(), inet::ospf::NeighborStateFull::processEvent(), inet::ospf::NeighborStateTwoWay::processEvent(), inet::ospf::NeighborStateExchange::processEvent(), and inet::ospf::DatabaseDescriptionHandler::processPacket().

 {
     OSPFDatabaseDescriptionPacket *ddPacket = new OSPFDatabaseDescriptionPacket();
 
     ddPacket->setType(DATABASE_DESCRIPTION_PACKET);
     ddPacket->setRouterID(IPv4Address(parentInterface->getArea()->getRouter()->getRouterID()));
     ddPacket->setAreaID(IPv4Address(parentInterface->getArea()->getAreaID()));
     ddPacket->setAuthenticationType(parentInterface->getAuthenticationType());
     AuthenticationKeyType authKey = parentInterface->getAuthenticationKey();
     for (int i = 0; i < 8; i++) {
         ddPacket->setAuthentication(i, authKey.bytes[i]);
     }
 
     if (parentInterface->getType() != Interface::VIRTUAL) {
         ddPacket->setInterfaceMTU(parentInterface->getMTU());
     }
     else {
         ddPacket->setInterfaceMTU(0);
     }
 
     OSPFOptions options;
     memset(&options, 0, sizeof(OSPFOptions));
     options.E_ExternalRoutingCapability = parentInterface->getArea()->getExternalRoutingCapability();
     ddPacket->setOptions(options);
 
     ddPacket->setDdSequenceNumber(ddSequenceNumber);
 
     long maxPacketSize = (((IP_MAX_HEADER_BYTES + OSPF_HEADER_LENGTH + OSPF_DD_HEADER_LENGTH + OSPF_LSA_HEADER_LENGTH) > parentInterface->getMTU()) ?
                           IPV4_DATAGRAM_LENGTH :
                           parentInterface->getMTU()) - IP_MAX_HEADER_BYTES;
     long packetSize = OSPF_HEADER_LENGTH + OSPF_DD_HEADER_LENGTH;
 
     if (init || databaseSummaryList.empty()) {
         ddPacket->setLsaHeadersArraySize(0);
     }
     else {
         // delete included LSAs from summary list
         // (they are still in lastTransmittedDDPacket)
         while ((!databaseSummaryList.empty()) && (packetSize <= (maxPacketSize - OSPF_LSA_HEADER_LENGTH))) {
             unsigned long headerCount = ddPacket->getLsaHeadersArraySize();
             OSPFLSAHeader *lsaHeader = *(databaseSummaryList.begin());
             ddPacket->setLsaHeadersArraySize(headerCount + 1);
             ddPacket->setLsaHeaders(headerCount, *lsaHeader);
             delete lsaHeader;
             databaseSummaryList.pop_front();
             packetSize += OSPF_LSA_HEADER_LENGTH;
         }
     }
 
     OSPFDDOptions ddOptions;
     memset(&ddOptions, 0, sizeof(OSPFDDOptions));
     if (init) {
         ddOptions.I_Init = true;
         ddOptions.M_More = true;
         ddOptions.MS_MasterSlave = true;
     }
     else {
         ddOptions.I_Init = false;
         ddOptions.M_More = (databaseSummaryList.empty()) ? false : true;
         ddOptions.MS_MasterSlave = (databaseExchangeRelationship == Neighbor::MASTER) ? true : false;
     }
     ddPacket->setDdOptions(ddOptions);
 
     ddPacket->setByteLength(packetSize);
 
     MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
     int ttl = (parentInterface->getType() == Interface::VIRTUAL) ? VIRTUAL_LINK_TTL : 1;
 
     if (lastTransmittedDDPacket != nullptr)
         delete lastTransmittedDDPacket;
     lastTransmittedDDPacket = ddPacket->dup();
 
     if (parentInterface->getType() == Interface::POINTTOPOINT) {
         messageHandler->sendPacket(ddPacket, IPv4Address::ALL_OSPF_ROUTERS_MCAST, parentInterface->getIfIndex(), ttl);
     }
     else {
         messageHandler->sendPacket(ddPacket, neighborIPAddress, parentInterface->getIfIndex(), ttl);
     }
 }

void inet::ospf::Neighbor::sendLinkStateRequestPacket ( )

Referenced by inet::ospf::NeighborStateExchange::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), and inet::ospf::DatabaseDescriptionHandler::processPacket().

 {
     OSPFLinkStateRequestPacket *requestPacket = new OSPFLinkStateRequestPacket();
 
     requestPacket->setType(LINKSTATE_REQUEST_PACKET);
     requestPacket->setRouterID(IPv4Address(parentInterface->getArea()->getRouter()->getRouterID()));
     requestPacket->setAreaID(IPv4Address(parentInterface->getArea()->getAreaID()));
     requestPacket->setAuthenticationType(parentInterface->getAuthenticationType());
     AuthenticationKeyType authKey = parentInterface->getAuthenticationKey();
     for (int i = 0; i < 8; i++) {
         requestPacket->setAuthentication(i, authKey.bytes[i]);
     }
 
     long maxPacketSize = (((IP_MAX_HEADER_BYTES + OSPF_HEADER_LENGTH + OSPF_REQUEST_LENGTH) > parentInterface->getMTU()) ?
                           IPV4_DATAGRAM_LENGTH :
                           parentInterface->getMTU()) - IP_MAX_HEADER_BYTES;
     long packetSize = OSPF_HEADER_LENGTH;
 
     if (linkStateRequestList.empty()) {
         requestPacket->setRequestsArraySize(0);
     }
     else {
         auto it = linkStateRequestList.begin();
 
         while ((it != linkStateRequestList.end()) && (packetSize <= (maxPacketSize - OSPF_REQUEST_LENGTH))) {
             unsigned long requestCount = requestPacket->getRequestsArraySize();
             OSPFLSAHeader *requestHeader = (*it);
             LSARequest request;
 
             request.lsType = requestHeader->getLsType();
             request.linkStateID = requestHeader->getLinkStateID();
             request.advertisingRouter = requestHeader->getAdvertisingRouter();
 
             requestPacket->setRequestsArraySize(requestCount + 1);
             requestPacket->setRequests(requestCount, request);
 
             packetSize += OSPF_REQUEST_LENGTH;
             it++;
         }
     }
 
     requestPacket->setByteLength(packetSize);
 
     MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
     int ttl = (parentInterface->getType() == Interface::VIRTUAL) ? VIRTUAL_LINK_TTL : 1;
     if (parentInterface->getType() == Interface::POINTTOPOINT) {
         messageHandler->sendPacket(requestPacket, IPv4Address::ALL_OSPF_ROUTERS_MCAST, parentInterface->getIfIndex(), ttl);
     }
     else {
         messageHandler->sendPacket(requestPacket, neighborIPAddress, parentInterface->getIfIndex(), ttl);
     }
 }

void inet::ospf::Neighbor::setAddress ( IPv4Address address )

inline

Referenced by inet::ospf::Area::calculateShortestPathTree(), inet::ospf::OSPFConfigReader::loadInterfaceParameters(), and inet::ospf::HelloHandler::processPacket().

164 { neighborIPAddress = address; }

inet::ospf::Neighbor::neighborIPAddress

IPv4Address neighborIPAddress

Definition: OSPFNeighbor.h:107

void inet::ospf::Neighbor::setBackupDesignatedRouter ( DesignatedRouterID routerID )

inline

Referenced by inet::ospf::HelloHandler::processPacket().

168 { neighborsBackupDesignatedRouter = routerID; }

inet::ospf::Neighbor::neighborsBackupDesignatedRouter

DesignatedRouterID neighborsBackupDesignatedRouter

Definition: OSPFNeighbor.h:110

void inet::ospf::Neighbor::setDatabaseExchangeRelationship ( DatabaseExchangeRelationshipType relation )

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processPacket().

179 { databaseExchangeRelationship = relation; }

inet::ospf::Neighbor::databaseExchangeRelationship

DatabaseExchangeRelationshipType databaseExchangeRelationship

Definition: OSPFNeighbor.h:101

void inet::ospf::Neighbor::setDDSequenceNumber ( unsigned long sequenceNumber )

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processDDPacket(), and inet::ospf::DatabaseDescriptionHandler::processPacket().

172 { ddSequenceNumber = sequenceNumber; }

inet::ospf::Neighbor::ddSequenceNumber

unsigned long ddSequenceNumber

Definition: OSPFNeighbor.h:103

void inet::ospf::Neighbor::setDesignatedRouter ( DesignatedRouterID routerID )

inline

Referenced by inet::ospf::HelloHandler::processPacket().

166 { neighborsDesignatedRouter = routerID; }

inet::ospf::Neighbor::neighborsDesignatedRouter

DesignatedRouterID neighborsDesignatedRouter

Definition: OSPFNeighbor.h:109

void inet::ospf::Neighbor::setInterface ( Interface * intf )

inline

Referenced by inet::ospf::Interface::addNeighbor().

182 { parentInterface = intf; }

inet::ospf::Neighbor::parentInterface

Interface * parentInterface

Definition: OSPFNeighbor.h:119

void inet::ospf::Neighbor::setLastReceivedDDPacket ( DDPacketID packetID )

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processPacket().

176 { lastReceivedDDPacket = packetID; }

inet::ospf::Neighbor::lastReceivedDDPacket

DDPacketID lastReceivedDDPacket

Definition: OSPFNeighbor.h:104

void inet::ospf::Neighbor::setNeighborID ( RouterID id )

inline

Referenced by inet::ospf::OSPFConfigReader::loadVirtualLink(), and inet::ospf::HelloHandler::processPacket().

160 { neighborID = id; }

inet::ospf::Neighbor::neighborID

RouterID neighborID

Definition: OSPFNeighbor.h:105

id

uint16_t id

Definition: TCP_NSC.cc:85

void inet::ospf::Neighbor::setOptions ( OSPFOptions options )

inline

Referenced by inet::ospf::DatabaseDescriptionHandler::processPacket().

174 { neighborOptions = options; }

inet::ospf::Neighbor::neighborOptions

OSPFOptions neighborOptions

Definition: OSPFNeighbor.h:108

void inet::ospf::Neighbor::setPriority ( unsigned char priority )

inline

Referenced by inet::ospf::OSPFConfigReader::loadInterfaceParameters(), and inet::ospf::HelloHandler::processPacket().

162 { neighborPriority = priority; }

inet::ospf::Neighbor::neighborPriority

unsigned char neighborPriority

Definition: OSPFNeighbor.h:106

void inet::ospf::Neighbor::setRouterDeadInterval ( short interval )

inline

Referenced by inet::ospf::HelloHandler::processPacket().

170 { neighborsRouterDeadInterval = interval; }

inet::ospf::Neighbor::neighborsRouterDeadInterval

short neighborsRouterDeadInterval

Definition: OSPFNeighbor.h:112

void inet::ospf::Neighbor::setupDesignatedRouters ( bool setUp )

inline

Referenced by inet::ospf::HelloHandler::processPacket().

194 { designatedRoutersSetUp = setUp; }

inet::ospf::Neighbor::designatedRoutersSetUp

bool designatedRoutersSetUp

Definition: OSPFNeighbor.h:111

void inet::ospf::Neighbor::startRequestRetransmissionTimer ( )

Referenced by inet::ospf::NeighborStateExchange::processEvent(), inet::ospf::NeighborStateLoading::processEvent(), and inet::ospf::DatabaseDescriptionHandler::processPacket().

 {
     MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
     messageHandler->startTimer(requestRetransmissionTimer, parentInterface->getRetransmissionInterval());
     requestRetransmissionTimerActive = true;
 }

void inet::ospf::Neighbor::startUpdateRetransmissionTimer ( )

Referenced by inet::ospf::Interface::floodLSA(), inet::ospf::NeighborStateLoading::processEvent(), inet::ospf::NeighborStateFull::processEvent(), and inet::ospf::NeighborStateExchange::processEvent().

 {
     MessageHandler *messageHandler = parentInterface->getArea()->getRouter()->getMessageHandler();
     messageHandler->startTimer(updateRetransmissionTimer, parentInterface->getRetransmissionInterval());
     updateRetransmissionTimerActive = true;
 }