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