Class BgpConfigurationManager
- java.lang.Object
-
- org.opendaylight.netvirt.bgpmanager.BgpConfigurationManager
-
- All Implemented Interfaces:
EbgpService
,org.opendaylight.yangtools.yang.binding.RpcService
@Singleton public class BgpConfigurationManager extends java.lang.Object implements EbgpService
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
BgpConfigurationManager.AddressFamiliesReactor
class
BgpConfigurationManager.AsIdReactor
class
BgpConfigurationManager.BfdConfigReactor
class
BgpConfigurationManager.BgpReactor
class
BgpConfigurationManager.ConfigServerReactor
class
BgpConfigurationManager.EbgpMultihopReactor
class
BgpConfigurationManager.GracefulRestartReactor
class
BgpConfigurationManager.LoggingReactor
class
BgpConfigurationManager.MultipathReactor
class
BgpConfigurationManager.NeighborsReactor
class
BgpConfigurationManager.NetworksReactor
class
BgpConfigurationManager.UpdateSourceReactor
class
BgpConfigurationManager.VrfMaxpathReactor
class
BgpConfigurationManager.VrfsReactor
-
Constructor Summary
Constructors Constructor Description BgpConfigurationManager(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService entityOwnershipService, FibDSWriter fibDSWriter, IVpnLinkService vpnLinkSrvce, org.osgi.framework.BundleContext bundleContext, BgpUtil bgpUtil, org.opendaylight.infrautils.metrics.MetricProvider metricProvider)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addAddressFamily(java.lang.String nbrIp, int afi, int safi)
void
addDcgwTep(java.lang.String dcgwIp, java.lang.String tepIp)
void
addEbgpMultihop(java.lang.String nbrIp, int hops)
void
addGracefulRestart(int staleTime)
void
addLogging(java.lang.String fileName, java.lang.String logLevel)
void
addNeighbor(java.lang.String nbrIp, long remoteAs, @Nullable TcpMd5SignaturePasswordType md5Secret)
void
addPrefix(java.lang.String rd, java.lang.String macAddress, java.lang.String pfx, java.util.List<java.lang.String> nhList, VrfEntryBase.EncapType encapType, org.opendaylight.yangtools.yang.common.Uint32 lbl, org.opendaylight.yangtools.yang.common.Uint32 l3vni, org.opendaylight.yangtools.yang.common.Uint32 l2vni, java.lang.String gatewayMac)
void
addTepToElanDS(java.lang.String rd, java.lang.String tepIp, java.lang.String mac, org.opendaylight.yangtools.yang.common.Uint32 l2vni)
boolean
addToRt2TepMap(java.lang.String rd, java.lang.String tepIp, java.lang.String mac, org.opendaylight.yangtools.yang.common.Uint32 l2vni)
void
addUpdateSource(java.lang.String nbrIp, java.lang.String srcIp)
void
addVrf(java.lang.String rd, java.util.List<java.lang.String> irts, java.util.List<java.lang.String> erts, AddressFamily addressFamily)
void
bgpRestarted()
void
close()
void
createStaleFibMap()
void
delAddressFamily(java.lang.String nbrIp, int afi, int safi)
void
delDcgwTep(java.lang.String dcgwIp, java.lang.String tepIp)
void
delEbgpMultihop(java.lang.String nbrIp)
void
deleteExternalFibRoutes()
boolean
deleteFromRt2TepMap(java.lang.String rd, java.lang.String tepIp, java.lang.String mac)
void
deleteTepfromElanDS(java.lang.String rd, java.lang.String tepIp, java.lang.String mac)
void
delGracefulRestart()
void
delLogging()
void
delMultipaths(java.lang.String rd)
void
delNeighbor(java.lang.String nbrIp)
void
delPrefix(java.lang.String rd, java.lang.String pfx)
void
delUpdateSource(java.lang.String nbrIp)
boolean
delVrf(java.lang.String rd, AddressFamily addressFamily)
Bgp
get()
BgpAlarms
getBgpAlarms()
BgpCounters
getBgpCounters()
java.lang.String
getBgpSdncMipIp()
org.opendaylight.ovsdb.utils.mdsal.utils.TransactionHistory
getBgpUpdatesHistory()
long
getCfgReplayEndTime()
long
getCfgReplayStartTime()
Bgp
getConfig()
java.lang.String
getConfigHost()
int
getConfigPort()
long
getConnectTS()
long
getLastConnectedTS()
static java.util.List<Neighbors>
getNbrList()
void
getPeerStatus(java.lang.String nbrIp, long nbrAsNum)
long
getStaleCleanupTime()
long
getStaleEndTime()
long
getStalePathtime(int defValue, AsId asId)
long
getStaleStartTime()
long
getStartTS()
java.util.Collection<java.lang.String>
getTepIPs(java.lang.String rd)
int
getTotalCleared()
int
getTotalStaledCount()
org.apache.thrift.transport.TTransport
getTransport()
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<InitiateEorOutput>>
initiateEor(InitiateEorInput input)
Invokeinitiate-eor
RPC.boolean
isBgpConnected()
boolean
isBGPEntityOwner()
boolean
isIpAvailable(java.lang.String odlip)
static boolean
isValidConfigBgpHostPort(java.lang.String bgpHost, int bgpPort)
void
onUpdatePushRoute(protocol_type protocolType, java.lang.String rd, java.lang.String prefix, int plen, java.lang.String nextHop, java.lang.String macaddress, org.opendaylight.yangtools.yang.common.Uint32 label, org.opendaylight.yangtools.yang.common.Uint32 l2label, java.lang.String routermac, af_afi afi)
void
onUpdateWithdrawRoute(java.lang.String rd, java.lang.String prefix, int plen, java.lang.String nexthop)
void
onUpdateWithdrawRoute(protocol_type protocolType, java.lang.String rd, java.lang.String prefix, int plen, java.lang.String nextHop, java.lang.String macaddress)
void
peerDown(java.lang.String ipAddress, long asNumber)
void
peerUp(java.lang.String ipAddress, long asNumber)
boolean
replay()
void
setCfgReplayEndTime(long cfgReplayEndTime)
void
setCfgReplayStartTime(long cfgReplayStartTime)
void
setMultipaths(java.lang.String rd, int maxpath)
void
setMultipathStatus(af_afi afi, af_safi safi, boolean enable)
void
setStaleCleanupTime(long staleCleanupTime)
void
setStaleEndTime(long staleEndTime)
void
setStaleStartTime(long staleStartTime)
void
startBfd(long detectMult, long minRx, long minTx, boolean multiHop)
void
startBgp(long as, java.lang.String routerId, int spt, boolean fbit)
void
startConfig(java.lang.String bgpHost, int thriftPort)
void
stopBfd()
void
stopBgp()
void
stopConfig()
-
-
-
Constructor Detail
-
BgpConfigurationManager
@Inject public BgpConfigurationManager(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService entityOwnershipService, FibDSWriter fibDSWriter, IVpnLinkService vpnLinkSrvce, org.osgi.framework.BundleContext bundleContext, BgpUtil bgpUtil, org.opendaylight.infrautils.metrics.MetricProvider metricProvider)
-
-
Method Detail
-
getBgpSdncMipIp
public java.lang.String getBgpSdncMipIp()
-
getStaleCleanupTime
public long getStaleCleanupTime()
-
setStaleCleanupTime
public void setStaleCleanupTime(long staleCleanupTime)
-
getCfgReplayEndTime
public long getCfgReplayEndTime()
-
setCfgReplayEndTime
public void setCfgReplayEndTime(long cfgReplayEndTime)
-
getBgpUpdatesHistory
public org.opendaylight.ovsdb.utils.mdsal.utils.TransactionHistory getBgpUpdatesHistory()
-
getCfgReplayStartTime
public long getCfgReplayStartTime()
-
setCfgReplayStartTime
public void setCfgReplayStartTime(long cfgReplayStartTime)
-
getStaleEndTime
public long getStaleEndTime()
-
setStaleEndTime
public void setStaleEndTime(long staleEndTime)
-
getStaleStartTime
public long getStaleStartTime()
-
setStaleStartTime
public void setStaleStartTime(long staleStartTime)
-
close
@PreDestroy public void close()
-
isBGPEntityOwner
public boolean isBGPEntityOwner()
-
get
public Bgp get()
-
isIpAvailable
public boolean isIpAvailable(java.lang.String odlip)
-
getStalePathtime
public long getStalePathtime(int defValue, AsId asId)
-
isValidConfigBgpHostPort
public static boolean isValidConfigBgpHostPort(java.lang.String bgpHost, int bgpPort)
-
bgpRestarted
public void bgpRestarted()
-
addTepToElanDS
public void addTepToElanDS(java.lang.String rd, java.lang.String tepIp, java.lang.String mac, org.opendaylight.yangtools.yang.common.Uint32 l2vni)
-
deleteTepfromElanDS
public void deleteTepfromElanDS(java.lang.String rd, java.lang.String tepIp, java.lang.String mac)
-
onUpdatePushRoute
public void onUpdatePushRoute(protocol_type protocolType, java.lang.String rd, java.lang.String prefix, int plen, java.lang.String nextHop, java.lang.String macaddress, org.opendaylight.yangtools.yang.common.Uint32 label, org.opendaylight.yangtools.yang.common.Uint32 l2label, java.lang.String routermac, af_afi afi)
-
onUpdateWithdrawRoute
public void onUpdateWithdrawRoute(protocol_type protocolType, java.lang.String rd, java.lang.String prefix, int plen, java.lang.String nextHop, java.lang.String macaddress)
-
onUpdateWithdrawRoute
public void onUpdateWithdrawRoute(java.lang.String rd, java.lang.String prefix, int plen, java.lang.String nexthop)
-
peerDown
public void peerDown(java.lang.String ipAddress, long asNumber)
-
peerUp
public void peerUp(java.lang.String ipAddress, long asNumber)
-
getConfigHost
public java.lang.String getConfigHost()
-
getConfigPort
public int getConfigPort()
-
getConfig
public Bgp getConfig()
-
replay
public boolean replay() throws java.lang.InterruptedException, java.util.concurrent.TimeoutException, java.util.concurrent.ExecutionException
- Throws:
java.lang.InterruptedException
java.util.concurrent.TimeoutException
java.util.concurrent.ExecutionException
-
startConfig
public void startConfig(java.lang.String bgpHost, int thriftPort)
-
startBgp
public void startBgp(long as, java.lang.String routerId, int spt, boolean fbit)
-
startBfd
public void startBfd(long detectMult, long minRx, long minTx, boolean multiHop)
-
addDcgwTep
public void addDcgwTep(java.lang.String dcgwIp, java.lang.String tepIp)
-
addLogging
public void addLogging(java.lang.String fileName, java.lang.String logLevel)
-
addGracefulRestart
public void addGracefulRestart(int staleTime)
-
addNeighbor
public void addNeighbor(java.lang.String nbrIp, long remoteAs, @Nullable TcpMd5SignaturePasswordType md5Secret)
-
addUpdateSource
public void addUpdateSource(java.lang.String nbrIp, java.lang.String srcIp)
-
addEbgpMultihop
public void addEbgpMultihop(java.lang.String nbrIp, int hops)
-
addAddressFamily
public void addAddressFamily(java.lang.String nbrIp, int afi, int safi)
-
addPrefix
public void addPrefix(java.lang.String rd, java.lang.String macAddress, java.lang.String pfx, java.util.List<java.lang.String> nhList, VrfEntryBase.EncapType encapType, org.opendaylight.yangtools.yang.common.Uint32 lbl, org.opendaylight.yangtools.yang.common.Uint32 l3vni, org.opendaylight.yangtools.yang.common.Uint32 l2vni, java.lang.String gatewayMac)
-
addVrf
public void addVrf(java.lang.String rd, java.util.List<java.lang.String> irts, java.util.List<java.lang.String> erts, AddressFamily addressFamily)
-
stopConfig
public void stopConfig()
-
stopBgp
public void stopBgp()
-
stopBfd
public void stopBfd()
-
delDcgwTep
public void delDcgwTep(java.lang.String dcgwIp, java.lang.String tepIp)
-
delLogging
public void delLogging()
-
delGracefulRestart
public void delGracefulRestart()
-
delNeighbor
public void delNeighbor(java.lang.String nbrIp)
-
delUpdateSource
public void delUpdateSource(java.lang.String nbrIp)
-
delEbgpMultihop
public void delEbgpMultihop(java.lang.String nbrIp)
-
delAddressFamily
public void delAddressFamily(java.lang.String nbrIp, int afi, int safi)
-
delPrefix
public void delPrefix(java.lang.String rd, java.lang.String pfx)
-
delVrf
public boolean delVrf(java.lang.String rd, AddressFamily addressFamily)
-
setMultipaths
public void setMultipaths(java.lang.String rd, int maxpath)
-
delMultipaths
public void delMultipaths(java.lang.String rd)
-
createStaleFibMap
public void createStaleFibMap()
-
deleteExternalFibRoutes
public void deleteExternalFibRoutes()
-
addToRt2TepMap
public boolean addToRt2TepMap(java.lang.String rd, java.lang.String tepIp, java.lang.String mac, org.opendaylight.yangtools.yang.common.Uint32 l2vni)
-
deleteFromRt2TepMap
public boolean deleteFromRt2TepMap(java.lang.String rd, java.lang.String tepIp, java.lang.String mac)
-
getTepIPs
public java.util.Collection<java.lang.String> getTepIPs(java.lang.String rd)
-
isBgpConnected
public boolean isBgpConnected()
-
getLastConnectedTS
public long getLastConnectedTS()
-
getConnectTS
public long getConnectTS()
-
getStartTS
public long getStartTS()
-
getTransport
public org.apache.thrift.transport.TTransport getTransport()
-
getTotalStaledCount
public int getTotalStaledCount()
-
getTotalCleared
public int getTotalCleared()
-
getNbrList
public static java.util.List<Neighbors> getNbrList()
-
getBgpCounters
public BgpCounters getBgpCounters()
-
getBgpAlarms
public BgpAlarms getBgpAlarms()
-
getPeerStatus
public void getPeerStatus(java.lang.String nbrIp, long nbrAsNum) throws BgpRouterException, org.apache.thrift.TException
- Throws:
BgpRouterException
org.apache.thrift.TException
-
initiateEor
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<InitiateEorOutput>> initiateEor(InitiateEorInput input)
Description copied from interface:EbgpService
Invokeinitiate-eor
RPC.during upgrade, BGPManager waits for EoR trigger from RBU
- Specified by:
initiateEor
in interfaceEbgpService
- Parameters:
input
- ofinitiate-eor
- Returns:
- output of
initiate-eor
-
-