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=1a66b3ba16316b4c5a1c92485e909cf061c3d398;hb=a1a4c87228915e5d5a0b9724d7d452047c898ee0;hpb=f46e0c0ac627304099c17783696bc0b5c9f622e1 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 1a66b3ba16..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,64 +60,4 @@ class FlowCapableInventoryProvider implements AutoCloseable { listenerRegistration?.close(); } -} - -class NodeChangeCommiter implements OpendaylightInventoryListener { - - @Property - val FlowCapableInventoryProvider manager; - - new(FlowCapableInventoryProvider manager) { - _manager = manager; - } - - override onNodeConnectorRemoved(NodeConnectorRemoved connector) { - val ref = connector.nodeConnectorRef; - - // Check path - val it = manager.startChange() - 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) - } - - putOperationalData(ref.value as InstanceIdentifier, data.build()); - commit() - } - - override onNodeRemoved(NodeRemoved node) { - val ref = node.nodeRef; - val it = manager.startChange() - - 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) - } - - putOperationalData(ref.value as InstanceIdentifier, data.build()) - commit() - } -} +} \ No newline at end of file