opendaylight/md-sal/compatibility/sal-compatibility/src/main/java/org/opendaylight/controller/sal/compatibility/topology/TopologyAdapter.xtend

   1 package org.opendaylight.controller.sal.compatibility.topology
   2
   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
  12
  13 import static extension org.opendaylight.controller.sal.compatibility.topology.TopologyMapping.*
  14
  15 class TopologyAdapter implements IPluginInTopologyService {
  16
  17     @Property
  18     DataProviderService dataService;
  19
  20     @Property
  21     IPluginOutTopologyService topologyPublisher;
  22
  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))
  28     }
  29
  30 }