1 package org.opendaylight.controller.sal.compatibility.topology
3 import org.opendaylight.controller.md.sal.binding.util.TypeSafeDataReader
4 import org.opendaylight.controller.sal.binding.api.data.DataProviderService
5 import org.opendaylight.controller.sal.topology.IPluginInTopologyService
6 import org.opendaylight.controller.sal.topology.IPluginOutTopologyService
7 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology
8 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId
9 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology
10 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey
11 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier
13 import static extension org.opendaylight.controller.sal.compatibility.topology.TopologyMapping.*
15 class TopologyAdapter implements IPluginInTopologyService {
18 DataProviderService dataService;
21 IPluginOutTopologyService topologyPublisher;
23 override sollicitRefresh() {
24 val path = InstanceIdentifier.builder(NetworkTopology).child(Topology,new TopologyKey(new TopologyId("flow:1"))).toInstance;
25 val reader = TypeSafeDataReader.forReader(dataService)
26 val topology = reader.readOperationalData(path)
27 topologyPublisher.edgeUpdate(topology.toADEdgeUpdates(reader))