inet::ospfv2::LinkStateRequestHandler Class Reference

#include <LinkStateRequestHandler.h>

Inheritance diagram for inet::ospfv2::LinkStateRequestHandler:

Public Member Functions
	LinkStateRequestHandler (Router *containingRouter)
void	processPacket (Packet *packet, Ospfv2Interface *intf, Neighbor *neighbor) override
Public Member Functions inherited from inet::ospfv2::IMessageHandler
	IMessageHandler (Router *containingRouter)
virtual	~IMessageHandler ()

Additional Inherited Members
Protected Attributes inherited from inet::ospfv2::IMessageHandler
Router *	router

Constructor & Destructor Documentation

LinkStateRequestHandler()

inet::ospfv2::LinkStateRequestHandler::LinkStateRequestHandler

(

Router *

containingRouter

)

                                                                         :
    IMessageHandler(containingRouter)
{
}

Member Function Documentation

processPacket()

void inet::ospfv2::LinkStateRequestHandler::processPacket ( Packet *  packet, Ospfv2Interface *  intf, Neighbor *  neighbor  )

overridevirtual

Implements inet::ospfv2::IMessageHandler.

{
    router->getMessageHandler()->printEvent("Link State Request packet received", intf, neighbor);
 
    Neighbor::NeighborStateType neighborState = neighbor->getState();
 
    if ((neighborState == Neighbor::EXCHANGE_STATE) ||
        (neighborState == Neighbor::LOADING_STATE) ||
        (neighborState == Neighbor::FULL_STATE))
    {
        const auto& lsRequestPacket = packet->peekAtFront<Ospfv2LinkStateRequestPacket>();
 
        unsigned long requestCount = lsRequestPacket->getRequestsArraySize();
        bool error = false;
        std::vector<Ospfv2Lsa *> lsas;
 
        EV_INFO << "  Processing packet contents:\n";
 
        for (unsigned long i = 0; i < requestCount; i++) {
            const auto& request = lsRequestPacket->getRequests(i);
            LsaKeyType lsaKey;
 
            EV_INFO << "    LsaRequest: type=" << request.lsType
                    << ", LSID=" << request.linkStateID
                    << ", advertisingRouter=" << request.advertisingRouter
                    << "\n";
 
            lsaKey.linkStateID = request.linkStateID;
            lsaKey.advertisingRouter = request.advertisingRouter;
 
            Ospfv2Lsa *lsaInDatabase = router->findLSA(static_cast<Ospfv2LsaType>(request.lsType), lsaKey, intf->getArea()->getAreaID());
 
            if (lsaInDatabase != nullptr) {
                lsas.push_back(lsaInDatabase);
            }
            else {
                error = true;
                neighbor->processEvent(Neighbor::BAD_LINK_STATE_REQUEST);
                break;
            }
        }
 
        if (!error) {
            int updatesCount = lsas.size();
            int ttl = (intf->getType() == Ospfv2Interface::VIRTUAL) ? VIRTUAL_LINK_TTL : 1;
            MessageHandler *messageHandler = router->getMessageHandler();
 
            for (int j = 0; j < updatesCount; j++) {
                Packet *updatePacket = intf->createUpdatePacket(lsas[j]);
                if (updatePacket != nullptr) {
                    if (intf->getType() == Ospfv2Interface::BROADCAST) {
                        if ((intf->getState() == Ospfv2Interface::DESIGNATED_ROUTER_STATE) ||
                            (intf->getState() == Ospfv2Interface::BACKUP_STATE) ||
                            (intf->getDesignatedRouter() == NULL_DESIGNATEDROUTERID))
                        {
                            messageHandler->sendPacket(updatePacket, Ipv4Address::ALL_OSPF_ROUTERS_MCAST, intf, ttl);
                        }
                        else {
                            messageHandler->sendPacket(updatePacket, Ipv4Address::ALL_OSPF_DESIGNATED_ROUTERS_MCAST, intf, ttl);
                        }
                    }
                    else {
                        if (intf->getType() == Ospfv2Interface::POINTTOPOINT) {
                            messageHandler->sendPacket(updatePacket, Ipv4Address::ALL_OSPF_ROUTERS_MCAST, intf, ttl);
                        }
                        else {
                            messageHandler->sendPacket(updatePacket, neighbor->getAddress(), intf, ttl);
                        }
                    }
                }
            }
            // These update packets should not be placed on retransmission lists
        }
    }
}

Referenced by inet::ospfv2::MessageHandler::processPacket().

---

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

• LinkStateRequestHandler.h
• LinkStateRequestHandler.cc