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

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