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=2b023a72e1c0442cb8f932c0d1472381cb3740ea;hb=b1ecff661be27aa2470c30d323ceeadad993cd1a;hpb=2f02ee43956e0b1aad16b8cd8ddab1bd35042e1e 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 2b023a72e1..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() - removeRuntimeData(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) - } - - putRuntimeData(ref.value as InstanceIdentifier, data.build()); - commit() - } - - override onNodeRemoved(NodeRemoved node) { - val ref = node.nodeRef; - val it = manager.startChange() - - removeRuntimeData(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) - } - - putRuntimeData(ref.value as InstanceIdentifier, data.build()) - commit() - } -} +} \ No newline at end of file