vpnservice/elanmanager/elanmanager-impl/src/main/java/org/opendaylight/vpnservice/elan/l2gw/internal/ElanL2GatewayProvider.java

   1 /*
   2  * Copyright (c) 2016 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
   9 package org.opendaylight.vpnservice.elan.l2gw.internal;
  10
  11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  12 import org.opendaylight.controller.md.sal.common.api.clustering.CandidateAlreadyRegisteredException;
  13 import org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService;
  14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  15 import org.opendaylight.elanmanager.utils.ElanL2GwCacheUtils;
  16 import org.opendaylight.vpnservice.datastoreutils.DataStoreJobCoordinator;
  17 import org.opendaylight.vpnservice.elan.internal.ElanInstanceManager;
  18 import org.opendaylight.vpnservice.elan.internal.ElanInterfaceManager;
  19 import org.opendaylight.vpnservice.elan.internal.ElanServiceProvider;
  20 import org.opendaylight.vpnservice.elan.l2gw.listeners.HwvtepLocalUcastMacListener;
  21 import org.opendaylight.vpnservice.elan.l2gw.listeners.HwvtepLogicalSwitchListener;
  22 import org.opendaylight.vpnservice.elan.l2gw.listeners.HwvtepNodeListener;
  23 import org.opendaylight.vpnservice.elan.l2gw.listeners.HwvtepPhysicalLocatorListener;
  24 import org.opendaylight.vpnservice.elan.l2gw.listeners.HwvtepRemoteMcastMacListener;
  25 import org.opendaylight.vpnservice.elan.l2gw.listeners.L2GatewayConnectionListener;
  26 import org.opendaylight.vpnservice.elan.l2gw.utils.ElanL2GatewayMulticastUtils;
  27 import org.opendaylight.vpnservice.elan.l2gw.utils.ElanL2GatewayUtils;
  28 import org.opendaylight.vpnservice.elan.l2gw.utils.L2GatewayConnectionUtils;
  29 import org.opendaylight.vpnservice.utils.clustering.EntityOwnerUtils;
  30 import org.opendaylight.vpnservice.utils.hwvtep.HwvtepSouthboundConstants;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.itm.rpcs.rev151217.ItmRpcService;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34
  35 /**
  36  * Elan L2 Gateway provider class.
  37  */
  38 public class ElanL2GatewayProvider implements AutoCloseable {
  39
  40     private static final Logger LOG = LoggerFactory.getLogger(ElanL2GatewayProvider.class);
  41
  42     private DataBroker broker;
  43     private EntityOwnershipService entityOwnershipService;
  44     private ItmRpcService itmRpcService;
  45     private ElanInstanceManager elanInstanceManager;
  46     private ElanInterfaceManager elanInterfaceManager;
  47
  48     private L2GatewayConnectionListener l2GwConnListener;
  49     private HwvtepNodeListener hwvtepNodeListener;
  50     private HwvtepLocalUcastMacListener torMacsListener;
  51     private HwvtepPhysicalLocatorListener physicalLocatorListener;
  52
  53     static DataStoreJobCoordinator dataStoreJobCoordinator;
  54
  55     /**
  56      * Instantiates a new elan l2 gateway provider.
  57      *
  58      * @param elanServiceProvider
  59      *            the elan service provider
  60      */
  61     public ElanL2GatewayProvider(ElanServiceProvider elanServiceProvider) {
  62         this.broker = elanServiceProvider.getBroker();
  63         this.entityOwnershipService = elanServiceProvider.getEntityOwnershipService();
  64         this.itmRpcService = elanServiceProvider.getItmRpcService();
  65         this.elanInstanceManager = elanServiceProvider.getElanInstanceManager();
  66         this.elanInterfaceManager = elanServiceProvider.getElanInterfaceManager();
  67         dataStoreJobCoordinator = elanServiceProvider.getDataStoreJobCoordinator();
  68         init();
  69
  70         LOG.info("ElanL2GatewayProvider Initialized");
  71     }
  72
  73     /**
  74      * Initialize Elan L2 Gateway.
  75      */
  76     private void init() {
  77         ElanL2GwCacheUtils.createElanL2GwDeviceCache();
  78         ElanL2GatewayUtils.setDataBroker(broker);
  79         ElanL2GatewayUtils.setItmRpcService(itmRpcService);
  80         ElanL2GatewayUtils.setDataStoreJobCoordinator(dataStoreJobCoordinator);
  81
  82         ElanL2GatewayMulticastUtils.setBroker(broker);
  83         ElanL2GatewayMulticastUtils.setElanInstanceManager(elanInstanceManager);
  84         ElanL2GatewayMulticastUtils.setElanInterfaceManager(elanInterfaceManager);
  85         ElanL2GatewayMulticastUtils.setDataStoreJobCoordinator(dataStoreJobCoordinator);
  86
  87         L2GatewayConnectionUtils.setElanInstanceManager(elanInstanceManager);
  88         L2GatewayConnectionUtils.setBroker(broker);
  89         L2GatewayConnectionUtils.setDataStoreJobCoordinator(dataStoreJobCoordinator);
  90
  91         HwvtepRemoteMcastMacListener.setDataStoreJobCoordinator(dataStoreJobCoordinator);
  92         HwvtepLogicalSwitchListener.setDataStoreJobCoordinator(dataStoreJobCoordinator);
  93
  94         this.torMacsListener = new HwvtepLocalUcastMacListener(broker);
  95         this.l2GwConnListener = new L2GatewayConnectionListener(broker, elanInstanceManager);
  96         this.hwvtepNodeListener = new HwvtepNodeListener(broker, elanInstanceManager, itmRpcService);
  97         this.hwvtepNodeListener.registerListener(LogicalDatastoreType.OPERATIONAL, broker);
  98
  99         physicalLocatorListener = new HwvtepPhysicalLocatorListener(broker);
 100         try {
 101             EntityOwnerUtils.registerEntityCandidateForOwnerShip(entityOwnershipService,
 102                     HwvtepSouthboundConstants.ELAN_ENTITY_TYPE, HwvtepSouthboundConstants.ELAN_ENTITY_TYPE,
 103                     null/*listener*/);
 104         } catch (CandidateAlreadyRegisteredException e) {
 105             LOG.error("failed to register the entity");
 106         }
 107     }
 108
 109     /*
 110      * (non-Javadoc)
 111      *
 112      * @see java.lang.AutoCloseable#close()
 113      */
 114     @Override
 115     public void close() throws Exception {
 116         this.torMacsListener.close();
 117         this.l2GwConnListener.close();
 118         this.hwvtepNodeListener.close();
 119         LOG.info("ElanL2GatewayProvider Closed");
 120     }
 121 }