src/nlsr_npt.cpp

#include <list>
#include <utility>
#include <algorithm>

#include "nlsr_npt.hpp"
#include "nlsr_npte.hpp"
#include "nlsr.hpp"

namespace nlsr
{

    using namespace std;

    static bool
    npteCompare(Npte& npte, string& name)
    {
        return npte.getNamePrefix()==name;
    }

// Following two methods will update FIB with response to change in NPT

    void
    Npt::addNpte(string name, RoutingTableEntry& rte, Nlsr& pnlsr)
    {
        std::list<Npte >::iterator it = std::find_if( npteList.begin(),
                                        npteList.end(), bind(&npteCompare, _1, name));

        if ( it == npteList.end() )
        {
            Npte newEntry(	name);
            newEntry.addRoutingTableEntry(rte);
            newEntry.generateNhlfromRteList();
            npteList.push_back(newEntry);
            // update FIB here with nhl list newEntry.getNhl()
            pnlsr.getFib().updateFib(pnlsr, name,newEntry.getNhl(),
                                     pnlsr.getConfParameter().getMaxFacesPerPrefix());
        }
        else
        {
            (*it).addRoutingTableEntry(rte);
            (*it).generateNhlfromRteList();
            // update FIB here with nhl list from (*it).getNhl()
            pnlsr.getFib().updateFib(pnlsr, name,(*it).getNhl() ,
                                     pnlsr.getConfParameter().getMaxFacesPerPrefix());
        }
    }

    void
    Npt::removeNpte(string name, RoutingTableEntry& rte, Nlsr& pnlsr)
    {
        std::list<Npte >::iterator it = std::find_if( npteList.begin(),
                                        npteList.end(), bind(&npteCompare, _1, name));
        if ( it != npteList.end() )
        {
            string destRouter=rte.getDestination();

            (*it).removeRoutingTableEntry(rte);
            if ( ((*it).getRteListSize() == 0 ) &&
                    (!pnlsr.getLsdb().doesLsaExist(destRouter+"/1",1) ) &&
                    (!pnlsr.getLsdb().doesLsaExist(destRouter+"/2",2) ) &&
                    (!pnlsr.getLsdb().doesLsaExist(destRouter+"/3",3) )   )
            {
                npteList.erase(it); // remove entry from NPT
                // remove FIB entry with this name
                pnlsr.getFib().removeFromFib(pnlsr,name);

            }
            else
            {
                (*it).generateNhlfromRteList();
                // update FIB entry with new NHL
                pnlsr.getFib().updateFib(pnlsr, name,(*it).getNhl(),
                                         pnlsr.getConfParameter().getMaxFacesPerPrefix());
            }
        }
    }


    void
    Npt::addNpte(string name, string destRouter, Nlsr& pnlsr)
    {
        std::pair<RoutingTableEntry& , bool> rteCheck=
            pnlsr.getRoutingTable().findRoutingTableEntry(destRouter);
        if(rteCheck.second)
        {
            addNpte(name,rteCheck.first,pnlsr);
        }
        else
        {
            RoutingTableEntry rte(destRouter);
            addNpte(name, rte,pnlsr);
        }

    }

    void
    Npt::removeNpte(string name, string destRouter, Nlsr& pnlsr)
    {
        std::pair<RoutingTableEntry& , bool> rteCheck=
            pnlsr.getRoutingTable().findRoutingTableEntry(destRouter);
        if(rteCheck.second)
        {
            removeNpte(name,rteCheck.first,pnlsr);
        }
        else
        {
            RoutingTableEntry rte(destRouter);
            removeNpte(name, rte,pnlsr);
        }
    }

    void
    Npt::updateNptWithNewRoute(Nlsr& pnlsr)
    {
        for(std::list<Npte >::iterator it=npteList.begin(); it!=npteList.end(); ++it)
        {
            std::list<RoutingTableEntry> rteList=(*it).getRteList();
            for(std::list<RoutingTableEntry >::iterator rteit=rteList.begin();
                    rteit !=rteList.end(); ++rteit)
            {
                std::pair<RoutingTableEntry& , bool> rteCheck=
                    pnlsr.getRoutingTable().findRoutingTableEntry((*rteit).getDestination());
                if(rteCheck.second)
                {
                    addNpte((*it).getNamePrefix(),rteCheck.first,pnlsr);
                }
                else
                {
                    RoutingTableEntry rte((*rteit).getDestination());
                    addNpte((*it).getNamePrefix(), rte,pnlsr);
                }
            }
        }
    }

    void
    Npt::printNpt()
    {
        cout<<"----------------NPT----------------------"<<endl;
        for(std::list<Npte >::iterator it=npteList.begin(); it!=npteList.end(); ++it)
        {
            cout <<(*it)<<endl;
        }
    }

}