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