opendaylight/md-sal/forwardingrules-manager/src/main/java/org/opendaylight/controller/frm/group/GroupProvider.xtend

   1 package org.opendaylight.controller.frm.group
   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.group.service.rev130918.SalGroupService
   7 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group
   8 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node
  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 GroupProvider implements AutoCloseable {
  16
  17     @Property
  18     DataProviderService dataService;
  19
  20     @Property
  21     SalGroupService salGroupService;
  22
  23     GroupCommitHandler commitHandler
  24
  25     Registration<DataCommitHandler<InstanceIdentifier<? extends DataObject>,DataObject>> commitHandlerRegistration;
  26
  27     static val LOG = LoggerFactory.getLogger(GroupProvider);
  28
  29     def void start() {
  30         commitHandler = new GroupCommitHandler(salGroupService)
  31         val InstanceIdentifier<? extends DataObject> path = InstanceIdentifier.builder(Nodes)
  32             .child(Node)
  33             .augmentation(FlowCapableNode)
  34             .child(Group)
  35             .toInstance();
  36         commitHandlerRegistration = dataService.registerCommitHandler(path,commitHandler);
  37         LOG.info("Group 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 }