2 * Copyright (c) 2016 Cisco Systems, 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
9 package org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.processors;
11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
12 import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
13 import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
15 import org.opendaylight.groupbasedpolicy.util.DataTreeChangeHandler;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.Mappings;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.GbpByNeutronMappings;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.BaseEndpointsByPorts;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.base.endpoints.by.ports.BaseEndpointByPort;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
21 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
22 import org.slf4j.Logger;
23 import org.slf4j.LoggerFactory;
25 public class PortAware extends DataTreeChangeHandler<BaseEndpointByPort> implements
26 MappingProvider<Port> {
28 private static final Logger LOG = LoggerFactory.getLogger(PortAware.class);
29 private final PortHandler portHandler;
31 protected PortAware(PortHandler portHandler, DataBroker dataProvider) {
33 this.portHandler = portHandler;
34 registerDataTreeChangeListener(new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL,
35 InstanceIdentifier.builder(Mappings.class)
36 .child(GbpByNeutronMappings.class)
37 .child(BaseEndpointsByPorts.class)
38 .child(BaseEndpointByPort.class)
43 public InstanceIdentifier<Port> getNeutronDtoIid() {
44 return portHandler.createWildcartedPortIid();
48 public void processCreatedNeutronDto(Port port) {
49 LOG.trace("Neutron port created: {}", port);
50 portHandler.processCreated(port);
54 public void processUpdatedNeutronDto(Port original, Port delta) {
55 LOG.trace("Neutron port updated: {}, delta {}", original, delta);
56 portHandler.processUpdated(original, delta);
60 public void processDeletedNeutronDto(Port port) {
61 LOG.trace("Neutron port deleted: {}", port);
62 // handled by BaseEndpointByPort removal
66 protected void onWrite(DataObjectModification<BaseEndpointByPort> rootNode,
67 InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
68 if (rootNode.getDataBefore() == null) {
69 portHandler.processCreated(rootNode.getDataAfter());
74 protected void onDelete(DataObjectModification<BaseEndpointByPort> rootNode,
75 InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
76 portHandler.processDeleted(rootNode.getDataBefore());
80 protected void onSubtreeModified(DataObjectModification<BaseEndpointByPort> rootNode,
81 InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
82 // update should not happen