ELAN FT Support for BE

[vpnservice.git] / elanmanager / elanmanager-impl / src / main / java / org / opendaylight / vpnservice / elan / internal / ElanInstanceManager.java

diff --git a/elanmanager/elanmanager-impl/src/main/java/org/opendaylight/vpnservice/elan/internal/ElanInstanceManager.java b/elanmanager/elanmanager-impl/src/main/java/org/opendaylight/vpnservice/elan/internal/ElanInstanceManager.java
new file mode 100644 (file)
index 0000000..d1aca50
--- /dev/null
+++ b/elanmanager/elanmanager-impl/src/main/java/org/opendaylight/vpnservice/elan/internal/ElanInstanceManager.java
@@ -0,0 +1,162 @@
+/*
+ * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+package org.opendaylight.vpnservice.elan.internal;
+
+import com.google.common.base.Optional;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
+import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.vpnservice.mdsalutil.AbstractDataChangeListener;
+import org.opendaylight.vpnservice.elan.utils.ElanConstants;
+import org.opendaylight.vpnservice.elan.utils.ElanUtils;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.ElanDpnInterfaces;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.ElanInstances;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.elan.dpn.interfaces.ElanDpnInterfacesList;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.elan.dpn.interfaces.ElanDpnInterfacesListKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.elan.dpn.interfaces.elan.dpn.interfaces.list.DpnInterfaces;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.elan.instances.ElanInstance;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.elan.instances.ElanInstanceKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.elan.interfaces.ElanInterface;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.elan.rev150602.elan.state.Elan;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdManagerService;
+import org.opendaylight.yangtools.concepts.ListenerRegistration;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+
+public class ElanInstanceManager extends AbstractDataChangeListener<ElanInstance> implements AutoCloseable {
+    private DataBroker broker;
+    private static ElanInstanceManager elanInstanceManager = new ElanInstanceManager();
+    private ListenerRegistration<DataChangeListener> elanInstanceListenerRegistration;
+    private IdManagerService idManager;
+    private ElanInterfaceManager elanInterfaceManager;
+
+    private static final Logger logger = LoggerFactory.getLogger(ElanInstanceManager.class);
+
+    private ElanInstanceManager() {
+        super(ElanInstance.class);
+
+    }
+
+    public static ElanInstanceManager getElanInstanceManager() {
+        return elanInstanceManager;
+    }
+
+    public void setIdManager(IdManagerService idManager) {
+        this.idManager = idManager;
+    }
+
+    public void setDataBroker(DataBroker broker) {
+        this.broker = broker;
+    }
+
+    public void setElanInterfaceManager(ElanInterfaceManager elanInterfaceManager) {
+        this.elanInterfaceManager = elanInterfaceManager;
+    }
+
+
+    public void registerListener() {
+        try {
+            elanInstanceListenerRegistration = broker.registerDataChangeListener(LogicalDatastoreType.CONFIGURATION,
+                    getElanInstanceWildcardPath(), ElanInstanceManager.this, DataChangeScope.SUBTREE);
+        } catch (final Exception e) {
+            logger.error("ELAN Instance DataChange listener registration failed !", e);
+            throw new IllegalStateException("ELAN Instance registration Listener failed.", e);
+        }
+    }
+
+    private InstanceIdentifier<?> getElanInstanceWildcardPath() {
+        return InstanceIdentifier.create(ElanInstances.class).child(ElanInstance.class);
+    }
+
+    @Override
+    public void close() throws Exception {
+        if (elanInstanceListenerRegistration != null) {
+            elanInstanceListenerRegistration.close();
+        }
+    }
+
+    @Override
+    protected void remove(InstanceIdentifier<ElanInstance> identifier, ElanInstance del) {
+        logger.trace("Remove ElanInstance - Key: {}, value: {}", identifier, del);
+        String elanName = del.getElanInstanceName();
+        //check the elan Instance present in the Operational DataStore
+        Elan existingElan = ElanUtils.getElanByName(elanName);
+        long elanTag = del.getElanTag();
+        //Cleaning up the existing Elan Instance
+        if(existingElan != null) {
+            List<String> elanInterfaces =  existingElan.getElanInterfaces();
+            if(elanInterfaces != null && !elanInterfaces.isEmpty()) {
+                for (String elanInterfaceName : elanInterfaces) {
+                    InstanceIdentifier<ElanInterface> elanInterfaceId = ElanUtils.getElanInterfaceConfigurationDataPathId(elanInterfaceName);
+                    elanInterfaceManager.removeElanInterface(del, elanInterfaceName);
+                    ElanUtils.delete(broker, LogicalDatastoreType.CONFIGURATION, elanInterfaceId);
+                }
+            }
+            ElanUtils.delete(broker, LogicalDatastoreType.OPERATIONAL, ElanUtils.getElanInstanceOperationalDataPath(elanName));
+            ElanUtils.delete(broker, LogicalDatastoreType.OPERATIONAL, getElanDpnOperationDataPath(elanName));
+            ElanUtils.delete(broker, LogicalDatastoreType.OPERATIONAL, ElanUtils.getElanInfoEntriesOperationalDataPath(elanTag));
+        }
+        // Release tag
+        ElanUtils.releaseId(idManager, ElanConstants.ELAN_ID_POOL_NAME, elanName);
+
+    }
+
+    @Override
+    protected void update(InstanceIdentifier<ElanInstance> identifier, ElanInstance original, ElanInstance update) {
+        if (original.getElanTag() == update.getElanTag()) {
+            return;
+        } else if (update.getElanTag() == null) {
+            // update the elan-Instance with new properties
+            if(original.getMacTimeout() == update.getMacTimeout() && original.getDescription().equalsIgnoreCase(update.getDescription())) {
+               return;
+            }
+            ElanUtils.UpdateOperationalDataStore(broker, idManager, update);
+            return;
+        }
+        elanInterfaceManager.handleunprocessedElanInterfaces(update);
+    }
+
+    @Override
+    protected void add(InstanceIdentifier<ElanInstance> identifier, ElanInstance elanInstanceAdded) {
+        Elan elanInfo = ElanUtils.getElanByName(elanInstanceAdded.getElanInstanceName());
+        if(elanInfo == null) {
+            ElanUtils.UpdateOperationalDataStore(broker, idManager, elanInstanceAdded);
+        }
+    }
+
+    public ElanInstance getElanInstanceByName(String elanInstanceName) {
+        InstanceIdentifier<ElanInstance> elanIdentifierId = getElanInstanceConfigurationDataPath(elanInstanceName);
+        Optional<ElanInstance> elanInstance = ElanUtils.read(broker, LogicalDatastoreType.CONFIGURATION, elanIdentifierId);
+        if(elanInstance.isPresent()) {
+            return elanInstance.get();
+        }
+        return null;
+    }
+
+    public List<DpnInterfaces> getElanDPNByName(String elanInstanceName) {
+        InstanceIdentifier<ElanDpnInterfacesList> elanIdentifier = getElanDpnOperationDataPath(elanInstanceName);
+        Optional<ElanDpnInterfacesList> elanInstance = ElanUtils.read(broker, LogicalDatastoreType.OPERATIONAL, elanIdentifier);
+        if(elanInstance.isPresent()) {
+            ElanDpnInterfacesList elanDPNs =  elanInstance.get();
+            return elanDPNs.getDpnInterfaces();
+        }
+        return null;
+    }
+
+    private InstanceIdentifier<ElanDpnInterfacesList> getElanDpnOperationDataPath(String elanInstanceName) {
+        return InstanceIdentifier.builder(ElanDpnInterfaces.class).child(ElanDpnInterfacesList.class, new ElanDpnInterfacesListKey(elanInstanceName)).build();
+    }
+
+    private InstanceIdentifier<ElanInstance> getElanInstanceConfigurationDataPath(String elanInstanceName) {
+        return InstanceIdentifier.builder(ElanInstances.class).child(ElanInstance.class, new ElanInstanceKey(elanInstanceName)).build();
+    }
+}