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.topology.pcep.rev131024.pcep.client.attributes.path.computation.client.ReportedLsps;
20 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
21 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
22 import org.opendaylight.yangtools.yang.binding.DataObject;
23 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
24 import org.opendaylight.yangtools.yang.common.RpcResult;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
28 import com.google.common.base.Preconditions;
30 final class NodeChangedListener implements DataChangeListener {
31 private static final Logger LOG = LoggerFactory.getLogger(NodeChangedListener.class);
32 private final InstanceIdentifier<Topology> target;
33 private final DataProviderService dataProvider;
35 NodeChangedListener(final DataProviderService dataProvider, final InstanceIdentifier<Topology> target) {
36 this.dataProvider = Preconditions.checkNotNull(dataProvider);
37 this.target = Preconditions.checkNotNull(target);
40 private void remove(final DataModificationTransaction trans, final InstanceIdentifier<?> id) {
41 if (Node.class.equals(id.getTargetType())) {
42 // FIXME: implement this
43 } else if (ReportedLsps.class.equals(id.getTargetType())) {
44 // FIXME: implement this
46 LOG.debug("Ignoring changed instance {}", id);
50 private void create(final DataModificationTransaction trans, final InstanceIdentifier<?> id, final DataObject obj) {
51 // FIXME: implement this
55 public void onDataChanged(final DataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
56 final DataModificationTransaction trans = dataProvider.beginTransaction();
58 for (final InstanceIdentifier<?> i : change.getRemovedOperationalData()) {
62 for (final Entry<InstanceIdentifier<?>, DataObject> e : change.getUpdatedOperationalData().entrySet()) {
63 remove(trans, e.getKey());
64 create(trans, e.getKey(), e.getValue());
67 for (final Entry<InstanceIdentifier<?>, DataObject> e : change.getCreatedOperationalData().entrySet()) {
68 create(trans, e.getKey(), e.getValue());
71 final Future<RpcResult<TransactionStatus>> f = trans.commit();
73 // FIXME: change to a subscribtion once that is possible
76 } catch (InterruptedException | ExecutionException e) {
77 LOG.error("Failed to propagate a topology change, target topology became inconsistent", e);