opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/connect/dom/ConnectorActivator.java

   1 package org.opendaylight.controller.sal.binding.impl.connect.dom;
   2
   3 import java.util.Collection;
   4 import java.util.Collections;
   5
   6 import javassist.ClassPool;
   7
   8 import org.opendaylight.controller.sal.binding.api.data.DataProviderService;
   9 import org.opendaylight.controller.sal.binding.dom.serializer.impl.RuntimeGeneratedMappingServiceImpl;
  10 import org.opendaylight.controller.sal.binding.dom.serializer.impl.TransformerGenerator;
  11 import org.opendaylight.controller.sal.core.api.Broker;
  12 import org.opendaylight.controller.sal.core.api.Provider;
  13 import org.opendaylight.controller.sal.core.api.Broker.ProviderSession;
  14 import org.opendaylight.controller.sal.core.api.data.DataBrokerService;
  15 import org.opendaylight.controller.sal.core.api.model.SchemaService;
  16 import org.osgi.framework.BundleContext;
  17 import org.osgi.framework.ServiceReference;
  18 import org.osgi.util.tracker.ServiceTracker;
  19 import org.osgi.util.tracker.ServiceTrackerCustomizer;
  20
  21 public class ConnectorActivator implements Provider, ServiceTrackerCustomizer<Broker, Broker> {
  22
  23     BindingIndependentDataServiceConnector dataConnector;
  24     BindingIndependentMappingService mappingService;
  25
  26     private final DataProviderService baDataService;
  27     private BundleContext context;
  28
  29     private ServiceTracker<Broker, Broker> brokerTracker;
  30
  31     public ConnectorActivator(DataProviderService dataService, BundleContext context) {
  32         baDataService = dataService;
  33         this.context = context;
  34         brokerTracker = new ServiceTracker<>(context, Broker.class, this);
  35     }
  36
  37     @Override
  38     public Collection<ProviderFunctionality> getProviderFunctionality() {
  39         return Collections.emptySet();
  40     }
  41
  42     @Override
  43     public void onSessionInitiated(ProviderSession session) {
  44
  45         RuntimeGeneratedMappingServiceImpl mappingImpl = new RuntimeGeneratedMappingServiceImpl();
  46         mappingImpl.setPool(new ClassPool());
  47         SchemaService schemaService = (session.getService(SchemaService.class));
  48         ClassPool pool = new ClassPool();
  49         mappingImpl.setBinding(new TransformerGenerator(pool));
  50         mappingImpl.start();
  51         schemaService.registerSchemaServiceListener(mappingImpl);
  52         mappingService = mappingImpl;
  53         dataConnector = new BindingIndependentDataServiceConnector();
  54         dataConnector.setBaDataService(baDataService);
  55         dataConnector.setBiDataService(session.getService(DataBrokerService.class));
  56         dataConnector.setMappingService(mappingService);
  57         dataConnector.start();
  58     }
  59
  60     @Override
  61     public Broker addingService(ServiceReference<Broker> reference) {
  62         Broker br= context.getService(reference);
  63         br.registerProvider(this, context);
  64         return br;
  65     }
  66
  67     @Override
  68     public void modifiedService(ServiceReference<Broker> reference, Broker service) {
  69         // NOOP
  70     }
  71
  72     @Override
  73     public void removedService(ServiceReference<Broker> reference, Broker service) {
  74         // NOOP
  75     }
  76
  77     public void start() {
  78         brokerTracker.open();
  79     }
  80 }