2 * Copyright (c) 2017 AT&T Intellectual Property. 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 static org.opendaylight.mdsal.common.api.LogicalDatastoreType.CONFIGURATION;
12 import java.util.Collection;
13 import java.util.HashMap;
14 import java.util.List;
16 import java.util.concurrent.TimeUnit;
17 import java.util.stream.Collectors;
18 import org.apache.commons.lang3.StringUtils;
19 import org.checkerframework.checker.lock.qual.GuardedBy;
20 import org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener;
21 import org.opendaylight.mdsal.binding.api.DataBroker;
22 import org.opendaylight.mdsal.binding.api.DataObjectModification;
23 import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
24 import org.opendaylight.mdsal.binding.api.DataTreeModification;
25 import org.opendaylight.mdsal.binding.api.RpcConsumerRegistry;
26 import org.opendaylight.mdsal.binding.api.RpcProviderService;
27 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.tunnel.pcep.config.rev181109.PcepTunnelTopologyConfig;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.tunnel.pcep.rev181109.TopologyTypes1;
30 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
31 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
32 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
33 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
34 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.TopologyTypes;
35 import org.opendaylight.yangtools.concepts.Registration;
36 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
37 import org.osgi.framework.BundleContext;
38 import org.osgi.service.component.annotations.Activate;
39 import org.osgi.service.component.annotations.Component;
40 import org.osgi.service.component.annotations.Deactivate;
41 import org.osgi.service.component.annotations.Reference;
42 import org.slf4j.Logger;
43 import org.slf4j.LoggerFactory;
45 @Component(service = { })
46 public final class TunnelProviderDeployer implements ClusteredDataTreeChangeListener<Topology>, AutoCloseable {
47 private static final Logger LOG = LoggerFactory.getLogger(TunnelProviderDeployer.class);
48 private static final long TIMEOUT_NS = TimeUnit.SECONDS.toNanos(5);
50 private final TunnelProviderDependencies dependencies;
52 private final Map<TopologyId, PCEPTunnelClusterSingletonService> pcepTunnelServices = new HashMap<>();
53 private final Registration reg;
56 public TunnelProviderDeployer(@Reference final DataBroker dataBroker,
57 @Reference final RpcProviderService rpcProviderRegistry,
58 @Reference final RpcConsumerRegistry rpcConsumerRegistry,
59 @Reference final ClusterSingletonServiceProvider cssp,
60 // FIXME: do not reference BundleContext in an alternative constructor
61 final BundleContext bundleContext) {
62 dependencies = new TunnelProviderDependencies(dataBroker, cssp, rpcProviderRegistry, rpcConsumerRegistry,
64 reg = dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(CONFIGURATION,
65 InstanceIdentifier.builder(NetworkTopology.class).child(Topology.class).build()), this);
66 LOG.info("Tunnel Provider Deployer created");
71 public synchronized void close() {
73 pcepTunnelServices.values().iterator().forEachRemaining(PCEPTunnelClusterSingletonService::close);
74 pcepTunnelServices.clear();
75 LOG.info("Tunnel Provider Deployer closed");
78 @SuppressWarnings("checkstyle:IllegalCatch")
79 private static void closeTopology(final PCEPTunnelClusterSingletonService topology, final TopologyId topologyId) {
80 if (topology != null) {
82 topology.closeServiceInstance().get(TIMEOUT_NS, TimeUnit.NANOSECONDS);
83 } catch (final Exception e) {
84 LOG.error("Topology {} instance failed to close service instance", topologyId, e);
91 public synchronized void onDataTreeChanged(final Collection<DataTreeModification<Topology>> changes) {
92 final List<DataObjectModification<Topology>> topoChanges = changes.stream()
93 .map(DataTreeModification::getRootNode)
94 .collect(Collectors.toList());
96 topoChanges.stream().iterator().forEachRemaining(this::handleTopologyChange);
99 private synchronized void handleTopologyChange(final DataObjectModification<Topology> topo) {
100 switch (topo.getModificationType()) {
101 case SUBTREE_MODIFIED:
102 updateTunnelTopologyProvider(topo.getDataAfter());
105 createTunnelTopologyProvider(topo.getDataAfter());
108 removeTunnelTopologyProvider(topo.getDataBefore());
114 private static boolean filterPcepTopologies(final TopologyTypes topologyTypes) {
115 if (topologyTypes == null) {
118 final TopologyTypes1 aug = topologyTypes.augmentation(TopologyTypes1.class);
119 return aug != null && aug.getTopologyTunnelPcep() != null;
122 private synchronized void createTunnelTopologyProvider(final Topology topology) {
123 if (!filterPcepTopologies(topology.getTopologyTypes())) {
126 final TopologyId topologyId = topology.getTopologyId();
127 if (pcepTunnelServices.containsKey(topology.getTopologyId())) {
128 LOG.warn("Tunnel Topology {} already exist. New instance won't be created", topologyId);
131 LOG.debug("Create Tunnel Topology {}", topologyId);
133 final PcepTunnelTopologyConfig config = topology.augmentation(PcepTunnelTopologyConfig.class);
134 final String pcepTopoID = StringUtils
135 .substringBetween(config.getPcepTopologyReference().getValue(), "=\"", "\"");
136 final InstanceIdentifier<Topology> pcepTopoRef = InstanceIdentifier.builder(NetworkTopology.class)
137 .child(Topology.class, new TopologyKey(new TopologyId(pcepTopoID))).build();
140 final PCEPTunnelClusterSingletonService tunnelTopoCss =
141 new PCEPTunnelClusterSingletonService(dependencies, pcepTopoRef, topologyId);
142 pcepTunnelServices.put(topology.getTopologyId(), tunnelTopoCss);
145 private synchronized void updateTunnelTopologyProvider(final Topology topology) {
146 if (!filterPcepTopologies(topology.getTopologyTypes())) {
149 final TopologyId topologyId = topology.getTopologyId();
150 final PCEPTunnelClusterSingletonService previous = pcepTunnelServices.remove(topology.getTopologyId());
151 closeTopology(previous, topologyId);
152 createTunnelTopologyProvider(topology);
155 private synchronized void removeTunnelTopologyProvider(final Topology topo) {
156 if (!filterPcepTopologies(topo.getTopologyTypes())) {
159 final TopologyId topologyId = topo.getTopologyId();
160 final PCEPTunnelClusterSingletonService topology = pcepTunnelServices.remove(topologyId);
161 closeTopology(topology, topologyId);