final NodeId nodeId = toTopologyNodeId(getNodeKey(notification.getNodeRef()).getId());
final InstanceIdentifier<Node> nodeInstance = toNodeIdentifier(notification.getNodeRef());
-
processor.enqueueOperation(new TopologyOperation() {
@Override
public void applyOperation(ReadWriteTransaction transaction) {
- Optional<Node> nodeOptional = Optional.absent();
- try {
- nodeOptional = transaction.read(LogicalDatastoreType.OPERATIONAL, nodeInstance).checkedGet();
- } catch (ReadFailedException e) {
- LOG.error("Error occured when trying to read Node ", e);
- }
- if (nodeOptional.isPresent()) {
removeAffectedLinks(nodeId, transaction);
transaction.delete(LogicalDatastoreType.OPERATIONAL, nodeInstance);
- }
}
@Override
final InstanceIdentifier<TerminationPoint> tpInstance = toTerminationPointIdentifier(
notification.getNodeConnectorRef());
+ final InstanceIdentifier<Node> node = tpInstance.firstIdentifierOf(Node.class);
+
final TpId tpId = toTerminationPointId(getNodeConnectorKey(
notification.getNodeConnectorRef()).getId());
processor.enqueueOperation(new TopologyOperation() {
@Override
public void applyOperation(ReadWriteTransaction transaction) {
- Optional<TerminationPoint> terminationPointOptional = Optional.absent();
+ Optional<Node> nodeOptional = Optional.absent();
try {
- terminationPointOptional = transaction.read(LogicalDatastoreType.OPERATIONAL, tpInstance).checkedGet();
+ nodeOptional = transaction.read(LogicalDatastoreType.OPERATIONAL, node).checkedGet();
} catch (ReadFailedException e) {
LOG.error("Error occured when trying to read NodeConnector ", e);
}
- if (terminationPointOptional.isPresent()) {
+ if (nodeOptional.isPresent()) {
removeAffectedLinks(tpId, transaction);
transaction.delete(LogicalDatastoreType.OPERATIONAL, tpInstance);
}
});
}
-
@Override
public void onLinkUtilizationNormal(final LinkUtilizationNormal notification) {
// NOOP