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

   1 package org.opendaylight.controller.sal.compatibility.topology
   2
   3 import com.google.common.collect.FluentIterable
   4 import java.util.concurrent.CopyOnWriteArrayList
   5 import org.opendaylight.controller.md.sal.binding.util.TypeSafeDataReader
   6 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler
   7 import org.opendaylight.controller.md.sal.common.api.data.DataModification
   8 import org.opendaylight.controller.sal.binding.api.data.DataProviderService
   9 import org.opendaylight.controller.sal.core.UpdateType
  10 import org.opendaylight.controller.sal.topology.IPluginOutTopologyService
  11 import org.opendaylight.controller.sal.topology.TopoEdgeUpdate
  12 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.NetworkTopology
  13 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.TopologyId
  14 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.Topology
  15 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.TopologyKey
  16 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.Link
  17 import org.opendaylight.yangtools.yang.binding.DataObject
  18 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier
  19 import static extension org.opendaylight.controller.sal.compatibility.topology.TopologyMapping.*
  20 import org.slf4j.LoggerFactory
  21
  22 class TopologyCommitHandler implements DataCommitHandler<InstanceIdentifier<? extends DataObject>, DataObject> {
  23     static val LOG = LoggerFactory.getLogger(TopologyCommitHandler);
  24     @Property
  25     IPluginOutTopologyService topologyPublisher;
  26
  27     @Property
  28     DataProviderService dataService;
  29
  30     new(DataProviderService dataService) {
  31         _topologyPublisher = topologyPublisher
  32         _dataService = dataService
  33     }
  34
  35     override requestCommit(DataModification<InstanceIdentifier<? extends DataObject>, DataObject> modification) {
  36         val msg = new CopyOnWriteArrayList<TopoEdgeUpdate>()
  37         try {
  38             val reader = TypeSafeDataReader.forReader(dataService)
  39             val topologyPath = InstanceIdentifier.builder(NetworkTopology).child(Topology, new TopologyKey(new TopologyId("flow:1"))).toInstance
  40             val topology = reader.readOperationalData(topologyPath)
  41             val adds = FluentIterable.from(modification.createdOperationalData.entrySet)
  42                 .filter[value instanceof Link]
  43                 .transform[(value as Link).toAdEdge(topology).toTopoEdgeUpdate(UpdateType.ADDED,reader)]
  44                 .toList
  45             val updates = FluentIterable.from(modification.updatedOperationalData.entrySet)
  46                 .filter[!modification.createdOperationalData.containsKey(key) && (value instanceof Link)]
  47                 .transform[(value as Link).toAdEdge(topology).toTopoEdgeUpdate(UpdateType.ADDED,reader)] // Evidently the ADSAL does not expect edge 'CHANGED"
  48                 .toList
  49             val removes = FluentIterable.from(modification.removedOperationalData)
  50                 .transform[reader.readOperationalData(it as InstanceIdentifier<DataObject>)]
  51                 .filter[it instanceof Link]
  52                 .transform[(it as Link).toAdEdge(topology).toTopoEdgeUpdate(UpdateType.REMOVED,reader)]
  53                 .toList
  54             msg.addAll(adds)
  55             msg.addAll(updates)
  56             msg.addAll(removes)
  57          } catch (Exception e) {
  58             LOG.error("Exception caught",e)
  59          }
  60         return new TopologyTransaction(modification,topologyPublisher,dataService,msg)
  61     }
  62 }