1 package org.opendaylight.controller.sal.compatibility.topology
3 import org.opendaylight.controller.sal.binding.api.data.DataProviderService
4 import org.opendaylight.controller.sal.topology.IPluginInTopologyService
5 import org.opendaylight.controller.sal.topology.IPluginOutTopologyService
6 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.NetworkTopology
7 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.TopologyId
8 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.Topology
9 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.TopologyKey
10 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier
12 import static extension org.opendaylight.controller.sal.compatibility.topology.TopologyMapping.*
14 import org.opendaylight.controller.sal.topology.TopoEdgeUpdate
15 import java.util.Collections
17 class TopologyAdapter implements IPluginInTopologyService {
20 DataProviderService dataService;
23 IPluginOutTopologyService topologyPublisher;
25 override sollicitRefresh() {
26 val path = InstanceIdentifier.builder(NetworkTopology).child(Topology,new TopologyKey(new TopologyId("flow:1"))).toInstance;
27 val topology = (dataService.readOperationalData(path) as Topology);
28 topologyPublisher.edgeUpdate(topology.toADEdgeUpdates)