neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/BaseEndpointByPortListener.java

   1 /*\r
   2  * Copyright (c) 2016 Cisco Systems, Inc. and others. All rights reserved.\r
   3  *\r
   4  * This program and the accompanying materials are made available under the\r
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,\r
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html\r
   7  */\r
   8 \r
   9 package org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.processors;\r
  10 \r
  11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;\r
  12 import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;\r
  13 import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;\r
  14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;\r
  15 import org.opendaylight.groupbasedpolicy.util.DataTreeChangeHandler;\r
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.Mappings;\r
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.GbpByNeutronMappings;\r
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.BaseEndpointsByPorts;\r
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.base.endpoints.by.ports.BaseEndpointByPort;\r
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;\r
  21 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;\r
  22 \r
  23 public class BaseEndpointByPortListener extends DataTreeChangeHandler<BaseEndpointByPort> implements\r
  24         MappingProvider<Port> {\r
  25 \r
  26     private final PortHandler portHandler;\r
  27 \r
  28     protected BaseEndpointByPortListener(PortHandler portHandler, DataBroker dataProvider) {\r
  29         super(dataProvider);\r
  30         this.portHandler = portHandler;\r
  31         registerDataTreeChangeListener(new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL,\r
  32                 InstanceIdentifier.builder(Mappings.class)\r
  33                     .child(GbpByNeutronMappings.class)\r
  34                     .child(BaseEndpointsByPorts.class)\r
  35                     .child(BaseEndpointByPort.class)\r
  36                     .build()));\r
  37     }\r
  38 \r
  39     @Override\r
  40     public InstanceIdentifier<Port> getNeutronDtoIid() {\r
  41         return portHandler.createWildcartedPortIid();\r
  42     }\r
  43 \r
  44     @Override\r
  45     public void processCreatedNeutronDto(Port port) {\r
  46         portHandler.processCreated(port);\r
  47     }\r
  48 \r
  49     @Override\r
  50     public void processUpdatedNeutronDto(Port original, Port delta) {\r
  51         portHandler.processUpdated(original, delta);\r
  52     }\r
  53 \r
  54     @Override\r
  55     public void processDeletedNeutronDto(Port port) {\r
  56         // handled by BaseEndpointByPort removal\r
  57     }\r
  58 \r
  59     @Override\r
  60     protected void onWrite(DataObjectModification<BaseEndpointByPort> rootNode,\r
  61             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {\r
  62         if (rootNode.getDataBefore() == null) {\r
  63             portHandler.processCreated(rootNode.getDataAfter());\r
  64         }\r
  65     }\r
  66 \r
  67     @Override\r
  68     protected void onDelete(DataObjectModification<BaseEndpointByPort> rootNode,\r
  69             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {\r
  70         portHandler.processDeleted(rootNode.getDataBefore());\r
  71     }\r
  72 \r
  73     @Override\r
  74     protected void onSubtreeModified(DataObjectModification<BaseEndpointByPort> rootNode,\r
  75             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {\r
  76         // update should not happen\r
  77     }\r
  78 }\r