opendaylight/md-sal/forwardingrules-manager/src/main/java/org/opendaylight/controller/frm/flow/FlowProvider.xtend

   1 package org.opendaylight.controller.frm.flow
   2
   3 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler
   4 import org.opendaylight.controller.sal.binding.api.data.DataProviderService
   5 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode
   6 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.Table
   7 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow
   8 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowService
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node
  11 import org.opendaylight.yangtools.concepts.Registration
  12 import org.opendaylight.yangtools.yang.binding.DataObject
  13 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier
  14 import org.slf4j.LoggerFactory
  15
  16 class FlowProvider implements AutoCloseable {
  17
  18     @Property
  19     DataProviderService dataService;
  20
  21     @Property
  22     SalFlowService salFlowService;
  23
  24     FlowCommitHandler commitHandler
  25
  26     Registration<DataCommitHandler<InstanceIdentifier<? extends DataObject>,DataObject>> commitHandlerRegistration;
  27
  28     static val LOG = LoggerFactory.getLogger(FlowProvider);
  29
  30     def void start() {
  31         commitHandler = new FlowCommitHandler(salFlowService)
  32         val InstanceIdentifier<? extends DataObject> path = InstanceIdentifier.builder(Nodes)
  33             .child(Node)
  34             .augmentation(FlowCapableNode)
  35             .child(Table)
  36             .child(Flow)
  37             .toInstance();
  38         commitHandlerRegistration = dataService.registerCommitHandler(path,commitHandler);
  39         LOG.info("Flow Config Provider started.");
  40     }
  41
  42     protected def startChange() {
  43         return dataService.beginTransaction;
  44     }
  45
  46     override close() throws Exception {
  47         throw new UnsupportedOperationException("TODO: auto-generated method stub")
  48     }
  49
  50 }