natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/SnatServiceImplFactory.java

   1 /*
   2  * Copyright (c) 2017 Red Hat, Inc. 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.natservice.internal;
   9
  10 import javax.inject.Inject;
  11 import javax.inject.Singleton;
  12 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  13 import org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar;
  14 import org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager;
  15 import org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager;
  16 import org.opendaylight.infrautils.inject.AbstractLifecycle;
  17 import org.opendaylight.netvirt.elanmanager.api.IElanService;
  18 import org.opendaylight.netvirt.fibmanager.api.IFibManager;
  19 import org.opendaylight.netvirt.natservice.ha.NatDataUtil;
  20 import org.opendaylight.netvirt.neutronvpn.interfaces.INeutronVpnManager;
  21 import org.opendaylight.netvirt.vpnmanager.api.IVpnFootprintService;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rpcs.rev160406.ItmRpcService;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.config.rev170206.NatserviceConfig;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.config.rev170206.NatserviceConfig.NatMode;
  27 import org.slf4j.Logger;
  28 import org.slf4j.LoggerFactory;
  29
  30 @Singleton
  31 public class SnatServiceImplFactory extends AbstractLifecycle {
  32
  33     private static final Logger LOG = LoggerFactory.getLogger(SnatServiceImplFactory.class);
  34
  35     private final DataBroker dataBroker;
  36     private final IMdsalApiManager mdsalManager;
  37     private final ItmRpcService itmManager;
  38     private final OdlInterfaceRpcService odlInterfaceRpcService;
  39     private final IdManagerService idManager;
  40     private final NAPTSwitchSelector naptSwitchSelector;
  41     private final NatMode natMode;
  42     private final INeutronVpnManager nvpnManager;
  43     private final ExternalRoutersListener externalRouterListener;
  44     private final IElanService elanManager;
  45     private final IInterfaceManager interfaceManager;
  46     private final IVpnFootprintService vpnFootprintService;
  47     private final IFibManager fibManager;
  48     private final NatDataUtil natDataUtil;
  49     private final DataTreeEventCallbackRegistrar eventCallbacks;
  50
  51     @Inject
  52     public SnatServiceImplFactory(final DataBroker dataBroker, final IMdsalApiManager mdsalManager,
  53                                   final ItmRpcService itmManager,
  54                                   final OdlInterfaceRpcService odlInterfaceRpcService,
  55                                   final IdManagerService idManager,
  56                                   final NAPTSwitchSelector naptSwitchSelector,
  57                                   final NatserviceConfig config,
  58                                   final INeutronVpnManager nvpnManager,
  59                                   final ExternalRoutersListener externalRouterListener,
  60                                   final IElanService elanManager,
  61                                   final IInterfaceManager interfaceManager,
  62                                   final IVpnFootprintService vpnFootprintService,
  63                                   final IFibManager fibManager,
  64                                   final NatDataUtil natDataUtil,
  65                                   final DataTreeEventCallbackRegistrar eventCallbacks) {
  66         this.dataBroker = dataBroker;
  67         this.mdsalManager = mdsalManager;
  68         this.itmManager = itmManager;
  69         this.odlInterfaceRpcService = odlInterfaceRpcService;
  70         this.idManager = idManager;
  71         this.naptSwitchSelector = naptSwitchSelector;
  72         if (config != null) {
  73             this.natMode = config.getNatMode();
  74         } else {
  75             this.natMode = null;
  76         }
  77         this.nvpnManager = nvpnManager;
  78         this.externalRouterListener = externalRouterListener;
  79         this.elanManager = elanManager;
  80         this.interfaceManager = interfaceManager;
  81         this.vpnFootprintService = vpnFootprintService;
  82         this.fibManager = fibManager;
  83         this.natDataUtil = natDataUtil;
  84         this.eventCallbacks = eventCallbacks;
  85     }
  86
  87     @Override
  88     protected void start() {
  89         LOG.info("{} start", getClass().getSimpleName());
  90     }
  91
  92     @Override
  93     protected void stop() {
  94         LOG.info("{} close", getClass().getSimpleName());
  95     }
  96
  97     public AbstractSnatService createFlatVlanSnatServiceImpl() {
  98
  99         if (natMode == NatMode.Conntrack) {
 100             return new FlatVlanConntrackBasedSnatService(dataBroker, mdsalManager, itmManager, odlInterfaceRpcService,
 101                     idManager, naptSwitchSelector, interfaceManager, vpnFootprintService, fibManager,  natDataUtil,
 102                     eventCallbacks);
 103         }
 104         return null;
 105     }
 106
 107     public AbstractSnatService createVxlanGreSnatServiceImpl() {
 108
 109         if (natMode == NatMode.Conntrack) {
 110             NatOverVxlanUtil.validateAndCreateVxlanVniPool(dataBroker, nvpnManager, idManager,
 111                     NatConstants.ODL_VNI_POOL_NAME);
 112             return new VxlanGreConntrackBasedSnatService(dataBroker, mdsalManager, itmManager, odlInterfaceRpcService,
 113                     idManager, naptSwitchSelector, externalRouterListener, elanManager, interfaceManager,
 114                     vpnFootprintService, fibManager, natDataUtil, eventCallbacks);
 115         }
 116         return null;
 117     }
 118
 119
 120 }