git.opendaylight Code Review - netvirt.git/blob

   1 /*
   2  * Copyright © 2015, 2017 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.netvirt.bgpmanager;
   9
  10 import java.util.ArrayList;
  11 import java.util.Collection;
  12 import java.util.Collections;
  13 import java.util.List;
  14 import java.util.Timer;
  15 import javax.annotation.Nullable;
  16
  17 import org.apache.thrift.TException;
  18 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  19 import org.opendaylight.netvirt.bgpmanager.api.IBgpManager;
  20 import org.opendaylight.netvirt.bgpmanager.oam.BgpAlarmBroadcaster;
  21 import org.opendaylight.netvirt.bgpmanager.oam.BgpAlarmErrorCodes;
  22 import org.opendaylight.netvirt.bgpmanager.oam.BgpAlarms;
  23 import org.opendaylight.netvirt.bgpmanager.oam.BgpConstants;
  24 import org.opendaylight.netvirt.bgpmanager.oam.BgpCounters;
  25 import org.opendaylight.netvirt.bgpmanager.thrift.gen.af_afi;
  26 import org.opendaylight.netvirt.bgpmanager.thrift.gen.af_safi;
  27 import org.opendaylight.netvirt.fibmanager.api.RouteOrigin;
  28 import org.opendaylight.yang.gen.v1.urn.ericsson.params.xml.ns.yang.ebgp.rev150901.Bgp;
  29 import org.opendaylight.yang.gen.v1.urn.ericsson.params.xml.ns.yang.ebgp.rev150901.LayerType;
  30 import org.opendaylight.yang.gen.v1.urn.ericsson.params.xml.ns.yang.ebgp.rev150901.TcpMd5SignaturePasswordType;
  31 import org.opendaylight.yang.gen.v1.urn.ericsson.params.xml.ns.yang.ebgp.rev150901.bgp.Neighbors;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.vrfentries.VrfEntry;
  33 import org.slf4j.Logger;
  34 import org.slf4j.LoggerFactory;
  35
  36 public class BgpManager implements AutoCloseable, IBgpManager {
  37     private static final Logger LOG = LoggerFactory.getLogger(BgpManager.class);
  38     private final DataBroker dataBroker;
  39     private final BgpConfigurationManager bcm;
  40     private final BgpAlarmBroadcaster qbgpAlarmProducer;
  41     private final FibDSWriter fibDSWriter;
  42     private long qbgprestartTS = 0;
  43     public Timer bgpAlarmsTimer;
  44     public BgpAlarms bgpAlarms;
  45     public BgpCounters bgpCounters;
  46
  47     public BgpManager(final DataBroker dataBroker,
  48             final BgpConfigurationManager bcm,
  49             final BgpAlarmBroadcaster bgpAlarmProducer,
  50             final FibDSWriter fibDSWriter) {
  51         this.dataBroker = dataBroker;
  52         this.bcm = bcm;
  53         this.qbgpAlarmProducer = bgpAlarmProducer;
  54         this.fibDSWriter = fibDSWriter;
  55     }
  56
  57     public void init() {
  58         BgpUtil.setBroker(dataBroker);
  59         ConfigureBgpCli.setBgpManager(this);
  60         LOG.info("{} start", getClass().getSimpleName());
  61     }
  62
  63     @Override
  64     public void close() throws Exception {
  65         LOG.info("{} close", getClass().getSimpleName());
  66     }
  67
  68     public void configureGR(int stalepathTime) throws TException {
  69         bcm.addGracefulRestart(stalepathTime);
  70     }
  71
  72     public void delGracefulRestart() throws Exception {
  73         bcm.delGracefulRestart();
  74     }
  75
  76     public void addNeighbor(String ipAddress, long asNum,
  77             @Nullable final TcpMd5SignaturePasswordType md5Password) throws TException {
  78         bcm.addNeighbor(ipAddress, asNum, md5Password);
  79     }
  80
  81     public void addEbgpMultihop(String ipAddress, int nhops) throws TException {
  82         bcm.addEbgpMultihop(ipAddress, nhops);
  83     }
  84
  85     public void addUpdateSource(String ipAddress, String srcIp) throws TException {
  86         bcm.addUpdateSource(ipAddress, srcIp);
  87     }
  88
  89     public void addAddressFamily(String ipAddress, af_afi afi, af_safi safi) throws TException {
  90         bcm.addAddressFamily(ipAddress, afi.getValue(), safi.getValue());
  91     }
  92
  93     public void deleteNeighbor(String ipAddress) throws TException {
  94         bcm.delNeighbor(ipAddress);
  95     }
  96
  97     @Override
  98     public void addVrf(String rd, Collection<String> importRts, Collection<String> exportRts,
  99                        LayerType layerType) throws Exception {
 100         bcm.addVrf(rd, new ArrayList<>(importRts), new ArrayList<>(exportRts), layerType);
 101     }
 102
 103     @Override
 104     public void deleteVrf(String rd, boolean removeFibTable) {
 105         if (removeFibTable) {
 106             fibDSWriter.removeVrfFromDS(rd);
 107         }
 108         bcm.delVrf(rd);
 109     }
 110
 111     @Override
 112     public void addPrefix(String rd, String macAddress, String prefix, List<String> nextHopList,
 113                           VrfEntry.EncapType encapType, int vpnLabel, long l3vni,
 114                           String gatewayMac, RouteOrigin origin)
 115             throws Exception {
 116         fibDSWriter.addFibEntryToDS(rd, macAddress, prefix, nextHopList,
 117                 encapType, vpnLabel, l3vni, gatewayMac, origin);
 118         bcm.addPrefix(rd, macAddress, prefix, nextHopList,
 119                 encapType, vpnLabel, l3vni, 0 /*l2vni*/, gatewayMac);
 120     }
 121
 122     @Override
 123     public void addPrefix(String rd, String macAddress, String prefix, String nextHop, VrfEntry.EncapType encapType,
 124                           int vpnLabel, long l3vni, String gatewayMac, RouteOrigin origin) throws Exception {
 125         addPrefix(rd, macAddress, prefix, Collections.singletonList(nextHop), encapType, vpnLabel, l3vni,
 126                 gatewayMac, origin);
 127     }
 128
 129     @Override
 130     public void deletePrefix(String rd, String prefix) {
 131         fibDSWriter.removeFibEntryFromDS(rd, prefix);
 132         bcm.delPrefix(rd, prefix);
 133     }
 134
 135     @Override
 136     public void advertisePrefix(String rd, String macAddress, String prefix, List<String> nextHopList,
 137                                 VrfEntry.EncapType encapType, long vpnLabel, long l3vni, long l2vni,
 138                                 String gatewayMac) throws Exception {
 139         bcm.addPrefix(rd, macAddress, prefix, nextHopList,
 140                 encapType, vpnLabel, l3vni, l2vni, gatewayMac);
 141     }
 142
 143     @Override
 144     public void advertisePrefix(String rd, String macAddress, String prefix, String nextHop,
 145                                 VrfEntry.EncapType encapType, long vpnLabel, long l3vni, long l2vni,
 146                                 String gatewayMac) throws Exception {
 147         LOG.info("ADVERTISE: Adding Prefix rd {} prefix {} nexthop {} label {} afi {}",
 148                 rd, prefix, nextHop, vpnLabel);
 149         bcm.addPrefix(rd, macAddress, prefix, Collections.singletonList(nextHop), encapType,
 150                 vpnLabel, l3vni, l2vni, gatewayMac);
 151         LOG.info("ADVERTISE: Added Prefix rd {} prefix {} nexthop {} label {} afi {}",
 152                 rd, prefix, nextHop, vpnLabel);
 153     }
 154
 155     @Override
 156     public void withdrawPrefix(String rd, String prefix) {
 157         LOG.info("WITHDRAW: Removing Prefix rd {} prefix {} afi {}", rd, prefix);
 158         bcm.delPrefix(rd, prefix);
 159         LOG.info("WITHDRAW: Removed Prefix rd {} prefix {} afi {}", rd, prefix);
 160     }
 161
 162     public void setQbgpLog(String fileName, String debugLevel) {
 163         bcm.addLogging(fileName, debugLevel);
 164     }
 165
 166     public void delLogging() {
 167         bcm.delLogging();
 168     }
 169
 170     public void startBgp(long asn, String routerId, int spt, boolean fbit) {
 171         bcm.startBgp(asn, routerId, spt, fbit);
 172     }
 173
 174     public void stopBgp() {
 175         bcm.stopBgp();
 176     }
 177
 178     public void startConfig(String host, int port) {
 179         bcm.startConfig(host, port);
 180     }
 181
 182     public void stopConfig() {
 183         bcm.stopConfig();
 184     }
 185
 186     public Bgp getConfig() {
 187         return bcm.getConfig();
 188     }
 189
 190
 191     public void enableMultipath(af_afi afi, af_safi safi) {
 192         bcm.setMultipathStatus(afi, safi,true);
 193     }
 194
 195     public void disableMultipath(af_afi afi, af_safi safi) {
 196         bcm.setMultipathStatus(afi, safi, false);
 197     }
 198
 199     public void multipaths(String rd, int maxpath) {
 200         bcm.multipaths(rd, maxpath);
 201     }
 202
 203     @Override
 204     public String getDCGwIP() {
 205         Bgp conf = bcm.getConfig();
 206         if (conf == null) {
 207             return null;
 208         }
 209         List<Neighbors> nbrs = conf.getNeighbors();
 210         if (nbrs == null) {
 211             return null;
 212         }
 213         return nbrs.get(0).getAddress().getValue();
 214     }
 215
 216     public synchronized void sendNotificationEvent(String pfx, int code, int subcode) {
 217         BgpAlarmErrorCodes errorSubCode;
 218         if (code != BgpConstants.BGP_NOTIFY_CEASE_CODE) {
 219             // CEASE Notifications alone have to be reported to the CBA.
 220             // Silently return here. No need to log because tons
 221             // of non-alarm notifications will be sent to the SDNc.
 222             return;
 223         }
 224         errorSubCode = BgpAlarmErrorCodes.checkErrorSubcode(subcode);
 225         if (errorSubCode == BgpAlarmErrorCodes.ERROR_IGNORE) {
 226             // Need to report only those subcodes, defined in
 227             // BgpAlarmErrorCodes enum class.
 228             return;
 229         }
 230     }
 231
 232     public FibDSWriter getFibWriter() {
 233         return fibDSWriter;
 234     }
 235
 236     public String getConfigHost() {
 237         return BgpConfigurationManager.getConfigHost();
 238     }
 239
 240     public int getConfigPort() {
 241         return BgpConfigurationManager.getConfigPort();
 242     }
 243
 244
 245     public void bgpRestarted() {
 246         bcm.bgpRestarted();
 247     }
 248
 249     public BgpManager getBgpManager() {
 250         return this;
 251     }
 252
 253     public boolean isBgpConnected() {
 254         return bcm.isBgpConnected();
 255     }
 256
 257     public long getLastConnectedTS() {
 258         return bcm.getLastConnectedTS();
 259     }
 260
 261     public long getConnectTS() {
 262         return bcm.getConnectTS();
 263     }
 264
 265     public long getStartTS() {
 266         return bcm.getStartTS();
 267     }
 268
 269     public long getQbgprestartTS() {
 270         return qbgprestartTS;
 271     }
 272
 273     public void setQbgprestartTS(long qbgprestartTS) {
 274         this.qbgprestartTS = qbgprestartTS;
 275     }
 276
 277     public long getStaleStartTime() {
 278         return bcm.getStaleStartTime();
 279     }
 280
 281     public long getStaleEndTime() {
 282         return bcm.getStaleEndTime();
 283     }
 284
 285     public long getCfgReplayStartTime() {
 286         return bcm.getCfgReplayStartTime();
 287     }
 288
 289     public long getCfgReplayEndTime() {
 290         return bcm.getCfgReplayEndTime();
 291     }
 292
 293     public long getStaleCleanupTime() {
 294         return bcm.getStaleCleanupTime();
 295     }
 296
 297
 298 }