Updated L2Gw changes in "neutronvpn", "elanmanager" and "dhcpservice" modules

[vpnservice.git] / elanmanager / elanmanager-impl / src / main / java / org / opendaylight / vpnservice / elan / l2gw / jobs / DeleteL2GwDeviceMacsFromElanJob.java

diff --git a/elanmanager/elanmanager-impl/src/main/java/org/opendaylight/vpnservice/elan/l2gw/jobs/DeleteL2GwDeviceMacsFromElanJob.java b/elanmanager/elanmanager-impl/src/main/java/org/opendaylight/vpnservice/elan/l2gw/jobs/DeleteL2GwDeviceMacsFromElanJob.java
new file mode 100644 (file)
index 0000000..96170f6
--- /dev/null
+++ b/elanmanager/elanmanager-impl/src/main/java/org/opendaylight/vpnservice/elan/l2gw/jobs/DeleteL2GwDeviceMacsFromElanJob.java
@@ -0,0 +1,118 @@
+/*
+ * 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.l2gw.jobs;
+
+import java.util.List;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ConcurrentMap;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.elanmanager.utils.ElanL2GwCacheUtils;
+import org.opendaylight.vpnservice.elan.l2gw.utils.ElanL2GatewayUtils;
+import org.opendaylight.vpnservice.neutronvpn.api.l2gw.L2GatewayDevice;
+import org.opendaylight.vpnservice.utils.hwvtep.HwvtepUtils;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.MacAddress;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.google.common.collect.Lists;
+import com.google.common.util.concurrent.FutureCallback;
+import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.ListenableFuture;
+
+/**
+ * The Job class to delete L2 gateway device local ucast macs from other Elan L2
+ * gateway devices.
+ */
+public class DeleteL2GwDeviceMacsFromElanJob implements Callable<List<ListenableFuture<Void>>> {
+
+    /** The Constant JOB_KEY_PREFIX. */
+    private static final String JOB_KEY_PREFIX = "hwvtep:";
+
+    /** The Constant LOG. */
+    private static final Logger LOG = LoggerFactory.getLogger(DeleteL2GwDeviceMacsFromElanJob.class);
+
+    /** The broker. */
+    private final DataBroker broker;
+
+    /** The elan name. */
+    private final String elanName;
+
+    /** The l2 gw device. */
+    private final L2GatewayDevice l2GwDevice;
+
+    /** The mac addresses. */
+    private final List<MacAddress> macAddresses;
+
+    /**
+     * Instantiates a new delete l2 gw device macs from elan job.
+     *
+     * @param broker
+     *            the broker
+     * @param elanName
+     *            the elan name
+     * @param l2GwDevice
+     *            the l2 gw device
+     * @param macAddresses
+     *            the mac addresses
+     */
+    public DeleteL2GwDeviceMacsFromElanJob(DataBroker broker, String elanName, L2GatewayDevice l2GwDevice,
+            List<MacAddress> macAddresses) {
+        this.broker = broker;
+        this.elanName = elanName;
+        this.l2GwDevice = l2GwDevice;
+        this.macAddresses = macAddresses;
+    }
+
+    public String getJobKey() {
+        return JOB_KEY_PREFIX + this.elanName;
+    }
+
+    /*
+     * (non-Javadoc)
+     *
+     * @see java.util.concurrent.Callable#call()
+     */
+    @Override
+    public List<ListenableFuture<Void>> call() {
+        LOG.debug("Deleting l2gw device [{}] macs from other l2gw devices for elan [{}]",
+                this.l2GwDevice.getHwvtepNodeId(), this.elanName);
+        final String logicalSwitchName = ElanL2GatewayUtils.getLogicalSwitchFromElan(this.elanName);
+
+        ConcurrentMap<String, L2GatewayDevice> elanL2GwDevices = ElanL2GwCacheUtils
+                .getInvolvedL2GwDevices(this.elanName);
+        List<ListenableFuture<Void>> futures = Lists.newArrayList();
+        for (L2GatewayDevice otherDevice : elanL2GwDevices.values()) {
+            if (!otherDevice.getHwvtepNodeId().equals(this.l2GwDevice.getHwvtepNodeId())
+                    && !ElanL2GatewayUtils.areMLAGDevices(this.l2GwDevice, otherDevice)) {
+                final String hwvtepId = otherDevice.getHwvtepNodeId();
+                // never batch deletes
+                ListenableFuture<Void> uninstallFuture = HwvtepUtils.deleteRemoteUcastMacs(this.broker,
+                        new NodeId(hwvtepId), logicalSwitchName, this.macAddresses);
+                Futures.addCallback(uninstallFuture, new FutureCallback<Void>() {
+                    @Override
+                    public void onSuccess(Void noarg) {
+                        LOG.trace("Successful in initiating ucast_remote_macs deletion related to {} in {}",
+                                logicalSwitchName, hwvtepId);
+                    }
+
+                    @Override
+                    public void onFailure(Throwable error) {
+                        LOG.error(String.format("Failed removing ucast_remote_macs related to %s in %s",
+                                logicalSwitchName, hwvtepId), error);
+                    }
+                });
+                // TODO: why to create a new arraylist for uninstallFuture?
+                futures.addAll(Lists.newArrayList(uninstallFuture));
+            }
+        }
+        return futures;
+    }
+}