package org.freertr.rtr; import java.util.ArrayList; import java.util.List; import org.freertr.addr.addrIP; import org.freertr.addr.addrIPv4; import org.freertr.addr.addrMac; import org.freertr.addr.addrPrefix; import org.freertr.cfg.cfgAceslst; import org.freertr.cfg.cfgAll; import org.freertr.cfg.cfgIfc; import org.freertr.cfg.cfgInit; import org.freertr.cfg.cfgPlymp; import org.freertr.cfg.cfgPrfxlst; import org.freertr.cfg.cfgProxy; import org.freertr.cfg.cfgRoump; import org.freertr.cfg.cfgRouplc; import org.freertr.cfg.cfgRtr; import org.freertr.cfg.cfgVrf; import org.freertr.clnt.clntWhois; import org.freertr.ifc.ifcDot1ah; import org.freertr.ip.ipCor4; import org.freertr.ip.ipCor6; import org.freertr.ip.ipFwd; import org.freertr.ip.ipFwdIface; import org.freertr.ip.ipFwdTab; import org.freertr.ip.ipRtr; import org.freertr.pack.packHolder; import org.freertr.pipe.pipeLine; import org.freertr.pipe.pipeSide; import org.freertr.prt.prtGenConn; import org.freertr.prt.prtServS; import org.freertr.prt.prtTcp; import org.freertr.tab.tabGen; import org.freertr.tab.tabIndex; import org.freertr.tab.tabIntMatcher; import org.freertr.tab.tabLabel; import org.freertr.tab.tabLabelBier; import org.freertr.tab.tabLabelBierN; import org.freertr.tab.tabLabelEntry; import org.freertr.tab.tabListing; import org.freertr.tab.tabPlcmapN; import org.freertr.tab.tabPrfxlstN; import org.freertr.tab.tabQos; import org.freertr.tab.tabRoute; import org.freertr.tab.tabRouteAttr; import org.freertr.tab.tabRouteEntry; import org.freertr.tab.tabRouteUtil; import org.freertr.tab.tabRtrmapN; import org.freertr.tab.tabRtrplcN; import org.freertr.user.userFormat; import org.freertr.user.userHelping; import org.freertr.util.bits; import org.freertr.util.cmds; import org.freertr.util.debugger; import org.freertr.util.logFil; import org.freertr.util.logger; import org.freertr.util.notifier; import org.freertr.spf.spfCalc; import org.freertr.spf.spfLnkst; import org.freertr.tab.tabRoautNtry; import org.freertr.util.counter; import org.freertr.util.syncInt; /** * border gateway protocol (rfc4271) version 4 * * @author matecsaba */ public class rtrBgp extends ipRtr implements prtServS, Runnable { /** * port to use */ public final static int port = 179; /** * local as number */ public int localAs; /** * address families */ public long addrFams; /** * router id */ public addrIPv4 routerID; /** * safe ebgp */ public boolean safeEbgp; /** * segment routing index */ public int segrouIdx = 0; /** * segment routing maximum */ public int segrouMax = 0; /** * segment routing base */ public int segrouBase = 0; /** * segment routing labels */ protected tabLabelEntry[] segrouLab; /** * bier index */ public int bierIdx = 0; /** * bier subdomain */ public int bierSub = 0; /** * bier length */ public int bierLen = 0; /** * bier maximum */ public int bierMax = 0; /** * bier labels */ protected tabLabelEntry[] bierLab; /** * scan time interval */ public int scanTime; /** * initial delay */ public int scanDelay; /** * recursion depth */ public int recursion; /** * default information originate */ public boolean defRou; /** * restart time */ public int restartTime; /** * long lived restart time */ public int llRestartTime; /** * external distance */ public int distantExt; /** * internal distance */ public int distantInt; /** * local distance */ public int distantLoc; /** * update groups */ public List groups; /** * group minimum */ public int groupMin; /** * group maximum */ public int groupMax; /** * listen configurations */ public tabGen lstnTmp = new tabGen(); /** * list of dynamic neighbors */ protected tabGen lstnNei; /** * route type */ protected final tabRouteAttr.routeType rouTyp; /** * unicast afi */ protected final int afiUni; /** * labeled unicast afi */ protected final int afiLab; /** * classful transport plane afi */ protected final int afiCtp; /** * color aware routing afi */ protected final int afiCar; /** * multicast afi */ protected final int afiMlt; /** * other labeled unicast afi */ protected final int afiOlab; /** * other classful transport plane afi */ protected final int afiOctp; /** * other color aware routing afi */ protected final int afiOcar; /** * other unicast afi */ protected final int afiOuni; /** * other multicast afi */ protected final int afiOmlt; /** * other flowspec afi */ protected final int afiOflw; /** * other srte afi */ protected final int afiOsrt; /** * flow specification afi */ protected final int afiFlw; /** * unicast vpn afi */ protected final int afiVpnU; /** * multicast vpn afi */ protected final int afiVpnM; /** * flowspec vpn afi */ protected final int afiVpnF; /** * other unicast vpn afi */ protected final int afiVpoU; /** * other multicast vpn afi */ protected final int afiVpoM; /** * other flowspec vpn afi */ protected final int afiVpoF; /** * vpls afi */ protected final int afiVpls; /** * mspw afi */ protected final int afiMspw; /** * evpn afi */ protected final int afiEvpn; /** * mdt afi */ protected final int afiMdt; /** * nsh afi */ protected final int afiNsh; /** * rpd afi */ protected final int afiRpd; /** * spf afi */ protected final int afiSpf; /** * rtfilter afi */ protected final int afiRtf; /** * srte afi */ protected final int afiSrte; /** * linkstate afi */ protected final int afiLnks; /** * mvpn afi */ protected final int afiMvpn; /** * other mvpn afi */ protected final int afiMvpo; /** * mtree afi */ protected final int afiMtre; /** * other mtree afi */ protected final int afiMtro; /** * router number */ protected final int rtrNum; /** * other changes trigger full computation */ protected boolean otherTrigger; /** * have route reflector client */ protected boolean have2reflect; /** * next hop tracking route map */ protected tabListing nhtRoumap; /** * next hop tracking route policy */ protected tabListing nhtRouplc; /** * next hop tracking policy map */ protected tabListing nhtPfxlst; /** * flow specification */ protected tabListing flowSpec; /** * link states */ protected tabGen linkStates; /** * install flow specification */ protected boolean flowInst; /** * rpki type configured */ protected tabRouteAttr.routeType rpkiT; /** * rpki number configured */ protected int rpkiN; /** * rpki process */ protected rtrRpki rpkiR; /** * rpki table */ protected tabGen rpkiA = new tabGen(); /** * other rpki table */ protected tabGen rpkiO = new tabGen(); /** * the computed other unicast routes */ public tabRoute computedOuni = new tabRoute("rx"); /** * the computed other multicast routes */ public tabRoute computedOmlt = new tabRoute("rx"); /** * the computed other flowspec routes */ public tabRoute computedOflw = new tabRoute("rx"); /** * the computed other srte routes */ public tabRoute computedOsrt = new tabRoute("rx"); /** * the computed vpnuni routes */ public tabRoute computedVpnU = new tabRoute("rx"); /** * the computed vpnmlt routes */ public tabRoute computedVpnM = new tabRoute("rx"); /** * the computed vpnflw routes */ public tabRoute computedVpnF = new tabRoute("rx"); /** * the computed other vpnuni routes */ public tabRoute computedVpoU = new tabRoute("rx"); /** * the computed other vpnmlt routes */ public tabRoute computedVpoM = new tabRoute("rx"); /** * the computed other vpnflw routes */ public tabRoute computedVpoF = new tabRoute("rx"); /** * the computed vpls routes */ public tabRoute computedVpls = new tabRoute("rx"); /** * the computed mspw routes */ public tabRoute computedMspw = new tabRoute("rx"); /** * the computed evpn routes */ public tabRoute computedEvpn = new tabRoute("rx"); /** * the computed mdt routes */ public tabRoute computedMdt = new tabRoute("rx"); /** * the computed nsh routes */ public tabRoute computedNsh = new tabRoute("rx"); /** * the computed rpd routes */ public tabRoute computedRpd = new tabRoute("rx"); /** * the computed spf routes */ public tabRoute computedSpf = new tabRoute("rx"); /** * the computed rtfilter routes */ public tabRoute computedRtf = new tabRoute("rx"); /** * the computed srte routes */ public tabRoute computedSrte = new tabRoute("rx"); /** * the computed linkstate routes */ public tabRoute computedLnks = new tabRoute("rx"); /** * the computed mvpn routes */ public tabRoute computedMvpn = new tabRoute("rx"); /** * the computed other mvpn routes */ public tabRoute computedMvpo = new tabRoute("rx"); /** * the computed mtree routes */ public tabRoute computedMtre = new tabRoute("rx"); /** * the computed other mtree routes */ public tabRoute computedMtro = new tabRoute("rx"); /** * the changed unicast routes */ public final tabRoute changedUni = new tabRoute("rx"); /** * the changed multicast routes */ public final tabRoute changedMlt = new tabRoute("rx"); /** * the changed other unicast routes */ public final tabRoute changedOuni = new tabRoute("rx"); /** * the changed other multicast routes */ public final tabRoute changedOmlt = new tabRoute("rx"); /** * the changed other flowspec routes */ public final tabRoute changedOflw = new tabRoute("rx"); /** * the changed other srte routes */ public final tabRoute changedOsrt = new tabRoute("rx"); /** * the changed flowspec routes */ public final tabRoute changedFlw = new tabRoute("rx"); /** * the changed vpnuni routes */ public final tabRoute changedVpnU = new tabRoute("rx"); /** * the changed vpnmlt routes */ public final tabRoute changedVpnM = new tabRoute("rx"); /** * the changed vpnflw routes */ public final tabRoute changedVpnF = new tabRoute("rx"); /** * the changed other vpnuni routes */ public final tabRoute changedVpoU = new tabRoute("rx"); /** * the changed other vpnmlt routes */ public final tabRoute changedVpoM = new tabRoute("rx"); /** * the changed other vpnflw routes */ public final tabRoute changedVpoF = new tabRoute("rx"); /** * the changed vpls routes */ public final tabRoute changedVpls = new tabRoute("rx"); /** * the changed mspw routes */ public final tabRoute changedMspw = new tabRoute("rx"); /** * the changed evpn routes */ public final tabRoute changedEvpn = new tabRoute("rx"); /** * the changed mdt routes */ public final tabRoute changedMdt = new tabRoute("rx"); /** * the changed nsh routes */ public final tabRoute changedNsh = new tabRoute("rx"); /** * the changed rpd routes */ public final tabRoute changedRpd = new tabRoute("rx"); /** * the changed spf routes */ public final tabRoute changedSpf = new tabRoute("rx"); /** * the changed rtfilter routes */ public final tabRoute changedRtf = new tabRoute("rx"); /** * the changed srte routes */ public final tabRoute changedSrte = new tabRoute("rx"); /** * the changed linkstate routes */ public final tabRoute changedLnks = new tabRoute("rx"); /** * the changed mvpn routes */ public final tabRoute changedMvpn = new tabRoute("rx"); /** * the changed other mvpn routes */ public final tabRoute changedMvpo = new tabRoute("rx"); /** * the changed mvpn routes */ public final tabRoute changedMtre = new tabRoute("rx"); /** * the changed other mvpn routes */ public final tabRoute changedMtro = new tabRoute("rx"); /** * the newly computed unicast routes */ public tabRoute newlyUni = new tabRoute("bst"); /** * the newly computed multicast routes */ public tabRoute newlyMlt = new tabRoute("bst"); /** * the newly computed other unicast routes */ public tabRoute newlyOuni = new tabRoute("bst"); /** * the newly computed other multicast routes */ public tabRoute newlyOmlt = new tabRoute("bst"); /** * the newly computed other flowspec routes */ public tabRoute newlyOflw = new tabRoute("bst"); /** * the newly computed other srte routes */ public tabRoute newlyOsrt = new tabRoute("bst"); /** * the newly computed flowspec routes */ public tabRoute newlyFlw = new tabRoute("bst"); /** * the newly computed vpnuni routes */ public tabRoute newlyVpnU = new tabRoute("bst"); /** * the newly computed vpnmlt routes */ public tabRoute newlyVpnM = new tabRoute("bst"); /** * the newly computed vpnflw routes */ public tabRoute newlyVpnF = new tabRoute("bst"); /** * the newly computed other vpnuni routes */ public tabRoute newlyVpoU = new tabRoute("bst"); /** * the newly computed other vpnmlt routes */ public tabRoute newlyVpoM = new tabRoute("bst"); /** * the newly computed other vpnflw routes */ public tabRoute newlyVpoF = new tabRoute("bst"); /** * the newly computed vpls routes */ public tabRoute newlyVpls = new tabRoute("bst"); /** * the newly computed mspw routes */ public tabRoute newlyMspw = new tabRoute("bst"); /** * the newly computed evpn routes */ public tabRoute newlyEvpn = new tabRoute("bst"); /** * the newly computed mdt routes */ public tabRoute newlyMdt = new tabRoute("bst"); /** * the newly computed nsh routes */ public tabRoute newlyNsh = new tabRoute("bst"); /** * the newly computed rpd routes */ public tabRoute newlyRpd = new tabRoute("bst"); /** * the newly computed spf routes */ public tabRoute newlySpf = new tabRoute("bst"); /** * the newly computed rtfilter routes */ public tabRoute newlyRtf = new tabRoute("bst"); /** * the newly computed srte routes */ public tabRoute newlySrte = new tabRoute("bst"); /** * the newly computed lnkst routes */ public tabRoute newlyLnks = new tabRoute("bst"); /** * the newly computed mvpn routes */ public tabRoute newlyMvpn = new tabRoute("bst"); /** * the newly computed other mvpn routes */ public tabRoute newlyMvpo = new tabRoute("bst"); /** * the newly computed mtree routes */ public tabRoute newlyMtre = new tabRoute("bst"); /** * the newly computed other mtree routes */ public tabRoute newlyMtro = new tabRoute("bst"); /** * the originated other unicast routes */ public tabRoute origntedOuni = new tabRoute("tx"); /** * the originated other multicast routes */ public tabRoute origntedOmlt = new tabRoute("tx"); /** * the originated other flowspec routes */ public tabRoute origntedOflw = new tabRoute("tx"); /** * the originated other srte routes */ public tabRoute origntedOsrt = new tabRoute("tx"); /** * the originated flowspec routes */ public tabRoute origntedFlw = new tabRoute("tx"); /** * the originated vpnuni routes */ public tabRoute origntedVpnU = new tabRoute("tx"); /** * the originated vpnmlt routes */ public tabRoute origntedVpnM = new tabRoute("tx"); /** * the originated vpnflw routes */ public tabRoute origntedVpnF = new tabRoute("tx"); /** * the originated other vpnuni routes */ public tabRoute origntedVpoU = new tabRoute("tx"); /** * the originated other vpnmlt routes */ public tabRoute origntedVpoM = new tabRoute("tx"); /** * the originated other vpnflw routes */ public tabRoute origntedVpoF = new tabRoute("tx"); /** * the originated vpls routes */ public tabRoute origntedVpls = new tabRoute("tx"); /** * the originated mspw routes */ public tabRoute origntedMspw = new tabRoute("tx"); /** * the originated evpn routes */ public tabRoute origntedEvpn = new tabRoute("tx"); /** * the originated mdt routes */ public tabRoute origntedMdt = new tabRoute("tx"); /** * the originated nsh routes */ public tabRoute origntedNsh = new tabRoute("tx"); /** * the originated rpd routes */ public tabRoute origntedRpd = new tabRoute("tx"); /** * the originated spf routes */ public tabRoute origntedSpf = new tabRoute("tx"); /** * the originated rtfilter routes */ public tabRoute origntedRtf = new tabRoute("tx"); /** * the originated srte routes */ public tabRoute origntedSrte = new tabRoute("tx"); /** * the originated linkstate routes */ public tabRoute origntedLnks = new tabRoute("tx"); /** * the originated mvpn routes */ public tabRoute origntedMvpn = new tabRoute("tx"); /** * the originated other mvpn routes */ public tabRoute origntedMvpo = new tabRoute("tx"); /** * the originated mtree routes */ public tabRoute origntedMtre = new tabRoute("tx"); /** * the originated other mtree routes */ public tabRoute origntedMtro = new tabRoute("tx"); /** * incremental limit */ public int incrLimit; /** * conquer bestpath */ public boolean conquer; /** * flap statistics */ public tabGen flaps; /** * list of monitors */ protected tabGen mons; /** * list of dumps */ protected tabGen dmps; /** * list of neighbors */ protected tabGen neighs; /** * list of templates */ protected tabGen temps; /** * other afi router */ protected rtrBgpOther other; /** * spf afi router */ protected rtrBgpSpf lspf; /** * list of vrfs */ protected tabGen vrfs; /** * list of other vrfs */ protected tabGen ovrfs; /** * list of colors */ protected tabGen clrs; /** * list of other colors */ protected tabGen oclrs; /** * list of vpls */ protected tabGen vpls; /** * list of evpns */ protected tabGen evpn; /** * evpn receiver */ protected rtrBgpEvpnPbb evpnRcv; /** * evpn unicast label */ protected tabLabelEntry evpnUni; /** * evpn multicast label */ protected tabLabelEntry evpnMul; /** * accept statistics */ public final counter accptStat = new counter(); /** * reachability statistics */ public final counter reachabStat = new counter(); /** * unreachability statistics */ public final counter unreachStat = new counter(); /** * message types received */ public final counter[] msgStats = new counter[256]; /** * attribute types received */ public final counter[] attrStats = new counter[256]; /** * full compute last */ public long fullLast; /** * incremental compute last */ public long incrLast; /** * full compute count */ public int fullCount; /** * incremental compute count */ public int incrCount; /** * full compute time */ public int fullTime; /** * incremental compute time */ public int incrTime; /** * changed prefixes current */ public int changedCur; /** * changed prefixes total */ public long changedTot; /** * changed prefixes peak */ public long changedMax; /** * changed prefixes peak */ public long changedPek; /** * the tcp protocol */ public final prtTcp tcpCore; /** * the forwarder protocol */ public final ipFwd fwdCore; /** * the forwarder vrf */ protected cfgVrf vrfCore; /** * notifier for table computation */ protected final notifier compute = new notifier(); /** * computation round */ protected final syncInt compRound = new syncInt(0); /** * need full round */ protected final syncInt needFull = new syncInt(0); private boolean oldAggr; private boolean need2run; /** * create bgp process * * @param forwarder forwarder to update * @param vrfcfg vrf config to use * @param protoT tcp protocol to use * @param id process id */ public rtrBgp(ipFwd forwarder, cfgVrf vrfcfg, prtTcp protoT, int id) { if (debugger.rtrBgpEvnt) { logger.debug("startup"); } vrfCore = vrfcfg; fwdCore = forwarder; tcpCore = protoT; vrfs = new tabGen(); ovrfs = new tabGen(); clrs = new tabGen(); oclrs = new tabGen(); vpls = new tabGen(); evpn = new tabGen(); evpnUni = tabLabel.allocate(tabLabelEntry.owner.evpnPbb); evpnMul = tabLabel.allocate(tabLabelEntry.owner.evpnPbb); evpnRcv = new rtrBgpEvpnPbb(this); evpnUni.setFwdPwe(tabLabelEntry.owner.evpnPbb, fwdCore, evpnRcv, 0, null); evpnMul.setFwdPwe(tabLabelEntry.owner.evpnPbb, fwdCore, evpnRcv, 0, null); routerID = new addrIPv4(); safeEbgp = true; addrFams = rtrBgpParam.mskUni; rtrNum = id; for (int i = 0; i < msgStats.length; i++) { msgStats[i] = new counter(); } for (int i = 0; i < attrStats.length; i++) { attrStats[i] = new counter(); } switch (fwdCore.ipVersion) { case ipCor4.protocolVersion: rouTyp = tabRouteAttr.routeType.bgp4; afiUni = rtrBgpUtil.safiIp4uni; afiLab = rtrBgpUtil.safiIp4lab; afiCtp = rtrBgpUtil.safiIp4ctp; afiCar = rtrBgpUtil.safiIp4car; afiMlt = rtrBgpUtil.safiIp4multi; afiOlab = rtrBgpUtil.safiIp6lab; afiOctp = rtrBgpUtil.safiIp6ctp; afiOcar = rtrBgpUtil.safiIp6car; afiOuni = rtrBgpUtil.safiIp6uni; afiOmlt = rtrBgpUtil.safiIp6multi; afiOflw = rtrBgpUtil.safiIp6flow; afiOsrt = rtrBgpUtil.safiIp6srte; afiFlw = rtrBgpUtil.safiIp4flow; afiVpnU = rtrBgpUtil.safiIp4vpnU; afiVpnM = rtrBgpUtil.safiIp4vpnM; afiVpnF = rtrBgpUtil.safiIp4vpnF; afiVpoU = rtrBgpUtil.safiIp6vpnU; afiVpoM = rtrBgpUtil.safiIp6vpnM; afiVpoF = rtrBgpUtil.safiIp6vpnF; afiVpls = rtrBgpUtil.safiVpls46; afiMspw = rtrBgpUtil.safiMspw46; afiEvpn = rtrBgpUtil.safiEvpn46; afiMdt = rtrBgpUtil.safiIp4mdt; afiNsh = rtrBgpUtil.safiNsh46; afiRpd = rtrBgpUtil.safiRpd46; afiSpf = rtrBgpUtil.safiIp46spf; afiRtf = rtrBgpUtil.safiRtf46; afiLnks = rtrBgpUtil.safiIp46lnks; afiSrte = rtrBgpUtil.safiIp4srte; afiMvpn = rtrBgpUtil.safiIp4mvpn; afiMvpo = rtrBgpUtil.safiIp6mvpn; afiMtre = rtrBgpUtil.safiIp4mtree; afiMtro = rtrBgpUtil.safiIp6mtree; other = new rtrBgpOther(this, vrfCore.fwd6); lspf = new rtrBgpSpf(this); break; case ipCor6.protocolVersion: rouTyp = tabRouteAttr.routeType.bgp6; afiUni = rtrBgpUtil.safiIp6uni; afiLab = rtrBgpUtil.safiIp6lab; afiCtp = rtrBgpUtil.safiIp6ctp; afiCar = rtrBgpUtil.safiIp6car; afiMlt = rtrBgpUtil.safiIp6multi; afiOlab = rtrBgpUtil.safiIp4lab; afiOctp = rtrBgpUtil.safiIp4ctp; afiOcar = rtrBgpUtil.safiIp4car; afiOuni = rtrBgpUtil.safiIp4uni; afiOmlt = rtrBgpUtil.safiIp4multi; afiOflw = rtrBgpUtil.safiIp4flow; afiOsrt = rtrBgpUtil.safiIp4srte; afiFlw = rtrBgpUtil.safiIp6flow; afiVpnU = rtrBgpUtil.safiIp6vpnU; afiVpnM = rtrBgpUtil.safiIp6vpnM; afiVpnF = rtrBgpUtil.safiIp6vpnF; afiVpoU = rtrBgpUtil.safiIp4vpnU; afiVpoM = rtrBgpUtil.safiIp4vpnM; afiVpoF = rtrBgpUtil.safiIp4vpnF; afiVpls = rtrBgpUtil.safiVpls46; afiMspw = rtrBgpUtil.safiMspw46; afiEvpn = rtrBgpUtil.safiEvpn46; afiMdt = rtrBgpUtil.safiIp6mdt; afiNsh = rtrBgpUtil.safiNsh46; afiRpd = rtrBgpUtil.safiRpd46; afiSpf = rtrBgpUtil.safiIp46spf; afiRtf = rtrBgpUtil.safiRtf46; afiLnks = rtrBgpUtil.safiIp46lnks; afiSrte = rtrBgpUtil.safiIp6srte; afiMvpn = rtrBgpUtil.safiIp6mvpn; afiMvpo = rtrBgpUtil.safiIp4mvpn; afiMtre = rtrBgpUtil.safiIp6mtree; afiMtro = rtrBgpUtil.safiIp4mtree; other = new rtrBgpOther(this, vrfCore.fwd4); lspf = new rtrBgpSpf(this); break; default: rouTyp = null; afiUni = 0; afiLab = 0; afiCtp = 0; afiCar = 0; afiMlt = 0; afiOlab = 0; afiOctp = 0; afiOcar = 0; afiOuni = 0; afiOmlt = 0; afiOflw = 0; afiOsrt = 0; afiFlw = 0; afiVpnU = 0; afiVpnM = 0; afiVpnF = 0; afiVpoU = 0; afiVpoM = 0; afiVpoF = 0; afiVpls = 0; afiMspw = 0; afiEvpn = 0; afiMdt = 0; afiNsh = 0; afiRpd = 0; afiSpf = 0; afiRtf = 0; afiLnks = 0; afiSrte = 0; afiMvpn = 0; afiMvpo = 0; afiMtre = 0; afiMtro = 0; other = new rtrBgpOther(this, null); lspf = new rtrBgpSpf(this); break; } incrLimit = 1000; conquer = false; flaps = null; scanTime = 1000; scanDelay = 1000; recursion = 1; restartTime = 60 * 1000; distantExt = 20; distantInt = 200; distantLoc = 200; linkStates = new tabGen(); lstnNei = new tabGen(); neighs = new tabGen(); mons = new tabGen(); dmps = new tabGen(); temps = new tabGen(); routerComputedU = new tabRoute("rx"); routerComputedM = new tabRoute("rx"); routerComputedF = new tabRoute("rx"); routerComputedI = new tabGen>(); needFull.add(1); compRound.add(1); routerCreateComputed(); need2run = true; new Thread(this).start(); fwdCore.routerAdd(this, rouTyp, id); } /** * convert to string * * @return string */ public String toString() { return "bgp on " + fwdCore; } /** * convert safi to mask * * @param safi safi * @return mask */ public long safi2mask(int safi) { if (safi == afiUni) { return rtrBgpParam.mskUni; } if (safi == afiLab) { return rtrBgpParam.mskLab; } if (safi == afiCtp) { return rtrBgpParam.mskCtp; } if (safi == afiCar) { return rtrBgpParam.mskCar; } if (safi == afiMlt) { return rtrBgpParam.mskMlt; } if (safi == afiOlab) { return rtrBgpParam.mskOlab; } if (safi == afiOctp) { return rtrBgpParam.mskOctp; } if (safi == afiOcar) { return rtrBgpParam.mskOcar; } if (safi == afiOuni) { return rtrBgpParam.mskOuni; } if (safi == afiOmlt) { return rtrBgpParam.mskOmlt; } if (safi == afiOflw) { return rtrBgpParam.mskOflw; } if (safi == afiOsrt) { return rtrBgpParam.mskOsrt; } if (safi == afiFlw) { return rtrBgpParam.mskFlw; } if (safi == afiVpnU) { return rtrBgpParam.mskVpnU; } if (safi == afiVpnM) { return rtrBgpParam.mskVpnM; } if (safi == afiVpnF) { return rtrBgpParam.mskVpnF; } if (safi == afiVpoU) { return rtrBgpParam.mskVpoU; } if (safi == afiVpoM) { return rtrBgpParam.mskVpoM; } if (safi == afiVpoF) { return rtrBgpParam.mskVpoF; } if (safi == afiVpls) { return rtrBgpParam.mskVpls; } if (safi == afiMspw) { return rtrBgpParam.mskMspw; } if (safi == afiEvpn) { return rtrBgpParam.mskEvpn; } if (safi == afiMdt) { return rtrBgpParam.mskMdt; } if (safi == afiNsh) { return rtrBgpParam.mskNsh; } if (safi == afiRpd) { return rtrBgpParam.mskRpd; } if (safi == afiSpf) { return rtrBgpParam.mskSpf; } if (safi == afiRtf) { return rtrBgpParam.mskRtf; } if (safi == afiSrte) { return rtrBgpParam.mskSrte; } if (safi == afiLnks) { return rtrBgpParam.mskLnks; } if (safi == afiMvpn) { return rtrBgpParam.mskMvpn; } if (safi == afiMvpo) { return rtrBgpParam.mskMvpo; } if (safi == afiMtre) { return rtrBgpParam.mskMtre; } if (safi == afiMtro) { return rtrBgpParam.mskMtro; } logger.info("unknown safi (" + safi + ") requested"); return -1; } /** * convert mask to safi * * @param mask mask * @return safi */ public int mask2safi(long mask) { if (mask == rtrBgpParam.mskUni) { return afiUni; } if (mask == rtrBgpParam.mskLab) { return afiLab; } if (mask == rtrBgpParam.mskCtp) { return afiCtp; } if (mask == rtrBgpParam.mskCar) { return afiCar; } if (mask == rtrBgpParam.mskMlt) { return afiMlt; } if (mask == rtrBgpParam.mskOlab) { return afiOlab; } if (mask == rtrBgpParam.mskOctp) { return afiOctp; } if (mask == rtrBgpParam.mskOcar) { return afiOcar; } if (mask == rtrBgpParam.mskOuni) { return afiOuni; } if (mask == rtrBgpParam.mskOmlt) { return afiOmlt; } if (mask == rtrBgpParam.mskOflw) { return afiOflw; } if (mask == rtrBgpParam.mskOsrt) { return afiOsrt; } if (mask == rtrBgpParam.mskFlw) { return afiFlw; } if (mask == rtrBgpParam.mskVpnU) { return afiVpnU; } if (mask == rtrBgpParam.mskVpnM) { return afiVpnM; } if (mask == rtrBgpParam.mskVpnF) { return afiVpnF; } if (mask == rtrBgpParam.mskVpoU) { return afiVpoU; } if (mask == rtrBgpParam.mskVpoM) { return afiVpoM; } if (mask == rtrBgpParam.mskVpoF) { return afiVpoF; } if (mask == rtrBgpParam.mskVpls) { return afiVpls; } if (mask == rtrBgpParam.mskMspw) { return afiMspw; } if (mask == rtrBgpParam.mskEvpn) { return afiEvpn; } if (mask == rtrBgpParam.mskMdt) { return afiMdt; } if (mask == rtrBgpParam.mskNsh) { return afiNsh; } if (mask == rtrBgpParam.mskRpd) { return afiRpd; } if (mask == rtrBgpParam.mskSpf) { return afiSpf; } if (mask == rtrBgpParam.mskRtf) { return afiRtf; } if (mask == rtrBgpParam.mskSrte) { return afiSrte; } if (mask == rtrBgpParam.mskLnks) { return afiLnks; } if (mask == rtrBgpParam.mskMvpn) { return afiMvpn; } if (mask == rtrBgpParam.mskMvpo) { return afiMvpo; } if (mask == rtrBgpParam.mskMtre) { return afiMtre; } if (mask == rtrBgpParam.mskMtro) { return afiMtro; } logger.info("unknown safi (" + mask + ") requested"); return -1; } /** * mask to list * * @param mask mask * @return list */ public List mask2list(long mask) { List safis = new ArrayList(); if ((mask & rtrBgpParam.mskUni) != 0) { safis.add(afiUni); } if ((mask & rtrBgpParam.mskLab) != 0) { safis.add(afiLab); } if ((mask & rtrBgpParam.mskCtp) != 0) { safis.add(afiCtp); } if ((mask & rtrBgpParam.mskCar) != 0) { safis.add(afiCar); } if ((mask & rtrBgpParam.mskMlt) != 0) { safis.add(afiMlt); } if ((mask & rtrBgpParam.mskOlab) != 0) { safis.add(afiOlab); } if ((mask & rtrBgpParam.mskOctp) != 0) { safis.add(afiOctp); } if ((mask & rtrBgpParam.mskOcar) != 0) { safis.add(afiOcar); } if ((mask & rtrBgpParam.mskOuni) != 0) { safis.add(afiOuni); } if ((mask & rtrBgpParam.mskOmlt) != 0) { safis.add(afiOmlt); } if ((mask & rtrBgpParam.mskOflw) != 0) { safis.add(afiOflw); } if ((mask & rtrBgpParam.mskOsrt) != 0) { safis.add(afiOsrt); } if ((mask & rtrBgpParam.mskFlw) != 0) { safis.add(afiFlw); } if ((mask & rtrBgpParam.mskVpnU) != 0) { safis.add(afiVpnU); } if ((mask & rtrBgpParam.mskVpnM) != 0) { safis.add(afiVpnM); } if ((mask & rtrBgpParam.mskVpnF) != 0) { safis.add(afiVpnF); } if ((mask & rtrBgpParam.mskVpoU) != 0) { safis.add(afiVpoU); } if ((mask & rtrBgpParam.mskVpoM) != 0) { safis.add(afiVpoM); } if ((mask & rtrBgpParam.mskVpoF) != 0) { safis.add(afiVpoF); } if ((mask & rtrBgpParam.mskVpls) != 0) { safis.add(afiVpls); } if ((mask & rtrBgpParam.mskMspw) != 0) { safis.add(afiMspw); } if ((mask & rtrBgpParam.mskEvpn) != 0) { safis.add(afiEvpn); } if ((mask & rtrBgpParam.mskMdt) != 0) { safis.add(afiMdt); } if ((mask & rtrBgpParam.mskNsh) != 0) { safis.add(afiNsh); } if ((mask & rtrBgpParam.mskRpd) != 0) { safis.add(afiRpd); } if ((mask & rtrBgpParam.mskSpf) != 0) { safis.add(afiSpf); } if ((mask & rtrBgpParam.mskRtf) != 0) { safis.add(afiRtf); } if ((mask & rtrBgpParam.mskSrte) != 0) { safis.add(afiSrte); } if ((mask & rtrBgpParam.mskLnks) != 0) { safis.add(afiLnks); } if ((mask & rtrBgpParam.mskMvpn) != 0) { safis.add(afiMvpn); } if ((mask & rtrBgpParam.mskMvpo) != 0) { safis.add(afiMvpo); } if ((mask & rtrBgpParam.mskMtre) != 0) { safis.add(afiMtre); } if ((mask & rtrBgpParam.mskMtro) != 0) { safis.add(afiMtro); } return safis; } /** * clear flap statistics */ public void doClearFlaps() { if (flaps == null) { return; } flaps.clear(); } /** * clear peak statistics */ public void doClearPeaks() { changedMax = 0; changedPek = 0; } /** * clear tiny counters */ public void doClearTinys() { reachabStat.clear(); unreachStat.clear(); accptStat.clear(); } /** * clear msg statistics */ public void doClearMsgs() { for (int i = 0; i < msgStats.length; i++) { msgStats[i].clear(); } } /** * clear msg statistics */ public void doClearAttrs() { for (int i = 0; i < attrStats.length; i++) { attrStats[i].clear(); } } /** * get database * * @param safi safi to query * @return table */ public tabRoute getDatabase(int safi) { if (safi == afiUni) { return routerComputedU; } if (safi == afiLab) { return routerComputedU; } if (safi == afiCtp) { return routerComputedU; } if (safi == afiCar) { return routerComputedU; } if (safi == afiMlt) { return routerComputedM; } if (safi == afiOlab) { return computedOuni; } if (safi == afiOctp) { return computedOuni; } if (safi == afiOcar) { return computedOuni; } if (safi == afiOuni) { return computedOuni; } if (safi == afiOmlt) { return computedOmlt; } if (safi == afiOflw) { return computedOflw; } if (safi == afiOsrt) { return computedOsrt; } if (safi == afiFlw) { return routerComputedF; } if (safi == afiVpnU) { return computedVpnU; } if (safi == afiVpnM) { return computedVpnM; } if (safi == afiVpnF) { return computedVpnF; } if (safi == afiVpoU) { return computedVpoU; } if (safi == afiVpoM) { return computedVpoM; } if (safi == afiVpoF) { return computedVpoF; } if (safi == afiVpls) { return computedVpls; } if (safi == afiMspw) { return computedMspw; } if (safi == afiEvpn) { return computedEvpn; } if (safi == afiMdt) { return computedMdt; } if (safi == afiNsh) { return computedNsh; } if (safi == afiRpd) { return computedRpd; } if (safi == afiSpf) { return computedSpf; } if (safi == afiRtf) { return computedRtf; } if (safi == afiSrte) { return computedSrte; } if (safi == afiLnks) { return computedLnks; } if (safi == afiMvpn) { return computedMvpn; } if (safi == afiMvpo) { return computedMvpo; } if (safi == afiMtre) { return computedMtre; } if (safi == afiMtro) { return computedMtro; } logger.info("unknown safi (" + safi + ") requested"); return null; } /** * get changed * * @param safi safi to query * @return table */ public tabRoute getChanged(int safi) { if (safi == afiUni) { return changedUni; } if (safi == afiLab) { return changedUni; } if (safi == afiCtp) { return changedUni; } if (safi == afiCar) { return changedUni; } if (safi == afiMlt) { return changedMlt; } if (safi == afiOlab) { return changedOuni; } if (safi == afiOctp) { return changedOuni; } if (safi == afiOcar) { return changedOuni; } if (safi == afiOuni) { return changedOuni; } if (safi == afiOmlt) { return changedOmlt; } if (safi == afiOflw) { return changedOflw; } if (safi == afiOsrt) { return changedOsrt; } if (safi == afiFlw) { return changedFlw; } if (safi == afiVpnU) { return changedVpnU; } if (safi == afiVpnM) { return changedVpnM; } if (safi == afiVpnF) { return changedVpnF; } if (safi == afiVpoU) { return changedVpoU; } if (safi == afiVpoM) { return changedVpoM; } if (safi == afiVpoF) { return changedVpoF; } if (safi == afiVpls) { return changedVpls; } if (safi == afiMspw) { return changedMspw; } if (safi == afiEvpn) { return changedEvpn; } if (safi == afiMdt) { return changedMdt; } if (safi == afiNsh) { return changedNsh; } if (safi == afiRpd) { return changedRpd; } if (safi == afiSpf) { return changedSpf; } if (safi == afiRtf) { return changedRtf; } if (safi == afiSrte) { return changedSrte; } if (safi == afiLnks) { return changedLnks; } if (safi == afiMvpn) { return changedMvpn; } if (safi == afiMvpo) { return changedMvpo; } if (safi == afiMtre) { return changedMtre; } if (safi == afiMtro) { return changedMtro; } logger.info("unknown safi (" + safi + ") requested"); return null; } public void run() { for (;;) { if (!cfgInit.booting) { break; } bits.sleep(1000); } needFull.add(1); routerCreateComputed(); bits.sleep(scanDelay); for (;;) { if (compute.misleep(0) > 0) { bits.sleep(scanTime); } if (!need2run) { break; } try { routerCreateComputed(); } catch (Exception e) { logger.traceback(e); } } } /** * close interface * * @param ifc interface */ public void closedInterface(ipFwdIface ifc) { } /** * start connection * * @param pipe pipeline * @param id connection * @return false if success, true if error */ public boolean streamAccept(pipeSide pipe, prtGenConn id) { packHolder pckCnt = new packHolder(true, true); accptStat.rx(pckCnt); rtrBgpLstn lstn = null; for (int i = 0; i < lstnTmp.size(); i++) { rtrBgpLstn ntry = lstnTmp.get(i); if (!ntry.acl.matches(id)) { continue; } lstn = ntry; break; } if (lstn == null) { accptStat.drop(pckCnt, counter.reasons.notInTab); return true; } if (lstn.temp.maxClones > 0) { int i = countClones(neighs, lstn.temp); i += countClones(lstnNei, lstn.temp); if (i > lstn.temp.maxClones) { accptStat.drop(pckCnt, counter.reasons.noBuffer); return true; } } id.changeSecurity(lstn.temp.keyId, lstn.temp.passwd, lstn.temp.ttlSecurity, lstn.temp.tosValue); rtrBgpNeigh ntry = new rtrBgpNeigh(this, id.peerAddr); ntry.localIfc = id.iface; ntry.localAddr = id.iface.addr.copyBytes(); ntry.updateOddr(); if (neighs.find(ntry) != null) { accptStat.drop(pckCnt, counter.reasons.notUp); return true; } ntry.copyFrom(lstn.temp); ntry.template = lstn.temp; if (ntry.fallOver) { ntry.sendingIfc = ipFwdTab.findSendingIface(fwdCore, ntry.peerAddr); } ntry.updatePeer(); rtrBgpNeigh res = lstnNei.add(ntry); if (res != null) { accptStat.drop(pckCnt, counter.reasons.noBuffer); return true; } logger.info("accepting dynamic " + id.peerAddr + " " + id.portRem + " as " + lstn.temp); ntry.conn = new rtrBgpSpeak(this, ntry, pipe); ntry.socketMode = 4; ntry.startNow(); accptStat.tx(pckCnt); return false; } private final int countClones(tabGen lst, rtrBgpTemp tmp) { int o = 0; for (int i = lst.size() - 1; i >= 0; i--) { rtrBgpNeigh ntry = lst.get(i); if (ntry == null) { continue; } if (ntry.template != tmp) { continue; } o++; } return o; } /** * add listen peer * * @param peer peer address * @param from from address * @param temp template to use * @return neighbor instance */ public rtrBgpNeigh addListenPeer(addrIP peer, addrIP from, rtrBgpTemp temp) { rtrBgpNeigh ntry = new rtrBgpNeigh(this, peer); ntry.localAddr = from.copyBytes(); if (neighs.find(ntry) != null) { return null; } ntry.copyFrom(temp); ntry.template = temp; ntry.updatePeer(); rtrBgpNeigh res = lstnNei.put(ntry); if (res != null) { res.socketMode = 5; res.stopNow(); } ntry.socketMode = 5; return ntry; } /** * get blocking mode * * @return mode */ public boolean streamForceBlock() { return true; } /** * redistribution changed */ public void routerRedistChanged() { if (debugger.rtrBgpFull) { logger.debug("redist changed"); } needFull.add(1); compute.wakeup(); } /** * others changed */ public void routerOthersChanged() { if (otherTrigger) { if (debugger.rtrBgpFull) { logger.debug("others changed"); } needFull.add(1); compute.wakeup(); return; } if ((nhtRoumap != null) || (nhtRouplc != null) || (nhtPfxlst != null)) { compute.wakeup(); return; } } private void computeFull() { long tim = bits.getTime(); if (debugger.rtrBgpIncr) { logger.debug("bestpath for everything"); } tabGen lstn = new tabGen(lstnNei); routerChangedU = null; routerChangedM = null; routerChangedF = null; other.routerChangedU = null; other.routerChangedM = null; other.routerChangedF = null; changedUni.clear(); changedMlt.clear(); changedOuni.clear(); changedOmlt.clear(); changedOflw.clear(); changedOsrt.clear(); changedFlw.clear(); changedVpnU.clear(); changedVpnM.clear(); changedVpnF.clear(); changedVpoU.clear(); changedVpoM.clear(); changedVpoF.clear(); changedVpls.clear(); changedMspw.clear(); changedEvpn.clear(); changedMdt.clear(); changedNsh.clear(); changedRpd.clear(); changedSpf.clear(); changedRtf.clear(); changedSrte.clear(); changedLnks.clear(); changedMvpn.clear(); changedMvpo.clear(); changedMtre.clear(); changedMtro.clear(); newlyUni = new tabRoute("bst"); newlyMlt = new tabRoute("bst"); newlyOuni = new tabRoute("bst"); newlyOmlt = new tabRoute("bst"); newlyOflw = new tabRoute("bst"); newlyOsrt = new tabRoute("bst"); newlyFlw = new tabRoute("bst"); newlyVpnU = new tabRoute("bst"); newlyVpnM = new tabRoute("bst"); newlyVpnF = new tabRoute("bst"); newlyVpoU = new tabRoute("bst"); newlyVpoM = new tabRoute("bst"); newlyVpoF = new tabRoute("bst"); newlyVpls = new tabRoute("bst"); newlyMspw = new tabRoute("bst"); newlyEvpn = new tabRoute("bst"); newlyMdt = new tabRoute("bst"); newlyNsh = new tabRoute("bst"); newlyRpd = new tabRoute("bst"); newlySpf = new tabRoute("bst"); newlyRtf = new tabRoute("bst"); newlySrte = new tabRoute("bst"); newlyLnks = new tabRoute("bst"); newlyMvpn = new tabRoute("bst"); newlyMvpo = new tabRoute("bst"); newlyMtre = new tabRoute("bst"); newlyMtro = new tabRoute("bst"); if (flowSpec != null) { rtrBgpFlow.doAdvertise(newlyFlw, flowSpec, new tabRouteEntry(), afiUni == rtrBgpUtil.safiIp6uni, localAs); } for (int i = 0; i < linkStates.size(); i++) { rtrBgpLnkst ls = linkStates.get(i); ls.rtr.routerLinkStates(newlyLnks, ls.par, localAs, routerID); } for (int i = 0; i < routerRedistedF.size(); i++) { tabRouteEntry ntry = routerRedistedF.get(i); if (ntry == null) { continue; } ntry = ntry.copyBytes(tabRoute.addType.notyet); ntry.best.rouTyp = rouTyp; ntry.best.protoNum = rtrNum; ntry.best.distance = distantLoc; newlyFlw.add(tabRoute.addType.better, ntry, false, false); } other.doAdvertise(); lspf.doAdvertise(); for (int i = 0; i < vrfs.size(); i++) { vrfs.get(i).doer.doAdvertise(newlyVpnU, newlyVpnM, newlyVpnF, newlyMvpn); } for (int i = 0; i < ovrfs.size(); i++) { ovrfs.get(i).doer.doAdvertise(newlyVpoU, newlyVpoM, newlyVpoF, newlyMvpo); } for (int i = 0; i < clrs.size(); i++) { clrs.get(i).doer.doAdvertise(newlyUni, newlyMlt, newlyFlw, newlyMvpn); } for (int i = 0; i < oclrs.size(); i++) { oclrs.get(i).doer.doAdvertise(newlyOuni, newlyOmlt, newlyOflw, newlyMvpo); } for (int i = 0; i < vpls.size(); i++) { vpls.get(i).doAdvertise(); } for (int i = 0; i < evpn.size(); i++) { evpn.get(i).doAdvertise(); } origntedOuni = new tabRoute(newlyOuni); origntedOmlt = new tabRoute(newlyOmlt); origntedOflw = new tabRoute(newlyOflw); origntedOsrt = new tabRoute(newlyOsrt); origntedFlw = new tabRoute(newlyFlw); origntedVpnU = new tabRoute(newlyVpnU); origntedVpnM = new tabRoute(newlyVpnM); origntedVpnF = new tabRoute(newlyVpnF); origntedVpoU = new tabRoute(newlyVpoU); origntedVpoM = new tabRoute(newlyVpoM); origntedVpoF = new tabRoute(newlyVpoF); origntedVpls = new tabRoute(newlyVpls); origntedMspw = new tabRoute(newlyMspw); origntedEvpn = new tabRoute(newlyEvpn); origntedMdt = new tabRoute(newlyMdt); origntedNsh = new tabRoute(newlyNsh); origntedRpd = new tabRoute(newlyRpd); origntedSpf = new tabRoute(newlySpf); origntedRtf = new tabRoute(newlyRtf); origntedSrte = new tabRoute(newlySrte); origntedLnks = new tabRoute(newlyLnks); origntedMvpn = new tabRoute(newlyMvpn); origntedMvpo = new tabRoute(newlyMvpo); origntedMtre = new tabRoute(newlyMtre); origntedMtro = new tabRoute(newlyMtro); if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " rpki"); } rpkiR = null; if (rpkiT != null) { cfgRtr rtrCfg = cfgAll.rtrFind(rpkiT, rpkiN, false); if (rtrCfg != null) { rpkiR = (rtrRpki) rtrCfg.getRouter(); } } if (rpkiR != null) { rpkiA = rpkiR.getFinalTab(fwdCore.ipVersion); rpkiO = rpkiR.getFinalTab(other.fwd.ipVersion); } else { rpkiA = new tabGen(); rpkiO = new tabGen(); } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " neighbors"); } groups = new ArrayList(); have2reflect = false; for (int i = 0; i < lstn.size(); i++) { rtrBgpNeigh nei = lstn.get(i); if (nei == null) { continue; } nei.setAccepted(); nei.setGroup(); nei.setMerge(); } for (int i = 0; i < neighs.size(); i++) { rtrBgpNeigh nei = neighs.get(i); if (nei == null) { continue; } nei.setAccepted(); nei.setGroup(); nei.setMerge(); } if (have2reflect) { tabRouteEntry ntry = new tabRouteEntry(); ntry.prefix = new addrPrefix(new addrIP(), 0); ntry.best.rouSrc = rtrBgpUtil.peerOriginate; newlyRtf.add(tabRoute.addType.always, ntry, true, true); origntedRtf.add(tabRoute.addType.always, ntry, true, true); } if (conquer) { if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " counquer"); } computeConquerTable(routerComputedU, newlyUni); computeConquerTable(routerComputedM, newlyMlt); computeConquerTable(computedOuni, newlyOuni); computeConquerTable(computedOmlt, newlyOmlt); computeConquerTable(computedOflw, newlyOflw); computeConquerTable(computedOsrt, newlyOsrt); computeConquerTable(routerComputedF, newlyFlw); computeConquerTable(computedVpnU, newlyVpnU); computeConquerTable(computedVpnM, newlyVpnM); computeConquerTable(computedVpnF, newlyVpnF); computeConquerTable(computedVpoU, newlyVpoU); computeConquerTable(computedVpoM, newlyVpoM); computeConquerTable(computedVpoF, newlyVpoF); computeConquerTable(computedVpls, newlyVpls); computeConquerTable(computedMspw, newlyMspw); computeConquerTable(computedEvpn, newlyEvpn); computeConquerTable(computedMdt, newlyMdt); computeConquerTable(computedNsh, newlyNsh); computeConquerTable(computedRpd, newlyRpd); computeConquerTable(computedSpf, newlySpf); computeConquerTable(computedRtf, newlyRtf); computeConquerTable(computedSrte, newlySrte); computeConquerTable(computedLnks, newlyLnks); computeConquerTable(computedMvpn, newlyMvpn); computeConquerTable(computedMvpo, newlyMvpo); computeConquerTable(computedMtre, newlyMtre); computeConquerTable(computedMtro, newlyMtro); } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " groups"); } for (int i = 0; i < groups.size(); i++) { groups.get(i).createNeeded(); } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " neigroups"); } lspf.doPeersFull(); boolean diffs = newlyUni.differs(tabRoute.addType.alters, routerComputedU) || newlyMlt.differs(tabRoute.addType.alters, routerComputedM) || newlyFlw.differs(tabRoute.addType.alters, routerComputedF); routerComputedU = newlyUni; routerComputedM = newlyMlt; computedOuni = newlyOuni; computedOmlt = newlyOmlt; computedOflw = newlyOflw; computedOsrt = newlyOsrt; routerComputedF = newlyFlw; computedVpnU = newlyVpnU; computedVpnM = newlyVpnM; computedVpnF = newlyVpnF; computedVpoU = newlyVpoU; computedVpoM = newlyVpoM; computedVpoF = newlyVpoF; computedVpls = newlyVpls; computedMspw = newlyMspw; computedEvpn = newlyEvpn; computedMdt = newlyMdt; computedNsh = newlyNsh; computedRpd = newlyRpd; computedSpf = newlySpf; computedRtf = newlyRtf; computedSrte = newlySrte; computedLnks = newlyLnks; computedMvpn = newlyMvpn; computedMvpo = newlyMvpo; computedMtre = newlyMtre; computedMtro = newlyMtro; if (diffs) { fwdCore.routerChg(this, true); } for (int i = 0; i < lstn.size(); i++) { rtrBgpNeigh nei = lstn.get(i); if (nei == null) { continue; } nei.setNeeded(); } for (int i = 0; i < neighs.size(); i++) { rtrBgpNeigh nei = neighs.get(i); if (nei == null) { continue; } nei.setNeeded(); } if (!lspf.enabled && (segrouLab != null)) { if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " segrou"); } tabGen> segrouUsd = new tabGen>(); for (int i = 0; i < newlyUni.size(); i++) { tabRouteEntry ntry = newlyUni.get(i); if (ntry == null) { continue; } if (ntry.best.segrouBeg < 1) { continue; } if ((ntry.best.segrouIdx <= 0) || (ntry.best.segrouIdx >= segrouMax)) { continue; } rtrBgpNeigh nei = findPeer(ntry.best.nextHop); if (nei == null) { continue; } List lab = tabLabel.int2labels(ntry.best.segrouBeg + ntry.best.segrouIdx); segrouLab[ntry.best.segrouIdx].setFwdMpls(tabLabelEntry.owner.bgpSrgb, fwdCore, nei.localIfc, nei.peerAddr, lab); tabIndex.add2table(segrouUsd, new tabIndex(ntry.best.segrouIdx, ntry.prefix)); } tabIndex.add2table(segrouUsd, new tabIndex(segrouIdx, new addrPrefix(new addrIP(), 0))); segrouLab[segrouIdx].setFwdCommon(tabLabelEntry.owner.bgpSrgb, fwdCore); for (int i = 0; i < segrouLab.length; i++) { if (segrouUsd.find(new tabIndex(i, null)) != null) { continue; } segrouLab[i].setFwdDrop(tabLabelEntry.owner.bgpSrgb); } routerComputedI = segrouUsd; } if (!lspf.enabled && (bierLab != null)) { if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " bier"); } tabLabelBier res = new tabLabelBier(bierLab[0].label, tabLabelBier.num2bsl(bierLen)); res.idx = bierIdx; for (int i = 0; i < newlyUni.size(); i++) { tabRouteEntry ntry = newlyUni.get(i); if (ntry == null) { continue; } if (ntry.best.bierBeg < 1) { continue; } if ((ntry.best.bierIdx <= 0) || (ntry.best.bierIdx >= bierMax)) { continue; } rtrBgpNeigh nei = findPeer(ntry.best.nextHop); if (nei == null) { continue; } tabLabelBierN per = new tabLabelBierN(fwdCore, nei.localIfc, nei.peerAddr, ntry.best.bierBeg, 0); tabLabelBierN old = res.peers.add(per); if (old != null) { per = old; } per.setBit(ntry.best.bierIdx - 1); } for (int i = 0; i < bierLab.length; i++) { bierLab[i].setBierMpls(tabLabelEntry.owner.bgpBier, fwdCore, res); } } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " export"); } otherTrigger = (addrFams & rtrBgpParam.mskLab) != 0; otherTrigger |= (addrFams & rtrBgpParam.mskCtp) != 0; otherTrigger |= (addrFams & rtrBgpParam.mskCar) != 0; otherTrigger |= linkStates.size() > 0; if (flowInst) { fwdCore.flowspec = tabQos.convertPolicy(rtrBgpFlow.doDecode(routerComputedF, afiUni == rtrBgpUtil.safiIp6uni)); } other.doPeersFull(); for (int i = 0; i < vrfs.size(); i++) { otherTrigger |= vrfs.get(i).doer.doPeersFull(newlyVpnU, newlyVpnM, newlyVpnF); } for (int i = 0; i < ovrfs.size(); i++) { otherTrigger |= ovrfs.get(i).doer.doPeersFull(newlyVpoU, newlyVpoM, newlyVpoF); } for (int i = 0; i < clrs.size(); i++) { otherTrigger |= clrs.get(i).doer.doPeersFull(newlyUni, newlyMlt, newlyFlw); } for (int i = 0; i < oclrs.size(); i++) { otherTrigger |= oclrs.get(i).doer.doPeersFull(newlyOuni, newlyOmlt, newlyOflw); } for (int i = 0; i < vpls.size(); i++) { vpls.get(i).doPeers(); } for (int i = 0; i < evpn.size(); i++) { evpn.get(i).doPeers(); } fullLast = bits.getTime(); fullTime = (int) (fullLast - tim); fullCount++; } private tabRouteEntry computeIncrBest(int afi, rtrBgpNeigh nei, tabRouteEntry best, tabRouteEntry curr) { if (nei == null) { return best; } if (!nei.reachable) { return best; } tabRoute acc = nei.getAccepted(afi); if (acc == null) { if (debugger.rtrBgpFull) { logger.debug("table not found"); } needFull.add(1); return best; } tabRouteEntry ntry = acc.find(curr); if (ntry == null) { return best; } if (best == null) { return ntry.copyBytes(tabRoute.addType.lnkEcmp); } if (best.best.isOtherBetter(ntry.best, false)) { return ntry.copyBytes(tabRoute.addType.lnkEcmp); } if (ntry.best.isOtherBetter(best.best, false)) { return best; } ntry = ntry.copyBytes(tabRoute.addType.lnkEcmp); best.addAlt(ntry.alts); return best; } private void computeIncrVersion(tabRouteEntry curr) { int ver = compRound.get() + 1; for (int i = 0; i < curr.alts.size(); i++) { curr.alts.get(i).version = ver; } } private void computeIncrEntry(int afi, tabRouteEntry curr, tabRoute cmp, tabRoute org) { if (debugger.rtrBgpIncr) { logger.debug("bestpath for " + tabRouteUtil.rd2string(curr.rouDst) + " " + curr.prefix + " in " + rtrBgpUtil.safi2string(afi)); } tabRouteEntry best = org.find(curr); if (best != null) { best = best.copyBytes(tabRoute.addType.altEcmp); best.best.rouSrc = rtrBgpUtil.peerOriginate; } for (int i = 0; i < lstnNei.size(); i++) { best = computeIncrBest(afi, lstnNei.get(i), best, curr); } for (int i = 0; i < neighs.size(); i++) { best = computeIncrBest(afi, neighs.get(i), best, curr); } if (best == null) { cmp.del(curr); computeIncrVersion(curr); for (int i = 0; i < groups.size(); i++) { rtrBgpGroup grp = groups.get(i); tabRoute wil = grp.getWilling(afi); tabRoute chg = grp.getChanged(afi); if ((wil == null) || (chg == null)) { if (debugger.rtrBgpFull) { logger.debug("table not found"); } needFull.add(1); continue; } if (wil.del(curr)) { continue; } chg.add(tabRoute.addType.always, curr, false, false); } return; } if (routerEcmp) { best.hashBest(); } else { best.selectBest(); } computeIncrVersion(best); if (conquer) { tabRouteEntry res = computeConquerEntry(cmp, best); if (res != null) { best = res; } } if ((best.best.rouSrc == rtrBgpUtil.peerOriginate) && ((afi == afiUni) || (afi == afiMlt))) { cmp.del(best); } else { cmp.add(tabRoute.addType.always, best, false, false); } for (int i = 0; i < groups.size(); i++) { rtrBgpGroup grp = groups.get(i); tabRoute wil = grp.getWilling(afi); tabRoute chg = grp.getChanged(afi); if ((wil == null) || (chg == null)) { if (debugger.rtrBgpFull) { logger.debug("table not found"); } needFull.add(1); continue; } tabRouteEntry ntry = null; tabRouteEntry old = wil.find(best); if (best.best.rouSrc == rtrBgpUtil.peerOriginate) { ntry = grp.originatePrefix(afi, best); } else { ntry = grp.readvertPrefix(afi, best); } if ((afi == afiUni) || (afi == afiMlt)) { ntry = tabRoute.doUpdateEntry(afi, grp.remoteAs, ntry, grp.roumapOut, grp.roupolOut, grp.prflstOut); } else if ((afi == afiOuni) || (afi == afiOmlt)) { ntry = tabRoute.doUpdateEntry(afi, grp.remoteAs, ntry, grp.oroumapOut, grp.oroupolOut, grp.oprflstOut); } else if ((afi == afiOflw) || (afi == afiOsrt) || (afi == afiMvpo) || (afi == afiVpoU) || (afi == afiVpoM) || (afi == afiVpoF)) { ntry = tabRoute.doUpdateEntry(afi, grp.remoteAs, ntry, grp.wroumapOut, grp.wroupolOut, null); } else if ((afi == afiEvpn) || (afi == afiVpls)) { ntry = tabRoute.doUpdateEntry(afi, grp.remoteAs, ntry, grp.eroumapOut, grp.eroupolOut, null); } else { ntry = tabRoute.doUpdateEntry(afi, grp.remoteAs, ntry, grp.vroumapOut, grp.vroupolOut, null); } if ((ntry == null) && (old == null)) { continue; } if (ntry == null) { wil.del(best); chg.add(tabRoute.addType.always, best, false, false); continue; } if (ntry.differs(tabRoute.addType.alters, old) == 0) { continue; } wil.add(tabRoute.addType.always, ntry, false, false); chg.add(tabRoute.addType.always, ntry, false, false); } } private int computeIncrUpdate(int afi, tabRoute don, tabRoute chg, tabRoute cmp, tabRoute org) { int res = 0; if (don == null) { don = new tabRoute("chg"); } for (int i = chg.size() - 1; i >= 0; i--) { tabRouteEntry ntry = chg.get(i); chg.del(ntry); don.add(tabRoute.addType.always, ntry, false, false); computeIncrEntry(afi, ntry, cmp, org); res++; } return res; } private void computeIncrPurge(int ver, tabRoute chg) { for (int i = chg.size() - 1; i >= 0; i--) { tabRouteEntry ntry = chg.get(i); if (ntry.best.version >= ver) { continue; } chg.del(ntry); } } private boolean computeIncr() { long tim = bits.getTime(); if (changedCur > incrLimit) { if (debugger.rtrBgpFull) { logger.debug("limit exceeded"); } return true; } if (lspf.enabled && (changedSpf.size() > 0)) { if (debugger.rtrBgpFull) { logger.debug("spf"); } return true; } if (routerAutoSummary || (routerAggregating.size() > 0)) { if (debugger.rtrBgpFull) { logger.debug("aggregation"); } oldAggr = true; return true; } if (oldAggr) { if (debugger.rtrBgpFull) { logger.debug("old aggregation"); } oldAggr = false; return true; } if ((segrouLab != null) || (bierLab != null)) { return true; } for (int i = 0; i < groups.size(); i++) { rtrBgpGroup grp = groups.get(i); if (grp.sendDefRou || grp.sendOtrDefRou) { return true; } } boolean labPer = routerAutoMesh != null; for (int i = 0; i < lstnNei.size(); i++) { rtrBgpNeigh nei = lstnNei.get(i); if (nei == null) { continue; } if (nei.softReconfig) { return true; } nei.setAccepted(); if (nei.reachOld != nei.reachable) { return true; } labPer |= nei.getLabeledPeer(); } for (int i = 0; i < neighs.size(); i++) { rtrBgpNeigh nei = neighs.get(i); if (nei == null) { continue; } if (nei.softReconfig) { return true; } nei.setAccepted(); if (nei.reachOld != nei.reachable) { return true; } labPer |= nei.getLabeledPeer(); } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " purge"); } for (int i = 0; i < groups.size(); i++) { groups.get(i).minversion = compRound.get(); } for (int i = 0; i < lstnNei.size(); i++) { rtrBgpNeigh nei = lstnNei.get(i); if (nei == null) { continue; } nei.setGrpVer(); } for (int i = 0; i < neighs.size(); i++) { rtrBgpNeigh nei = neighs.get(i); if (nei == null) { continue; } nei.setGrpVer(); } groupMin = compRound.get(); groupMax = 0; for (int i = 0; i < groups.size(); i++) { rtrBgpGroup grp = groups.get(i); if (grp.minversion < groupMin) { groupMin = grp.minversion; } if (grp.minversion > groupMax) { groupMax = grp.minversion; } computeIncrPurge(grp.minversion, grp.chgUni); computeIncrPurge(grp.minversion, grp.chgMlt); computeIncrPurge(grp.minversion, grp.chgOuni); computeIncrPurge(grp.minversion, grp.chgOmlt); computeIncrPurge(grp.minversion, grp.chgOflw); computeIncrPurge(grp.minversion, grp.chgOsrt); computeIncrPurge(grp.minversion, grp.chgFlw); computeIncrPurge(grp.minversion, grp.chgVpnU); computeIncrPurge(grp.minversion, grp.chgVpnM); computeIncrPurge(grp.minversion, grp.chgVpnF); computeIncrPurge(grp.minversion, grp.chgVpoU); computeIncrPurge(grp.minversion, grp.chgVpoM); computeIncrPurge(grp.minversion, grp.chgVpoF); computeIncrPurge(grp.minversion, grp.chgVpls); computeIncrPurge(grp.minversion, grp.chgMspw); computeIncrPurge(grp.minversion, grp.chgEvpn); computeIncrPurge(grp.minversion, grp.chgMdt); computeIncrPurge(grp.minversion, grp.chgNsh); computeIncrPurge(grp.minversion, grp.chgRpd); computeIncrPurge(grp.minversion, grp.chgSpf); computeIncrPurge(grp.minversion, grp.chgRtf); computeIncrPurge(grp.minversion, grp.chgSrte); computeIncrPurge(grp.minversion, grp.chgLnks); computeIncrPurge(grp.minversion, grp.chgMvpn); computeIncrPurge(grp.minversion, grp.chgMvpo); computeIncrPurge(grp.minversion, grp.chgMtre); computeIncrPurge(grp.minversion, grp.chgMtro); } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " changes"); } routerChangedU = new tabRoute("chg"); routerChangedM = new tabRoute("chg"); routerChangedF = new tabRoute("chg"); other.routerChangedU = new tabRoute("chg"); other.routerChangedM = new tabRoute("chg"); other.routerChangedF = new tabRoute("chg"); tabRoute chgVpnU = new tabRoute("chg"); tabRoute chgVpnM = new tabRoute("chg"); tabRoute chgVpnF = new tabRoute("chg"); tabRoute chgVpoU = new tabRoute("chg"); tabRoute chgVpoM = new tabRoute("chg"); tabRoute chgVpoF = new tabRoute("chg"); tabRoute chgEvpn = new tabRoute("chg"); int cntGlb = computeIncrUpdate(afiUni, routerChangedU, changedUni, routerComputedU, routerRedistedU); cntGlb += computeIncrUpdate(afiMlt, routerChangedM, changedMlt, routerComputedM, routerRedistedM); computeIncrUpdate(afiOuni, other.routerChangedU, changedOuni, computedOuni, origntedOuni); computeIncrUpdate(afiOmlt, other.routerChangedM, changedOmlt, computedOmlt, origntedOmlt); computeIncrUpdate(afiOflw, other.routerChangedF, changedOflw, computedOflw, origntedOflw); computeIncrUpdate(afiOsrt, null, changedOsrt, computedOsrt, origntedOsrt); int cntFlw = computeIncrUpdate(afiFlw, routerChangedF, changedFlw, routerComputedF, origntedFlw); computeIncrUpdate(afiVpnU, chgVpnU, changedVpnU, computedVpnU, origntedVpnU); computeIncrUpdate(afiVpnM, chgVpnM, changedVpnM, computedVpnM, origntedVpnM); computeIncrUpdate(afiVpnF, chgVpnF, changedVpnF, computedVpnF, origntedVpnF); computeIncrUpdate(afiVpoU, chgVpoU, changedVpoU, computedVpoU, origntedVpoU); computeIncrUpdate(afiVpoM, chgVpoM, changedVpoM, computedVpoM, origntedVpoM); computeIncrUpdate(afiVpoF, chgVpoF, changedVpoF, computedVpoF, origntedVpoF); int cntVpls = computeIncrUpdate(afiVpls, null, changedVpls, computedVpls, origntedVpls); computeIncrUpdate(afiMspw, null, changedMspw, computedMspw, origntedMspw); int cntEvpn = computeIncrUpdate(afiEvpn, chgEvpn, changedEvpn, computedEvpn, origntedEvpn); computeIncrUpdate(afiMdt, null, changedMdt, computedMdt, origntedMdt); computeIncrUpdate(afiNsh, null, changedNsh, computedNsh, origntedNsh); computeIncrUpdate(afiRpd, null, changedRpd, computedRpd, origntedRpd); computeIncrUpdate(afiSpf, null, changedSpf, computedSpf, origntedSpf); computeIncrUpdate(afiRtf, null, changedRtf, computedRtf, origntedRtf); computeIncrUpdate(afiSrte, null, changedSrte, computedSrte, origntedSrte); computeIncrUpdate(afiLnks, null, changedLnks, computedLnks, origntedLnks); computeIncrUpdate(afiMvpn, null, changedMvpn, computedMvpn, origntedMvpn); computeIncrUpdate(afiMvpo, null, changedMvpo, computedMvpo, origntedMvpo); computeIncrUpdate(afiMtre, null, changedMtre, computedMtre, origntedMtre); computeIncrUpdate(afiMtro, null, changedMtro, computedMtro, origntedMtro); lspf.doPeersIncr(); if (labPer || ((cntGlb + cntFlw) > 0)) { fwdCore.routerChg(this, labPer); } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " export"); } if (flowInst && (cntFlw > 0)) { fwdCore.flowspec = tabQos.convertPolicy(rtrBgpFlow.doDecode(routerComputedF, afiUni == rtrBgpUtil.safiIp6uni)); } other.doPeersIncr(); for (int i = 0; i < vrfs.size(); i++) { vrfs.get(i).doer.doPeersIncr(computedVpnU, computedVpnM, computedVpnF, chgVpnU, chgVpnM, chgVpnF, chgEvpn); } for (int i = 0; i < ovrfs.size(); i++) { ovrfs.get(i).doer.doPeersIncr(computedVpoU, computedVpoM, computedVpoF, chgVpoU, chgVpoM, chgVpoF, chgEvpn); } for (int i = 0; i < clrs.size(); i++) { clrs.get(i).doer.doPeersIncr(routerComputedU, routerComputedM, routerComputedF, routerChangedU, routerChangedM, routerChangedF, chgEvpn); } for (int i = 0; i < oclrs.size(); i++) { oclrs.get(i).doer.doPeersIncr(computedOuni, computedOmlt, computedOflw, other.routerChangedU, other.routerChangedM, other.routerChangedF, chgEvpn); } if (cntVpls > 0) { for (int i = 0; i < vpls.size(); i++) { vpls.get(i).doPeers(); } } if (cntEvpn > 0) { for (int i = 0; i < evpn.size(); i++) { evpn.get(i).doPeers(); } } incrLast = bits.getTime(); incrTime = (int) (incrLast - tim); incrCount++; return false; } private tabRouteEntry computeConquerEntry(tabRoute cmp, tabRouteEntry best) { if (best.best.nextHop == null) { return null; } tabRouteEntry old = cmp.find(best); if (old == null) { return null; } if (old.best.nextHop == null) { return null; } best = best.copyBytes(tabRoute.addType.notyet); if (best.best.locPref < old.best.locPref) { best.best.locPref = old.best.locPref; } if (old.best.nextHop.compareTo(best.best.nextHop) != 0) { best.best.locPref++; } return best; } private void computeConquerTable(tabRoute old, tabRoute cmp) { for (int i = 0; i < cmp.size(); i++) { tabRouteEntry ntry = cmp.get(i); ntry = computeConquerEntry(old, ntry); if (ntry == null) { continue; } cmp.add(tabRoute.addType.always, ntry, false, false); } } /** * update flap statistics * * @param afi afi * @param rd rd * @param prf prefix * @param pth path */ protected void prefixFlapped(int afi, long rd, addrPrefix prf, List pth) { if (pth == null) { pth = new ArrayList(); } rtrBgpFlapStat ntry = new rtrBgpFlapStat(afi, rd, prf); rtrBgpFlapStat old = flaps.add(ntry); if (old != null) { ntry = old; } ntry.count++; ntry.last = bits.getTime(); rtrBgpFlapLst pe = new rtrBgpFlapLst(pth); rtrBgpFlapLst op = ntry.paths.add(pe); if (op != null) { pe = op; } pe.count++; pe.last = ntry.last; } /** * create computed table */ public synchronized void routerCreateComputed() { if (debugger.rtrBgpEvnt) { logger.debug("create table"); } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " start"); } changedCur = changedUni.size() + changedMlt.size() + changedOuni.size() + changedOmlt.size() + changedOflw.size() + changedOsrt.size() + changedFlw.size() + changedVpnU.size() + changedVpnM.size() + changedVpnF.size() + changedVpoU.size() + changedVpoM.size() + changedVpoF.size() + changedVpls.size() + changedMspw.size() + changedEvpn.size() + changedMdt.size() + changedNsh.size() + changedRpd.size() + changedSpf.size() + changedSrte.size() + changedLnks.size() + changedRtf.size() + changedMvpn.size() + changedMvpo.size() + changedMtre.size() + changedMtro.size(); changedTot += changedCur; if (changedCur > changedMax) { changedMax = changedCur; changedPek = bits.getTime(); } if (needFull.set(0) > 0) { computeFull(); } else if (computeIncr()) { computeFull(); } compRound.add(1); for (int i = 0; i < lstnNei.size(); i++) { rtrBgpNeigh nei = lstnNei.get(i); if (nei == null) { continue; } nei.transmit.wakeup(); } for (int i = 0; i < neighs.size(); i++) { rtrBgpNeigh nei = neighs.get(i); if (nei == null) { continue; } nei.transmit.wakeup(); } if (debugger.rtrBgpComp) { logger.debug("round " + compRound + " done"); } } /** * stop work */ public void routerCloseNow() { if (debugger.rtrBgpEvnt) { logger.debug("shutdown"); } need2run = false; compute.wakeup(); for (int i = 0; i < mons.size(); i++) { rtrBgpMon ntry = mons.get(i); ntry.stopNow(); } for (int i = 0; i < dmps.size(); i++) { rtrBgpMrt ntry = dmps.get(i); ntry.fileHandle.close(); } for (int i = 0; i < lstnTmp.size(); i++) { rtrBgpLstn ntry = lstnTmp.get(i); tcpCore.listenStop(ntry.iface, port, null, 0); } for (int i = lstnNei.size() - 1; i >= 0; i--) { rtrBgpNeigh nei = lstnNei.get(i); if (nei == null) { continue; } nei.stopNow(); nei.conn.closeNow(); } for (int i = 0; i < neighs.size(); i++) { rtrBgpNeigh nei = neighs.get(i); if (nei == null) { continue; } nei.stopNow(); nei.conn.closeNow(); } other.unregister2ip(); for (int i = 0; i < vrfs.size(); i++) { vrfs.get(i).doer.unregister2ip(); } for (int i = 0; i < ovrfs.size(); i++) { ovrfs.get(i).doer.unregister2ip(); } for (int i = 0; i < clrs.size(); i++) { clrs.get(i).doer.unregister2ip(); } for (int i = 0; i < oclrs.size(); i++) { oclrs.get(i).doer.unregister2ip(); } for (int i = 0; i < vpls.size(); i++) { vpls.get(i).doStop(); } for (int i = 0; i < evpn.size(); i++) { evpn.get(i).doStop(); } tabLabel.release(evpnUni, tabLabelEntry.owner.evpnPbb); tabLabel.release(evpnMul, tabLabelEntry.owner.evpnPbb); tabLabel.release(segrouLab, tabLabelEntry.owner.bgpSrgb); tabLabel.release(bierLab, tabLabelEntry.owner.bgpBier); fwdCore.routerDel(this); } /** * get help * * @param l list */ public void routerGetHelp(userHelping l) { List tmps = new ArrayList(); for (int i = 0; i < temps.size(); i++) { rtrBgpTemp ntry = temps.get(i); tmps.add(ntry.tempName); } List neis = new ArrayList(); for (int i = 0; i < neighs.size(); i++) { rtrBgpNeigh ntry = neighs.get(i); neis.add("" + ntry.peerAddr); } l.add(null, "1 2 address-family specify address families"); rtrBgpParam.getAfiList(l, "2 2,.", "to use", true); l.add(null, "1 2 local-as specify local as number"); l.add(null, "2 . autonomous system number"); l.add(null, "1 . default-originate advertise default route"); l.add(null, "1 . conquer conquer bestpath advertisements"); l.add(null, "1 . flapstat count flap statistics"); l.add(null, "1 . safe-ebgp safe ebgp policy"); l.add(null, "1 2 incremental limit on incremental bestpath calculation"); l.add(null, "2 . maximum prefixes"); l.add(null, "1 2 router-id specify router id"); l.add(null, "2 . router id"); l.add(null, "1 2 scantime scan time interval"); l.add(null, "2 . ms between scans"); l.add(null, "1 2 scandelay initial scan time delay"); l.add(null, "2 . ms before scan"); l.add(null, "1 2 graceful-restart graceful restart interval"); l.add(null, "2 . ms to recover"); l.add(null, "1 2 longlived-graceful long lived graceful restart interval"); l.add(null, "2 . ms to recover"); l.add(null, "1 2 template specify template parameters"); l.add(tmps, "2 3 name of template"); rtrBgpParam.getParamHelp(l); l.add(null, "1 2 nexthop specify next hop tracking parameter"); l.add(null, "2 3 recursion specify recursion depth"); l.add(null, "3 . maximum rounds"); l.add(null, "2 3 route-map filter next hops"); l.add(null, "3 . name of route map"); l.add(null, "2 3 route-policy filter next hops"); l.add(null, "3 . name of route policy"); l.add(null, "2 3 prefix-list filter next hops"); l.add(null, "3 . name of prefix list"); l.add(null, "1 2 segrout segment routing parameters"); l.add(null, "2 3 maximum index"); l.add(null, "3 4,. this node index"); l.add(null, "4 5 base specify base"); l.add(null, "5 4,. label base"); l.add(null, "1 2 bier bier parameters"); l.add(null, "2 3 bitstring length"); l.add(null, "3 4 maximum index"); l.add(null, "4 5,. node index"); l.add(null, "5 .