vpnmanager/impl/src/main/java/org/opendaylight/netvirt/vpnmanager/populator/impl/L3vpnOverVxlanPopulator.java

   1 /*
   2  * Copyright (c) 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.vpnmanager.populator.impl;
   9
  10 import java.util.Collections;
  11 import java.util.List;
  12 import java.util.Objects;
  13 import javax.annotation.PostConstruct;
  14 import javax.annotation.PreDestroy;
  15 import javax.inject.Inject;
  16 import javax.inject.Singleton;
  17 import org.opendaylight.genius.infra.Datastore.Configuration;
  18 import org.opendaylight.genius.infra.TypedWriteTransaction;
  19 import org.opendaylight.mdsal.binding.api.DataBroker;
  20 import org.opendaylight.netvirt.bgpmanager.api.IBgpManager;
  21 import org.opendaylight.netvirt.fibmanager.api.IFibManager;
  22 import org.opendaylight.netvirt.fibmanager.api.RouteOrigin;
  23 import org.opendaylight.netvirt.vpnmanager.VpnUtil;
  24 import org.opendaylight.netvirt.vpnmanager.populator.input.L3vpnInput;
  25 import org.opendaylight.netvirt.vpnmanager.populator.registry.L3vpnRegistry;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.fibmanager.rev150330.vrfentries.VrfEntry;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.adjacency.list.Adjacency;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.adjacency.list.AdjacencyBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.adjacency.list.AdjacencyKey;
  30 import org.opendaylight.yangtools.yang.common.Uint32;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33
  34 @Singleton
  35 public class L3vpnOverVxlanPopulator extends L3vpnPopulator {
  36     private static final Logger LOG = LoggerFactory.getLogger(L3vpnOverVxlanPopulator.class);
  37
  38     @Inject
  39     public L3vpnOverVxlanPopulator(DataBroker dataBroker, IBgpManager bgpManager, IFibManager fibManager,
  40                                    VpnUtil vpnUtil) {
  41         super(dataBroker, bgpManager, fibManager, vpnUtil);
  42     }
  43
  44     @PostConstruct
  45     public void init() {
  46         LOG.info("{} start", getClass().getSimpleName());
  47         L3vpnRegistry.registerL3vpnPopulator(VrfEntry.EncapType.Vxlan, this);
  48     }
  49
  50     @PreDestroy
  51     public void close() {
  52         LOG.trace("L3vpnOverVxlanPopulator Closed");
  53     }
  54
  55     @Override
  56     public void populateFib(L3vpnInput input, TypedWriteTransaction<Configuration> writeConfigTxn) {
  57         if (input.getRouteOrigin() == RouteOrigin.CONNECTED) {
  58             LOG.info("populateFib : Found SubnetRoute for subnet {} rd {}", input.getSubnetIp(), input.getPrimaryRd());
  59             addSubnetRouteFibEntry(input);
  60             return;
  61         }
  62         String rd = input.getRd();
  63         String primaryRd = input.getPrimaryRd();
  64         Adjacency nextHop = input.getNextHop();
  65         LOG.info("populateFib : Found Interface Adjacency with prefix {} rd {}", nextHop.getIpAddress(), primaryRd);
  66         if (!rd.equalsIgnoreCase(input.getVpnName()) && !rd.equals(input.getNetworkName())) {
  67             Objects.requireNonNull(input.getRouteOrigin(), "populateFib: RouteOrigin is mandatory");
  68             addPrefixToBGP(rd, primaryRd, nextHop.getMacAddress(), nextHop.getIpAddress(), input.getNextHopIp(),
  69                     input.getEncapType(), Uint32.ZERO /*label*/, Uint32.valueOf(input.getL3vni()),
  70                     input.getGatewayMac(), input.getRouteOrigin(), writeConfigTxn);
  71         } else {
  72             LOG.error("Internal VPN for L3 Over VxLAN is not supported. Aborting.");
  73             return;
  74         }
  75     }
  76
  77     @Override
  78     public Adjacency createOperationalAdjacency(L3vpnInput input) {
  79         Adjacency nextHop = input.getNextHop();
  80         String nextHopIp = input.getNextHopIp();
  81         String rd = input.getRd();
  82         String prefix = VpnUtil.getIpPrefix(nextHop.getIpAddress());
  83         List<String> adjNextHop = nextHop.getNextHopIpList();
  84         List<String> nextHopList = adjNextHop != null && !adjNextHop.isEmpty() ? adjNextHop
  85                 : nextHopIp == null ? Collections.emptyList() : Collections.singletonList(nextHopIp);
  86
  87         return new AdjacencyBuilder(nextHop).setNextHopIpList(nextHopList).setIpAddress(prefix).setVrfId(rd)
  88                 .withKey(new AdjacencyKey(prefix)).setAdjacencyType(nextHop.getAdjacencyType())
  89                 .setSubnetGatewayMacAddress(nextHop.getSubnetGatewayMacAddress()).build();
  90     }
  91 }