X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Finventory-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Finventory%2Fmanager%2FFlowCapableInventoryProvider.xtend;h=ec8da8693fd5dd83379377786a6c3dc015797d34;hp=43f48a50e56175a2297e78e32478f80404ff839d;hb=a1a4c87228915e5d5a0b9724d7d452047c898ee0;hpb=59cb3e27630fb1fd965152f9e1584213e89fa62f diff --git a/opendaylight/md-sal/inventory-manager/src/main/java/org/opendaylight/controller/md/inventory/manager/FlowCapableInventoryProvider.xtend b/opendaylight/md-sal/inventory-manager/src/main/java/org/opendaylight/controller/md/inventory/manager/FlowCapableInventoryProvider.xtend index 43f48a50e5..ec8da8693f 100644 --- a/opendaylight/md-sal/inventory-manager/src/main/java/org/opendaylight/controller/md/inventory/manager/FlowCapableInventoryProvider.xtend +++ b/opendaylight/md-sal/inventory-manager/src/main/java/org/opendaylight/controller/md/inventory/manager/FlowCapableInventoryProvider.xtend @@ -60,75 +60,4 @@ class FlowCapableInventoryProvider implements AutoCloseable { listenerRegistration?.close(); } -} - -class NodeChangeCommiter implements OpendaylightInventoryListener { - - static val LOG = LoggerFactory.getLogger(NodeChangeCommiter); - - @Property - val FlowCapableInventoryProvider manager; - - new(FlowCapableInventoryProvider manager) { - _manager = manager; - } - - override onNodeConnectorRemoved(NodeConnectorRemoved connector) { - val ref = connector.nodeConnectorRef; - - // Check path - val it = manager.startChange() - - LOG.debug("removing node connector : " + ref.value.toString()); - - removeOperationalData(ref.value as InstanceIdentifier); - commit() - } - - override onNodeConnectorUpdated(NodeConnectorUpdated connector) { - val ref = connector.nodeConnectorRef; - - val flowConnector = connector.getAugmentation(FlowCapableNodeConnectorUpdated); - - val it = manager.startChange() - val data = new NodeConnectorBuilder(connector); - data.key = (new NodeConnectorKey(connector.id)) - if (flowConnector != null) { - val augment = flowConnector.toInventoryAugment() - data.addAugmentation(FlowCapableNodeConnector, augment) - } - - LOG.debug("updating node connector : " + ref.value.toString()); - - putOperationalData(ref.value as InstanceIdentifier, data.build()); - commit() - } - - override onNodeRemoved(NodeRemoved node) { - val ref = node.nodeRef; - val it = manager.startChange() - - LOG.debug("removing node : " + ref.value.toString()); - - removeOperationalData(ref.value as InstanceIdentifier); - commit() - } - - override onNodeUpdated(NodeUpdated node) { - val ref = node.nodeRef; - val flowNode = node.getAugmentation(FlowCapableNodeUpdated); - - val it = manager.startChange() - val data = new NodeBuilder(node); - data.key = (new NodeKey(node.id)) - if (flowNode != null) { - val augment = flowNode.toInventoryAugment(); - data.addAugmentation(FlowCapableNode, augment) - } - - LOG.debug("updating node : " + ref.value.toString()); - - putOperationalData(ref.value as InstanceIdentifier, data.build()) - commit() - } -} +} \ No newline at end of file