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

   1 /*\r
   2  * Copyright (c) 2014 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 MappingProvider<Port> {\r
  24 \r
  25     private final PortHandler portHandler;\r
  26 \r
  27     protected BaseEndpointByPortListener(PortHandler portHandler, DataBroker dataProvider) {\r
  28         super(dataProvider);\r
  29         this.portHandler = portHandler;\r
  30         registerDataTreeChangeListener(new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL,\r
  31                 InstanceIdentifier.builder(Mappings.class)\r
  32                     .child(GbpByNeutronMappings.class)\r
  33                     .child(BaseEndpointsByPorts.class)\r
  34                     .child(BaseEndpointByPort.class)\r
  35                     .build()));\r
  36     }\r
  37 \r
  38     @Override\r
  39     public InstanceIdentifier<Port> getNeutronDtoIid() {\r
  40         return portHandler.createWildcartedPortIid();\r
  41     }\r
  42 \r
  43     @Override\r
  44     public void processCreatedNeutronDto(Port port) {\r
  45         portHandler.processCreated(port);\r
  46     }\r
  47 \r
  48     @Override\r
  49     public void processUpdatedNeutronDto(Port original, Port delta) {\r
  50         portHandler.processUpdated(original, delta);\r
  51     }\r
  52 \r
  53     @Override\r
  54     public void processDeletedNeutronDto(Port port) {\r
  55         // handled by BaseEndpointByPort removal\r
  56     }\r
  57 \r
  58     @Override\r
  59     protected void onWrite(DataObjectModification<BaseEndpointByPort> rootNode,\r
  60             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {\r
  61         if (rootNode.getDataBefore() == null) {\r
  62             portHandler.processCreated(rootNode.getDataAfter());\r
  63         }\r
  64     }\r
  65 \r
  66     @Override\r
  67     protected void onDelete(DataObjectModification<BaseEndpointByPort> rootNode,\r
  68             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {\r
  69         portHandler.processDeleted(rootNode.getDataBefore());\r
  70     }\r
  71 \r
  72     @Override\r
  73     protected void onSubtreeModified(DataObjectModification<BaseEndpointByPort> rootNode,\r
  74             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {\r
  75         // update should not happen\r
  76     }\r
  77 }\r