2 * Copyright (c) 2015 - 2016 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
8 package org.opendaylight.vpnservice.interfacemgr.listeners;
10 import com.google.common.util.concurrent.ListenableFuture;
11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
12 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
13 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
14 import org.opendaylight.vpnservice.datastoreutils.AsyncDataChangeListenerBase;
15 import org.opendaylight.vpnservice.datastoreutils.DataStoreJobCoordinator;
16 import org.opendaylight.vpnservice.interfacemgr.renderer.ovs.statehelpers.OvsInterfaceTopologyStateAddHelper;
17 import org.opendaylight.vpnservice.interfacemgr.renderer.ovs.statehelpers.OvsInterfaceTopologyStateRemoveHelper;
18 import org.opendaylight.vpnservice.interfacemgr.renderer.ovs.statehelpers.OvsInterfaceTopologyStateUpdateHelper;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
20 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
21 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
22 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
23 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
27 import java.util.List;
28 import java.util.concurrent.Callable;
30 public class InterfaceTopologyStateListener extends AsyncDataChangeListenerBase<OvsdbBridgeAugmentation, InterfaceTopologyStateListener> {
31 private static final Logger LOG = LoggerFactory.getLogger(InterfaceTopologyStateListener.class);
32 private DataBroker dataBroker;
34 public InterfaceTopologyStateListener(DataBroker dataBroker) {
35 super(OvsdbBridgeAugmentation.class, InterfaceTopologyStateListener.class);
36 this.dataBroker = dataBroker;
40 protected InstanceIdentifier<OvsdbBridgeAugmentation> getWildCardPath() {
41 return InstanceIdentifier.builder(NetworkTopology.class).child(Topology.class)
42 .child(Node.class).augmentation(OvsdbBridgeAugmentation.class).build();
46 protected DataChangeListener getDataChangeListener() {
47 return InterfaceTopologyStateListener.this;
51 protected AsyncDataBroker.DataChangeScope getDataChangeScope() {
52 return AsyncDataBroker.DataChangeScope.ONE;
56 protected void remove(InstanceIdentifier<OvsdbBridgeAugmentation> identifier, OvsdbBridgeAugmentation bridgeOld) {
57 LOG.debug("Received Remove DataChange Notification for identifier: {}, ovsdbBridgeAugmentation: {}",
58 identifier, bridgeOld);
59 DataStoreJobCoordinator jobCoordinator = DataStoreJobCoordinator.getInstance();
60 RendererStateRemoveWorker rendererStateRemoveWorker = new RendererStateRemoveWorker(identifier, bridgeOld);
61 jobCoordinator.enqueueJob(bridgeOld.getBridgeName().getValue(), rendererStateRemoveWorker);
65 protected void update(InstanceIdentifier<OvsdbBridgeAugmentation> identifier, OvsdbBridgeAugmentation bridgeOld,
66 OvsdbBridgeAugmentation bridgeNew) {
67 LOG.debug("Received Update DataChange Notification for identifier: {}, ovsdbBridgeAugmentation old: {}, new: {}.",
68 identifier, bridgeOld, bridgeNew);
69 if(bridgeOld.getDatapathId()== null && bridgeNew.getDatapathId()!= null){
70 DataStoreJobCoordinator jobCoordinator = DataStoreJobCoordinator.getInstance();
71 RendererStateAddWorker rendererStateAddWorker = new RendererStateAddWorker(identifier, bridgeNew);
72 jobCoordinator.enqueueJob(bridgeNew.getBridgeName().getValue(), rendererStateAddWorker);
73 } else if(!bridgeOld.getDatapathId().equals(bridgeNew.getDatapathId())){
74 DataStoreJobCoordinator jobCoordinator = DataStoreJobCoordinator.getInstance();
75 RendererStateUpdateWorker rendererStateAddWorker = new RendererStateUpdateWorker(identifier, bridgeNew, bridgeOld);
76 jobCoordinator.enqueueJob(bridgeNew.getBridgeName().getValue(), rendererStateAddWorker);
81 protected void add(InstanceIdentifier<OvsdbBridgeAugmentation> identifier, OvsdbBridgeAugmentation bridgeNew) {
82 LOG.debug("Received Add DataChange Notification for identifier: {}, ovsdbBridgeAugmentation: {}",
83 identifier, bridgeNew);
84 DataStoreJobCoordinator jobCoordinator = DataStoreJobCoordinator.getInstance();
85 RendererStateAddWorker rendererStateAddWorker = new RendererStateAddWorker(identifier, bridgeNew);
86 jobCoordinator.enqueueJob(bridgeNew.getBridgeName().getValue() + bridgeNew.getDatapathId(), rendererStateAddWorker);
89 private class RendererStateAddWorker implements Callable<List<ListenableFuture<Void>>> {
90 InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier;
91 OvsdbBridgeAugmentation bridgeNew;
94 public RendererStateAddWorker(InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier,
95 OvsdbBridgeAugmentation bridgeNew) {
96 this.instanceIdentifier = instanceIdentifier;
97 this.bridgeNew = bridgeNew;
101 public List<ListenableFuture<Void>> call() throws Exception {
102 // If another renderer(for eg : CSS) needs to be supported, check can be performed here
103 // to call the respective helpers.
104 return OvsInterfaceTopologyStateAddHelper.addPortToBridge(instanceIdentifier,
105 bridgeNew, dataBroker);
109 private class RendererStateRemoveWorker implements Callable<List<ListenableFuture<Void>>> {
110 InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier;
111 OvsdbBridgeAugmentation bridgeNew;
114 public RendererStateRemoveWorker(InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier,
115 OvsdbBridgeAugmentation bridgeNew) {
116 this.instanceIdentifier = instanceIdentifier;
117 this.bridgeNew = bridgeNew;
121 public List<ListenableFuture<Void>> call() throws Exception {
122 // If another renderer(for eg : CSS) needs to be supported, check can be performed here
123 // to call the respective helpers.
124 return OvsInterfaceTopologyStateRemoveHelper.removePortFromBridge(instanceIdentifier,
125 bridgeNew, dataBroker);
128 private class RendererStateUpdateWorker implements Callable<List<ListenableFuture<Void>>> {
129 InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier;
130 OvsdbBridgeAugmentation bridgeNew;
131 OvsdbBridgeAugmentation bridgeOld;
134 public RendererStateUpdateWorker(InstanceIdentifier<OvsdbBridgeAugmentation> instanceIdentifier,
135 OvsdbBridgeAugmentation bridgeNew, OvsdbBridgeAugmentation bridgeOld) {
136 this.instanceIdentifier = instanceIdentifier;
137 this.bridgeNew = bridgeNew;
138 this.bridgeOld = bridgeOld;
142 public List<ListenableFuture<Void>> call() throws Exception {
143 // If another renderer(for eg : CSS) needs to be supported, check can be performed here
144 // to call the respective helpers.
145 return OvsInterfaceTopologyStateUpdateHelper.updateBridgeRefEntry(instanceIdentifier,
146 bridgeNew, bridgeOld, dataBroker);