X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=neutron-vpp-mapper%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fgroupbasedpolicy%2Fneutron%2Fvpp%2Fmapper%2Fprocessors%2FPortAware.java;h=e08508c38c65df32da5fbd80ee153c2c16b11f21;hb=refs%2Fchanges%2F92%2F64692%2F1;hp=df44f2cfa0c2af43b9a9e4a1266d29f8e803a54b;hpb=aed74c1bec15e3b6a0328a44d4438c0a95bb2b2e;p=groupbasedpolicy.git

diff --git a/neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/PortAware.java b/neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/PortAware.java
index df44f2cfa..e08508c38 100644
--- a/neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/PortAware.java
+++ b/neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/PortAware.java
@@ -1,84 +1,84 @@
-/*
- * Copyright (c) 2016 Cisco Systems, Inc. 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.groupbasedpolicy.neutron.vpp.mapper.processors;
-
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
-import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.groupbasedpolicy.util.DataTreeChangeHandler;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.Mappings;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.GbpByNeutronMappings;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.BaseEndpointsByPorts;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.base.endpoints.by.ports.BaseEndpointByPort;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class PortAware extends DataTreeChangeHandler<BaseEndpointByPort> implements
-        MappingProvider<Port> {
-
-    private static final Logger LOG = LoggerFactory.getLogger(PortAware.class);
-    private final PortHandler portHandler;
-
-    protected PortAware(PortHandler portHandler, DataBroker dataProvider) {
-        super(dataProvider);
-        this.portHandler = portHandler;
-        registerDataTreeChangeListener(new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL,
-                InstanceIdentifier.builder(Mappings.class)
-                    .child(GbpByNeutronMappings.class)
-                    .child(BaseEndpointsByPorts.class)
-                    .child(BaseEndpointByPort.class)
-                    .build()));
-    }
-
-    @Override
-    public InstanceIdentifier<Port> getNeutronDtoIid() {
-        return portHandler.createWildcartedPortIid();
-    }
-
-    @Override
-    public void processCreatedNeutronDto(Port port) {
-        LOG.trace("Neutron port created: {}", port);
-        portHandler.processCreated(port);
-    }
-
-    @Override
-    public void processUpdatedNeutronDto(Port original, Port delta) {
-        LOG.trace("Neutron port updated: {}, delta {}", original, delta);
-        portHandler.processUpdated(original, delta);
-    }
-
-    @Override
-    public void processDeletedNeutronDto(Port port) {
-        LOG.trace("Neutron port deleted: {}", port);
-        // handled by BaseEndpointByPort removal
-    }
-
-    @Override
-    protected void onWrite(DataObjectModification<BaseEndpointByPort> rootNode,
-            InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
-        if (rootNode.getDataBefore() == null) {
-            portHandler.processCreated(rootNode.getDataAfter());
-        }
-    }
-
-    @Override
-    protected void onDelete(DataObjectModification<BaseEndpointByPort> rootNode,
-            InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
-        portHandler.processDeleted(rootNode.getDataBefore());
-    }
-
-    @Override
-    protected void onSubtreeModified(DataObjectModification<BaseEndpointByPort> rootNode,
-            InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
-        // update should not happen
-    }
-}
+/*
+ * Copyright (c) 2016 Cisco Systems, Inc. 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.groupbasedpolicy.neutron.vpp.mapper.processors;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
+import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.groupbasedpolicy.util.DataTreeChangeHandler;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.Mappings;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.GbpByNeutronMappings;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.BaseEndpointsByPorts;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.base.endpoints.by.ports.BaseEndpointByPort;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class PortAware extends DataTreeChangeHandler<BaseEndpointByPort> implements
+        MappingProvider<Port> {
+
+    private static final Logger LOG = LoggerFactory.getLogger(PortAware.class);
+    private final PortHandler portHandler;
+
+    protected PortAware(PortHandler portHandler, DataBroker dataProvider) {
+        super(dataProvider);
+        this.portHandler = portHandler;
+        registerDataTreeChangeListener(new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL,
+                InstanceIdentifier.builder(Mappings.class)
+                    .child(GbpByNeutronMappings.class)
+                    .child(BaseEndpointsByPorts.class)
+                    .child(BaseEndpointByPort.class)
+                    .build()));
+    }
+
+    @Override
+    public InstanceIdentifier<Port> getNeutronDtoIid() {
+        return portHandler.createWildcartedPortIid();
+    }
+
+    @Override
+    public void processCreatedNeutronDto(Port port) {
+        LOG.trace("Neutron port created: {}", port);
+        portHandler.processCreated(port);
+    }
+
+    @Override
+    public void processUpdatedNeutronDto(Port original, Port delta) {
+        LOG.trace("Neutron port updated: {}, delta {}", original, delta);
+        portHandler.processUpdated(original, delta);
+    }
+
+    @Override
+    public void processDeletedNeutronDto(Port port) {
+        LOG.trace("Neutron port deleted: {}", port);
+        // handled by BaseEndpointByPort removal
+    }
+
+    @Override
+    protected void onWrite(DataObjectModification<BaseEndpointByPort> rootNode,
+            InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
+        if (rootNode.getDataBefore() == null) {
+            portHandler.processCreated(rootNode.getDataAfter());
+        }
+    }
+
+    @Override
+    protected void onDelete(DataObjectModification<BaseEndpointByPort> rootNode,
+            InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
+        portHandler.processDeleted(rootNode.getDataBefore());
+    }
+
+    @Override
+    protected void onSubtreeModified(DataObjectModification<BaseEndpointByPort> rootNode,
+            InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
+        // update should not happen
+    }
+}