neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/hostconfigs/VppNodeListener.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.hostconfigs;\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.binding.api.ReadWriteTransaction;\r
  15 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;\r
  16 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;\r
  17 import org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.SocketInfo;\r
  18 import org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.util.HostconfigUtil;\r
  19 import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;\r
  20 import org.opendaylight.groupbasedpolicy.util.DataTreeChangeHandler;\r
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.RendererName;\r
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.Renderers;\r
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.Renderer;\r
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.RendererKey;\r
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.RendererNodes;\r
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.nodes.RendererNode;\r
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.hostconfig.rev150712.hostconfig.attributes.Hostconfigs;\r
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.hostconfig.rev150712.hostconfig.attributes.hostconfigs.Hostconfig;\r
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.hostconfig.rev150712.hostconfig.attributes.hostconfigs.HostconfigKey;\r
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;\r
  31 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;\r
  32 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;\r
  33 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;\r
  34 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;\r
  35 import org.slf4j.Logger;\r
  36 import org.slf4j.LoggerFactory;\r
  37 \r
  38 public class VppNodeListener extends DataTreeChangeHandler<RendererNode> {\r
  39 \r
  40     private static final Logger LOG = LoggerFactory.getLogger(VppNodeListener.class);\r
  41 \r
  42     private SocketInfo socketInfo;\r
  43     public static final RendererName VPP_RENDERER_NAME = new RendererName("vpp-renderer");\r
  44 \r
  45     public VppNodeListener(DataBroker dataBroker, SocketInfo socketInfo) {\r
  46         super(dataBroker);\r
  47         this.socketInfo = socketInfo;\r
  48         registerDataTreeChangeListener(new DataTreeIdentifier<>(\r
  49                 LogicalDatastoreType.OPERATIONAL, getVppNodeWildcardIid()));\r
  50     }\r
  51 \r
  52     private InstanceIdentifier<RendererNode> getVppNodeWildcardIid() {\r
  53         return InstanceIdentifier.builder(Renderers.class)\r
  54             .child(Renderer.class, new RendererKey(VPP_RENDERER_NAME))\r
  55             .child(RendererNodes.class)\r
  56             .child(RendererNode.class)\r
  57             .build();\r
  58     }\r
  59 \r
  60     @Override\r
  61     protected void onWrite(DataObjectModification<RendererNode> rootNode,\r
  62             InstanceIdentifier<RendererNode> rootIdentifier) {\r
  63         writeData(rootNode.getDataAfter());\r
  64     }\r
  65 \r
  66     @Override\r
  67     protected void onDelete(DataObjectModification<RendererNode> rootNode,\r
  68             InstanceIdentifier<RendererNode> rootIdentifier) {\r
  69         deleteData(rootNode.getDataBefore());\r
  70     }\r
  71 \r
  72     @Override\r
  73     protected void onSubtreeModified(DataObjectModification<RendererNode> rootNode,\r
  74             InstanceIdentifier<RendererNode> rootIdentifier) {\r
  75         deleteData(rootNode.getDataAfter());\r
  76         writeData(rootNode.getDataBefore());\r
  77     }\r
  78 \r
  79     private void writeData(RendererNode rendererNode) {\r
  80         NodeKey nodeKey = rendererNode.getNodePath().firstKeyOf(Node.class);\r
  81         WriteTransaction wTx = dataProvider.newWriteOnlyTransaction();\r
  82         Hostconfig hcData = HostconfigUtil.createHostconfigsDataFor(nodeKey.getNodeId(), socketInfo);\r
  83         wTx.put(LogicalDatastoreType.OPERATIONAL, hostconfigIid(nodeKey.getNodeId()), hcData);\r
  84         DataStoreHelper.submitToDs(wTx);\r
  85         LOG.info("Hostconfig data written to DS for VPP node {}", nodeKey);\r
  86     }\r
  87 \r
  88     private InstanceIdentifier<Hostconfig> hostconfigIid(NodeId nodeId) {\r
  89         return InstanceIdentifier.builder(Neutron.class)\r
  90             .child(Hostconfigs.class)\r
  91             .child(Hostconfig.class, new HostconfigKey(nodeId.getValue(), HostconfigUtil.L2_HOST_TYPE))\r
  92             .build();\r
  93     }\r
  94 \r
  95     private void deleteData(RendererNode rendererNode) {\r
  96         NodeKey nodeKey = rendererNode.getNodePath().firstKeyOf(Node.class);\r
  97         ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();\r
  98         DataStoreHelper.removeIfExists(LogicalDatastoreType.OPERATIONAL, hostconfigIid(nodeKey.getNodeId()), rwTx);\r
  99         DataStoreHelper.submitToDs(rwTx);\r
 100         LOG.info("Hostconfig data removed from DS for VPP node {}", nodeKey);\r
 101     }\r
 102 }\r