2 * Copyright © 2017 AT&T 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.transportpce.inventory;
10 import java.util.ArrayList;
11 import java.util.List;
12 import javax.sql.DataSource;
13 import org.opendaylight.mdsal.binding.api.DataBroker;
14 import org.opendaylight.mdsal.binding.api.DataTreeChangeListener;
15 import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
16 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
17 import org.opendaylight.transportpce.common.InstanceIdentifiers;
18 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
19 import org.opendaylight.transportpce.inventory.listener.ClliNetworkChangeListener;
20 import org.opendaylight.transportpce.inventory.listener.DeviceConfigListener;
21 import org.opendaylight.transportpce.inventory.listener.DeviceListener;
22 import org.opendaylight.transportpce.inventory.listener.OverlayNetworkChangeListener;
23 import org.opendaylight.transportpce.inventory.listener.UnderlayNetworkChangeListener;
24 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
25 import org.opendaylight.yangtools.concepts.Registration;
26 import org.osgi.service.component.annotations.Activate;
27 import org.osgi.service.component.annotations.Component;
28 import org.osgi.service.component.annotations.Deactivate;
29 import org.osgi.service.component.annotations.Reference;
30 import org.slf4j.Logger;
31 import org.slf4j.LoggerFactory;
34 * {@link ListenerProvider} registers {@link DataTreeChangeListener} for each network layer.
37 public class ListenerProvider {
39 private static final Logger LOG = LoggerFactory.getLogger(ListenerProvider.class);
40 private List<Registration> listeners = new ArrayList<>();
43 * Constructor invoked by blueprint injects all dependencies.
45 * @param dataBroker dataBroker
46 * @param dataSource dataSource
47 * @param deviceTransactionManager deviceTransactionManager
50 public ListenerProvider(@Reference DataBroker dataBroker,
51 @Reference DataSource dataSource,
52 @Reference DeviceTransactionManager deviceTransactionManager) {
54 LOG.debug("Registering listeners...");
55 OverlayNetworkChangeListener overlayNetworkListener = new OverlayNetworkChangeListener();
56 listeners.add(dataBroker.registerDataTreeChangeListener(
57 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, InstanceIdentifiers.OVERLAY_NETWORK_II),
58 overlayNetworkListener));
59 LOG.info("Overlay network change listener was successfully registered");
60 UnderlayNetworkChangeListener underlayNetworkListener = new UnderlayNetworkChangeListener();
61 listeners.add(dataBroker.registerDataTreeChangeListener(
62 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, InstanceIdentifiers.UNDERLAY_NETWORK_II),
63 underlayNetworkListener));
64 LOG.info("Underlay network change listener was successfully registered");
65 ClliNetworkChangeListener clliNetworkChangeListener = new ClliNetworkChangeListener();
66 listeners.add(dataBroker.registerDataTreeChangeListener(
67 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, InstanceIdentifiers.CLLI_NETWORK_II),
68 clliNetworkChangeListener));
69 LOG.info("CLLI network change listener was successfully registered");
70 INode121 inode121 = new INode121(dataSource, deviceTransactionManager);
71 INode inode = new INode(dataSource, inode121);
72 DeviceInventory deviceInventory = new DeviceInventory(dataSource, inode);
73 DeviceListener deviceListener = new DeviceListener(deviceInventory);
74 listeners.add(dataBroker.registerDataTreeChangeListener(
75 DataTreeIdentifier.create(LogicalDatastoreType.OPERATIONAL,
76 InstanceIdentifiers.NETCONF_TOPOLOGY_II.child(Node.class)), deviceListener));
77 LOG.info("Device change listener was successfully registered");
78 DeviceConfigListener deviceConfigListener = new DeviceConfigListener(deviceInventory);
79 listeners.add(dataBroker.registerDataTreeChangeListener(
80 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION,
81 InstanceIdentifiers.NETCONF_TOPOLOGY_II.child(Node.class)), deviceConfigListener));
82 LOG.info("Device config change listener was successfully registered");
87 listeners.forEach(lis -> lis.close());