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