opendaylight/md-sal/forwardingrules-manager/src/main/java/org/opendaylight/controller/frm/meter/MeterProvider.xtend

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