Remove redundant names in paths

[netvirt.git] / dhcpservice / impl / src / main / java / org / opendaylight / netvirt / dhcpservice / jobs / DhcpInterfaceUpdateJob.java

diff --git a/dhcpservice/impl/src/main/java/org/opendaylight/netvirt/dhcpservice/jobs/DhcpInterfaceUpdateJob.java b/dhcpservice/impl/src/main/java/org/opendaylight/netvirt/dhcpservice/jobs/DhcpInterfaceUpdateJob.java
new file mode 100644 (file)
index 0000000..e5c81ec
--- /dev/null
+++ b/dhcpservice/impl/src/main/java/org/opendaylight/netvirt/dhcpservice/jobs/DhcpInterfaceUpdateJob.java
@@ -0,0 +1,71 @@
+/*
+ * 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.netvirt.dhcpservice.jobs;
+
+import com.google.common.util.concurrent.ListenableFuture;
+import java.math.BigInteger;
+import java.util.Collections;
+import java.util.List;
+import java.util.concurrent.Callable;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.genius.interfacemanager.interfaces.IInterfaceManager;
+import org.opendaylight.netvirt.dhcpservice.DhcpExternalTunnelManager;
+import org.opendaylight.netvirt.dhcpservice.DhcpServiceUtils;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev140508.Tunnel;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.OperStatus;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfTunnel;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class DhcpInterfaceUpdateJob implements Callable<List<ListenableFuture<Void>>> {
+
+    private static final Logger LOG = LoggerFactory.getLogger(DhcpInterfaceUpdateJob.class);
+    private final DhcpExternalTunnelManager dhcpExternalTunnelManager;
+    private final DataBroker dataBroker;
+    private final String interfaceName;
+    private final BigInteger dpnId;
+    private final OperStatus operStatus;
+    private final IInterfaceManager interfaceManager;
+
+    public DhcpInterfaceUpdateJob(DhcpExternalTunnelManager dhcpExternalTunnelManager,
+                                  DataBroker dataBroker, String interfaceName, BigInteger dpnId,
+                                  OperStatus operStatus, IInterfaceManager interfaceManager) {
+        this.dhcpExternalTunnelManager = dhcpExternalTunnelManager;
+        this.dataBroker = dataBroker;
+        this.interfaceName = interfaceName;
+        this.dpnId = dpnId;
+        this.operStatus = operStatus;
+        this.interfaceManager = interfaceManager;
+    }
+
+    @Override
+    public List<ListenableFuture<Void>> call() throws Exception {
+        org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface iface =
+                interfaceManager.getInterfaceInfoFromConfigDataStore(interfaceName);
+        if (iface == null) {
+            LOG.trace("Interface {} is not present in the config DS", interfaceName);
+            return Collections.emptyList();
+        }
+        if (Tunnel.class.equals(iface.getType())) {
+            IfTunnel tunnelInterface = iface.getAugmentation(IfTunnel.class);
+            if (tunnelInterface != null && !tunnelInterface.isInternal()) {
+                IpAddress tunnelIp = tunnelInterface.getTunnelDestination();
+                List<BigInteger> dpns = DhcpServiceUtils.getListOfDpns(dataBroker);
+                if (dpns.contains(dpnId)) {
+                    if (operStatus == OperStatus.Down) {
+                        return dhcpExternalTunnelManager.handleTunnelStateDown(tunnelIp, dpnId);
+                    } else if (operStatus == OperStatus.Up) {
+                        return dhcpExternalTunnelManager.handleTunnelStateUp(tunnelIp, dpnId);
+                    }
+                }
+            }
+        }
+        return Collections.emptyList();
+    }
+}
\ No newline at end of file