2 * Copyright (c) 2018 Ericsson India Global Services Pvt Ltd. and others. All rights reserved.
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
9 package org.opendaylight.genius.itm.itmdirecttunnels.listeners;
11 import com.google.common.util.concurrent.ListenableFuture;
12 import java.util.Collections;
13 import java.util.List;
14 import java.util.concurrent.Callable;
15 import org.eclipse.jdt.annotation.NonNull;
16 import org.opendaylight.genius.itm.globals.ITMConstants;
17 import org.opendaylight.genius.itm.impl.ITMBatchingUtils;
18 import org.opendaylight.infrautils.jobcoordinator.JobCoordinator;
19 import org.opendaylight.mdsal.binding.api.DataBroker;
20 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
21 import org.opendaylight.serviceutils.tools.listener.AbstractSyncDataTreeChangeListener;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnel.list.InternalTunnel;
23 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
28 * This class listens for Internal Tunnel in Configuration DS.
29 * This deletes the entries incase of upgrade from non-ItmDirectTunnel way to ItmDirectTunnel.
32 public class InternalTunnelListener extends AbstractSyncDataTreeChangeListener<InternalTunnel> {
33 private static final Logger LOG = LoggerFactory.getLogger(InternalTunnelListener.class);
35 private final DataBroker dataBroker;
36 private final JobCoordinator coordinator;
38 public InternalTunnelListener(final DataBroker dataBroker, final JobCoordinator coordinator) {
39 super(dataBroker, LogicalDatastoreType.CONFIGURATION,
40 InstanceIdentifier.create(InternalTunnel.class));
41 this.dataBroker = dataBroker;
42 this.coordinator = coordinator;
46 public void remove(@NonNull InstanceIdentifier<InternalTunnel> key, @NonNull InternalTunnel interfaceOld) {
47 LOG.debug("REMOVE hit in InternalTunnelListenerITM");
51 public void update(@NonNull InstanceIdentifier<InternalTunnel> key, @NonNull InternalTunnel internalTunnelOld,
52 @NonNull InternalTunnel internalTunnelNew) {
53 LOG.debug("UPDATE hit in InternalTunnelListenerITM");
57 public void add(@NonNull InstanceIdentifier<InternalTunnel> key, @NonNull InternalTunnel internalTunnel) {
58 LOG.debug("ADD of Interface {} received in InternalTunnelListenerITM", internalTunnel);
59 RendererInternalTunnelDeleteWorker configWorker = new RendererInternalTunnelDeleteWorker(key, internalTunnel);
60 coordinator.enqueueJob(getKeyForEnqueuing(internalTunnel), configWorker, ITMConstants.JOB_MAX_RETRIES);
63 private String getKeyForEnqueuing(InternalTunnel internalTunnel) {
64 return "tun" + internalTunnel.getSourceDPN() + internalTunnel.getDestinationDPN();
67 private static class RendererInternalTunnelDeleteWorker implements Callable<List<? extends ListenableFuture<?>>> {
68 final InstanceIdentifier<InternalTunnel> key;
69 final InternalTunnel internalTunnel;
71 RendererInternalTunnelDeleteWorker(InstanceIdentifier<InternalTunnel> key,
72 InternalTunnel internalTunnelNew) {
74 this.internalTunnel = internalTunnelNew;
78 public List<ListenableFuture<Void>> call() throws Exception {
79 LOG.debug("Deleting Internal Tunnel Config for src Dpn {}, Dst Dpn {} as ITM direct tunnel is enabled",
80 internalTunnel.getSourceDPN(), internalTunnel.getDestinationDPN());
81 ITMBatchingUtils.delete(key, ITMBatchingUtils.EntityType.DEFAULT_CONFIG);
82 return Collections.emptyList();
86 public String toString() {
87 return "RendererInternalTunnelDeleteWorker{"
89 + ", internalTunnel=" + internalTunnel + '\''