2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.bgpcep.pcep.tunnel.provider;
10 import java.util.Map.Entry;
11 import java.util.concurrent.ExecutionException;
12 import java.util.concurrent.Future;
14 import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
15 import org.opendaylight.controller.md.sal.common.api.data.DataChangeEvent;
16 import org.opendaylight.controller.sal.binding.api.data.DataChangeListener;
17 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
18 import org.opendaylight.controller.sal.binding.api.data.DataProviderService;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.SymbolicPathName;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev131024.pcep.client.attributes.path.computation.client.ReportedLsps;
21 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.LinkId;
22 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
23 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
24 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Link;
25 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.LinkKey;
26 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
27 import org.opendaylight.yangtools.yang.binding.DataObject;
28 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
29 import org.opendaylight.yangtools.yang.common.RpcResult;
30 import org.slf4j.Logger;
31 import org.slf4j.LoggerFactory;
33 import com.google.common.base.Preconditions;
35 final class NodeChangedListener implements DataChangeListener {
36 private static final Logger LOG = LoggerFactory.getLogger(NodeChangedListener.class);
37 private final InstanceIdentifier<Topology> target;
38 private final DataProviderService dataProvider;
40 NodeChangedListener(final DataProviderService dataProvider, final InstanceIdentifier<Topology> target) {
41 this.dataProvider = Preconditions.checkNotNull(dataProvider);
42 this.target = Preconditions.checkNotNull(target);
45 private void remove(final DataModificationTransaction trans, final InstanceIdentifier<?> id) {
46 if (Node.class.equals(id.getTargetType())) {
47 // FIXME: implement this
48 } else if (ReportedLsps.class.equals(id.getTargetType())) {
49 // FIXME: implement this
51 LOG.debug("Ignoring changed instance {}", id);
55 private void create(final DataModificationTransaction trans, final InstanceIdentifier<?> id, final DataObject obj) {
56 // FIXME: implement this
60 public void onDataChanged(final DataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
61 final DataModificationTransaction trans = dataProvider.beginTransaction();
63 for (final InstanceIdentifier<?> i : change.getRemovedOperationalData()) {
67 for (final Entry<InstanceIdentifier<?>, DataObject> e : change.getUpdatedOperationalData().entrySet()) {
68 remove(trans, e.getKey());
69 create(trans, e.getKey(), e.getValue());
72 for (final Entry<InstanceIdentifier<?>, DataObject> e : change.getCreatedOperationalData().entrySet()) {
73 create(trans, e.getKey(), e.getValue());
76 final Future<RpcResult<TransactionStatus>> f = trans.commit();
78 // FIXME: change to a subscribtion once that is possible
81 } catch (InterruptedException | ExecutionException e) {
82 LOG.error("Failed to propagate a topology change, target topology became inconsistent", e);
86 public static InstanceIdentifier<Link> linkIdentifier(final InstanceIdentifier<Topology> topology,
87 final NodeId node, final SymbolicPathName name) {
88 return InstanceIdentifier.builder(topology).
89 node(Link.class, new LinkKey(new LinkId(node.getValue() + "/lsp/" + name))).toInstance();