2 * Copyright © 2015 Dell, Inc. 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.ovsdb.openstack.netvirt.sfc;
15 import com.google.common.base.Preconditions;
16 import java.util.concurrent.Callable;
17 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
18 import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
19 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
20 import org.opendaylight.ovsdb.openstack.netvirt.sfc.openflow13.INetvirtSfcOF13Provider;
21 import org.opendaylight.ovsdb.utils.mdsal.utils.MdsalUtils;
22 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
23 import org.opendaylight.yangtools.concepts.ListenerRegistration;
25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.acl.rev141010.AccessLists;
26 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.acl.rev141010.access.lists.AccessList;
27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.acl.rev141010.access.lists.AccessListKey;
28 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.acl.rev141010.access.lists.access.list.AccessListEntries;
29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.acl.rev141010.access.lists.access.list.access.list.entries.AccessListEntry;
30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.acl.rev141010.access.lists.access.list.access.list.entries.AccessListEntryKey;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netvirt.sfc.classifier.rev150105.Classifiers;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netvirt.sfc.classifier.rev150105.classifiers.Classifier;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netvirt.sfc.classifier.rev150105.classifiers.classifier.sffs.Sff;
34 import org.slf4j.Logger;
35 import org.slf4j.LoggerFactory;
37 public class NetvirtSfcAclListener extends AbstractDataTreeListener<AccessList> {
38 private static final Logger LOG = LoggerFactory.getLogger(NetvirtSfcAclListener.class);
39 private ListenerRegistration<NetvirtSfcAclListener> listenerRegistration;
40 private MdsalUtils dbutils;
42 public NetvirtSfcAclListener (final INetvirtSfcOF13Provider provider, final DataBroker db) {
43 super(provider, AccessList.class);
44 Preconditions.checkNotNull(db, "DataBroker can not be null!");
46 dbutils = new MdsalUtils(db);
47 registrationListener(db);
50 private void registrationListener(final DataBroker db) {
51 final DataTreeIdentifier<AccessList> treeId = new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION, getIetfAclIid());
53 LOG.info("Registering Data Change Listener for Netvirt AccesList configuration.");
54 listenerRegistration = db.registerDataTreeChangeListener(treeId, this);
55 } catch (final Exception e) {
56 LOG.warn("Netvirt AccesList DataChange listener registration fail!");
57 LOG.debug("Netvirt AccesList DataChange listener registration fail!", e);
58 throw new IllegalStateException("NetvirtSfcAccesListListener startup fail! System needs restart.", e);
64 if (listenerRegistration != null) {
66 listenerRegistration.close();
67 } catch (final Exception e) {
68 LOG.warn("Error while stopping IETF ACL ChangeListener: {}", e.getMessage());
69 LOG.debug("Error while stopping IETF ACL ChangeListener..", e);
71 listenerRegistration = null;
76 public void remove(final InstanceIdentifier<AccessList> identifier,
77 final AccessList removeDataObj) {
78 Preconditions.checkNotNull(removeDataObj, "Removed object can not be null!");
79 String aclName = removeDataObj.getAclName();
81 Classifiers classifiers = dbutils.read(LogicalDatastoreType.CONFIGURATION, getClassifierIid());
82 if(classifiers != null) {
83 for(Classifier classifier : classifiers.getClassifier()) {
84 if(classifier.getAcl().equalsIgnoreCase(aclName)) {
85 if(classifier.getSffs() != null) {
86 for(Sff sff : classifier.getSffs().getSff()) {
87 provider.removeClassifierRules(sff, removeDataObj);
97 public void update(final InstanceIdentifier<AccessList> identifier,
98 final AccessList original, final AccessList update) {
102 public void add(final InstanceIdentifier<AccessList> identifier,
103 final AccessList addDataObj) {
104 Preconditions.checkNotNull(addDataObj, "Added object can not be null!");
105 String aclName = addDataObj.getAclName();
106 LOG.debug("Adding accesslist = {}", identifier);
107 Classifiers classifiers = dbutils.read(LogicalDatastoreType.CONFIGURATION, getClassifierIid());
108 if(classifiers != null) {
109 for(Classifier classifier : classifiers.getClassifier()) {
110 if(classifier.getAcl().equalsIgnoreCase(aclName)) {
111 if(classifier.getSffs() != null) {
112 for(Sff sff : classifier.getSffs().getSff()) {
113 provider.addClassifierRules(sff, addDataObj);
122 private InstanceIdentifier<Classifiers> getClassifierIid () {
123 return InstanceIdentifier.create(Classifiers.class);
126 public InstanceIdentifier<AccessList> getIetfAclIid () {
127 return InstanceIdentifier.create(AccessLists.class).child(AccessList.class);
130 public InstanceIdentifier<AccessListEntry> getIetfAclEntryIid (String aclName, String ruleName) {
131 return InstanceIdentifier.create(AccessLists.class).child(AccessList.class, new AccessListKey(aclName)).
132 child(AccessListEntries.class).child(AccessListEntry.class, new AccessListEntryKey(ruleName));