opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/BrokerConfigActivator.xtend

   1 package org.opendaylight.controller.sal.dom.broker
   2
   3 import org.osgi.framework.ServiceRegistration
   4 import org.opendaylight.controller.sal.core.api.model.SchemaService
   5 import org.opendaylight.controller.sal.core.api.data.DataBrokerService
   6 import org.opendaylight.controller.sal.core.api.data.DataProviderService
   7 import org.opendaylight.controller.sal.dom.broker.impl.HashMapDataStore
   8 import org.opendaylight.controller.sal.core.api.mount.MountProvisionService
   9 import org.opendaylight.controller.sal.core.api.mount.MountService
  10 import org.osgi.framework.BundleContext
  11 import java.util.Hashtable
  12 import org.opendaylight.yangtools.yang.parser.impl.YangParserImpl
  13 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier
  14 import org.opendaylight.controller.sal.core.api.data.DataStore
  15 import org.opendaylight.controller.sal.dom.broker.impl.SchemaAwareDataStoreAdapter
  16 import org.opendaylight.controller.sal.core.api.model.SchemaServiceListener
  17 import org.opendaylight.controller.sal.dom.broker.impl.RpcRouterImpl
  18
  19 class BrokerConfigActivator implements AutoCloseable {
  20
  21
  22     private static val ROOT = InstanceIdentifier.builder().toInstance();
  23
  24     @Property
  25     private var DataBrokerImpl dataService;
  26
  27     private var ServiceRegistration<SchemaService> schemaReg;
  28     private var ServiceRegistration<DataBrokerService> dataReg;
  29     private var ServiceRegistration<DataProviderService> dataProviderReg;
  30     private var ServiceRegistration<MountService> mountReg;
  31     private var ServiceRegistration<MountProvisionService> mountProviderReg;
  32     private var SchemaServiceImpl schemaService;
  33     private var MountPointManagerImpl mountService;
  34
  35     SchemaAwareDataStoreAdapter wrappedStore
  36
  37     public def void start(BrokerImpl broker,DataStore store,BundleContext context) {
  38         val emptyProperties = new Hashtable<String, String>();
  39         broker.setBundleContext(context);
  40
  41         broker.setRouter(new RpcRouterImpl("Rpc router"))
  42         schemaService = new SchemaServiceImpl();
  43         schemaService.setContext(context);
  44         schemaService.setParser(new YangParserImpl());
  45         schemaService.start();
  46         schemaReg = context.registerService(SchemaService, schemaService, emptyProperties);
  47
  48         dataService = new DataBrokerImpl();
  49         dataService.setExecutor(broker.getExecutor());
  50
  51         dataReg = context.registerService(DataBrokerService, dataService, emptyProperties);
  52         dataProviderReg = context.registerService(DataProviderService, dataService, emptyProperties);
  53
  54         wrappedStore = new SchemaAwareDataStoreAdapter();
  55         wrappedStore.changeDelegate(store);
  56         wrappedStore.setValidationEnabled(false);
  57
  58         context.registerService(SchemaServiceListener,wrappedStore,emptyProperties)
  59
  60         dataService.registerConfigurationReader(ROOT, wrappedStore);
  61         dataService.registerCommitHandler(ROOT, wrappedStore);
  62         dataService.registerOperationalReader(ROOT, wrappedStore);
  63
  64         mountService = new MountPointManagerImpl();
  65         mountService.setDataBroker(dataService);
  66
  67         mountReg = context.registerService(MountService, mountService, emptyProperties);
  68         mountProviderReg =  context.registerService(MountProvisionService, mountService, emptyProperties);
  69     }
  70
  71     override def close() {
  72         schemaReg?.unregister();
  73         dataReg?.unregister();
  74         dataProviderReg?.unregister();
  75         mountReg?.unregister();
  76         mountProviderReg?.unregister();
  77     }
  78
  79 }