2 * Copyright (c) 2015 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.vpnservice.interfacemgr.listeners;
11 import com.google.common.util.concurrent.ListenableFuture;
12 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
13 import org.opendaylight.idmanager.IdManager;
14 import org.opendaylight.vpnservice.datastoreutils.AsyncDataTreeChangeListenerBase;
15 import org.opendaylight.vpnservice.datastoreutils.DataStoreJobCoordinator;
16 import org.opendaylight.vpnservice.interfacemgr.renderer.ovs.confighelpers.OvsInterfaceConfigAddHelper;
17 import org.opendaylight.vpnservice.interfacemgr.renderer.ovs.confighelpers.OvsInterfaceConfigRemoveHelper;
18 import org.opendaylight.vpnservice.interfacemgr.renderer.ovs.confighelpers.OvsInterfaceConfigUpdateHelper;
19 import org.opendaylight.vpnservice.mdsalutil.interfaces.IMdsalApiManager;
20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.alivenessmonitor.rev150629.AlivenessMonitorService;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdManagerService;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.ParentRefs;
25 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
26 import org.slf4j.Logger;
27 import org.slf4j.LoggerFactory;
29 import java.util.List;
30 import java.util.concurrent.Callable;
33 * This class listens for interface creation/removal/update in Configuration DS.
34 * This is used to handle interfaces for base of-ports.
36 public class InterfaceConfigListener extends AsyncDataTreeChangeListenerBase<Interface, InterfaceConfigListener> {
37 private static final Logger LOG = LoggerFactory.getLogger(InterfaceConfigListener.class);
38 private DataBroker dataBroker;
39 private IdManagerService idManager;
40 private AlivenessMonitorService alivenessMonitorService;
41 private IMdsalApiManager mdsalApiManager;
43 public InterfaceConfigListener(final DataBroker dataBroker, final IdManagerService idManager,
44 final AlivenessMonitorService alivenessMonitorService,
45 final IMdsalApiManager mdsalApiManager) {
46 super(Interface.class, InterfaceConfigListener.class);
47 this.dataBroker = dataBroker;
48 this.idManager = idManager;
49 this.alivenessMonitorService = alivenessMonitorService;
50 this.mdsalApiManager = mdsalApiManager;
54 protected InstanceIdentifier<Interface> getWildCardPath() {
55 return InstanceIdentifier.create(Interfaces.class).child(Interface.class);
59 protected InterfaceConfigListener getDataTreeChangeListener() {
60 return InterfaceConfigListener.this;
64 protected void remove(InstanceIdentifier<Interface> key, Interface interfaceOld) {
65 LOG.debug("Received Interface Remove Event: {}, {}", key, interfaceOld);
66 String ifName = interfaceOld.getName();
67 ParentRefs parentRefs = interfaceOld.getAugmentation(ParentRefs.class);
68 DataStoreJobCoordinator coordinator = DataStoreJobCoordinator.getInstance();
69 RendererConfigRemoveWorker configWorker = new RendererConfigRemoveWorker(key, interfaceOld, ifName, parentRefs);
70 coordinator.enqueueJob(ifName, configWorker);
74 protected void update(InstanceIdentifier<Interface> key, Interface interfaceOld, Interface interfaceNew) {
75 LOG.debug("Received Interface Update Event: {}, {}, {}", key, interfaceOld, interfaceNew);
76 String ifNameNew = interfaceNew.getName();
77 DataStoreJobCoordinator coordinator = DataStoreJobCoordinator.getInstance();
78 RendererConfigUpdateWorker worker = new RendererConfigUpdateWorker(key, interfaceOld, interfaceNew, ifNameNew);
79 coordinator.enqueueJob(ifNameNew, worker);
83 protected void add(InstanceIdentifier<Interface> key, Interface interfaceNew) {
84 LOG.debug("Received Interface Add Event: {}, {}", key, interfaceNew);
85 String ifName = interfaceNew.getName();
86 ParentRefs parentRefs = interfaceNew.getAugmentation(ParentRefs.class);
87 if (parentRefs == null) {
88 LOG.error("parent refs not specified for {}",interfaceNew.getName());
90 DataStoreJobCoordinator coordinator = DataStoreJobCoordinator.getInstance();
91 RendererConfigAddWorker configWorker = new RendererConfigAddWorker(key, interfaceNew, parentRefs, ifName);
92 coordinator.enqueueJob(ifName, configWorker);
95 private class RendererConfigAddWorker implements Callable<List<ListenableFuture<Void>>> {
96 InstanceIdentifier<Interface> key;
97 Interface interfaceNew;
99 ParentRefs parentRefs;
101 public RendererConfigAddWorker(InstanceIdentifier<Interface> key, Interface interfaceNew,
102 ParentRefs parentRefs, String portName) {
104 this.interfaceNew = interfaceNew;
105 this.portName = portName;
106 this.parentRefs = parentRefs;
110 public List<ListenableFuture<Void>> call() throws Exception {
111 // If another renderer(for eg : CSS) needs to be supported, check can be performed here
112 // to call the respective helpers.
113 return OvsInterfaceConfigAddHelper.addConfiguration(dataBroker, parentRefs, interfaceNew,
114 idManager, alivenessMonitorService, mdsalApiManager);
118 public String toString() {
119 return "RendererConfigAddWorker{" +
121 ", interfaceNew=" + interfaceNew +
122 ", portName='" + portName + '\'' +
130 private class RendererConfigUpdateWorker implements Callable {
131 InstanceIdentifier<Interface> key;
132 Interface interfaceOld;
133 Interface interfaceNew;
136 public RendererConfigUpdateWorker(InstanceIdentifier<Interface> key, Interface interfaceOld,
137 Interface interfaceNew, String portNameNew) {
139 this.interfaceOld = interfaceOld;
140 this.interfaceNew = interfaceNew;
141 this.portNameNew = portNameNew;
145 public List<ListenableFuture<Void>> call() throws Exception {
146 // If another renderer(for eg : CSS) needs to be supported, check can be performed here
147 // to call the respective helpers.
148 return OvsInterfaceConfigUpdateHelper.updateConfiguration(dataBroker, alivenessMonitorService, idManager,
149 mdsalApiManager, interfaceNew, interfaceOld);
153 public String toString() {
154 return "RendererConfigUpdateWorker{" +
156 ", interfaceOld=" + interfaceOld +
157 ", interfaceNew=" + interfaceNew +
158 ", portNameNew='" + portNameNew + '\'' +
166 private class RendererConfigRemoveWorker implements Callable {
167 InstanceIdentifier<Interface> key;
168 Interface interfaceOld;
170 ParentRefs parentRefs;
172 public RendererConfigRemoveWorker(InstanceIdentifier<Interface> key, Interface interfaceOld, String portName,
173 ParentRefs parentRefs) {
175 this.interfaceOld = interfaceOld;
176 this.portName = portName;
177 this.parentRefs = parentRefs;
181 public List<ListenableFuture<Void>> call() throws Exception {
182 // If another renderer(for eg : CSS) needs to be supported, check can be performed here
183 // to call the respective helpers.
184 return OvsInterfaceConfigRemoveHelper.removeConfiguration(dataBroker, alivenessMonitorService,
185 interfaceOld, idManager, mdsalApiManager, parentRefs);
189 public String toString() {
190 return "RendererConfigRemoveWorker{" +
192 ", interfaceOld=" + interfaceOld +
193 ", portName='" + portName + '\'' +