opendaylight/md-sal/compatibility/sal-compatibility/src/main/java/org/opendaylight/controller/sal/compatibility/ComponentActivator.xtend

   1 package org.opendaylight.controller.sal.compatibility
   2
   3 import java.util.Arrays
   4 import java.util.Dictionary
   5 import java.util.Hashtable
   6 import org.apache.felix.dm.Component
   7 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker
   8 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext
   9 import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer
  10 import org.opendaylight.controller.sal.binding.api.NotificationService
  11 import org.opendaylight.controller.sal.binding.api.data.DataBrokerService
  12 import org.opendaylight.controller.sal.binding.api.data.DataProviderService
  13 import org.opendaylight.controller.sal.compatibility.topology.TopologyAdapter
  14 import org.opendaylight.controller.sal.core.ComponentActivatorAbstractBase
  15 import org.opendaylight.controller.sal.core.Node
  16 import org.opendaylight.controller.sal.core.NodeConnector
  17 import org.opendaylight.controller.sal.discovery.IDiscoveryService
  18 import org.opendaylight.controller.sal.flowprogrammer.IPluginInFlowProgrammerService
  19 import org.opendaylight.controller.sal.flowprogrammer.IPluginOutFlowProgrammerService
  20 import org.opendaylight.controller.sal.inventory.IPluginInInventoryService
  21 import org.opendaylight.controller.sal.inventory.IPluginOutInventoryService
  22 import org.opendaylight.controller.sal.packet.IPluginOutDataPacketService
  23 import org.opendaylight.controller.sal.reader.IPluginInReadService
  24 import org.opendaylight.controller.sal.reader.IPluginOutReadService
  25 import org.opendaylight.controller.sal.topology.IPluginInTopologyService
  26 import org.opendaylight.controller.sal.topology.IPluginOutTopologyService
  27 import org.opendaylight.controller.sal.utils.GlobalConstants
  28 import org.opendaylight.controller.sal.utils.INodeConnectorFactory
  29 import org.opendaylight.controller.sal.utils.INodeFactory
  30 import org.opendaylight.controller.clustering.services.IClusterGlobalServices
  31
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowService
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.OpendaylightFlowStatisticsService
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.table.statistics.rev131215.OpendaylightFlowTableStatisticsService
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.FlowTopologyDiscoveryService
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.OpendaylightPortStatisticsService
  37 import org.osgi.framework.BundleContext
  38
  39 import static org.opendaylight.controller.sal.compatibility.NodeMapping.*
  40 import org.opendaylight.controller.sal.compatibility.topology.TopologyProvider
  41
  42 class ComponentActivator extends ComponentActivatorAbstractBase implements BindingAwareConsumer {
  43
  44     private BundleContext context;
  45
  46     @Property
  47     FlowProgrammerAdapter flow = new FlowProgrammerAdapter;
  48
  49     @Property
  50     InventoryAndReadAdapter inventory = new InventoryAndReadAdapter;
  51
  52     @Property
  53     DataPacketAdapter dataPacket = new DataPacketAdapter;
  54
  55     @Property
  56     INodeFactory nodeFactory = new MDSalNodeFactory
  57
  58     @Property
  59     INodeConnectorFactory nodeConnectorFactory = new MDSalNodeConnectorFactory
  60
  61     @Property
  62     TopologyAdapter topology = new TopologyAdapter
  63
  64     @Property
  65     TopologyProvider tpProvider = new TopologyProvider()
  66
  67
  68     override protected init() {
  69         Node.NodeIDType.registerIDType(MD_SAL_TYPE, String);
  70         NodeConnector.NodeConnectorIDType.registerIDType(MD_SAL_TYPE, String, MD_SAL_TYPE);
  71     }
  72
  73     override start(BundleContext context) {
  74         super.start(context)
  75         this.context = context;
  76     }
  77
  78     def setBroker(BindingAwareBroker broker) {
  79         broker.registerConsumer(this, context)
  80     }
  81
  82     override onSessionInitialized(ConsumerContext session) {
  83         val subscribe = session.getSALService(NotificationService)
  84
  85         // Registration of Flow Service
  86         flow.delegate = session.getRpcService(SalFlowService)
  87         flow.dataBrokerService = session.getSALService(DataBrokerService);
  88         subscribe.registerNotificationListener(flow);
  89
  90         // Data Packet Service
  91         subscribe.registerNotificationListener(inventory);
  92
  93         // Inventory Service
  94         inventory.dataService = session.getSALService(DataBrokerService);
  95         inventory.flowStatisticsService = session.getRpcService(OpendaylightFlowStatisticsService);
  96         inventory.flowTableStatisticsService = session.getRpcService(OpendaylightFlowTableStatisticsService);
  97         inventory.nodeConnectorStatisticsService = session.getRpcService(OpendaylightPortStatisticsService);
  98         inventory.topologyDiscovery = session.getRpcService(FlowTopologyDiscoveryService);
  99                 inventory.dataProviderService = session.getSALService(DataProviderService)
 100                 topology.dataService = session.getSALService(DataProviderService)
 101                 tpProvider.dataService = session.getSALService(DataProviderService)
 102                 tpProvider.start();
 103
 104         subscribe.registerNotificationListener(dataPacket)
 105
 106     }
 107
 108     override protected getGlobalImplementations() {
 109         return Arrays.asList(this, flow, inventory, dataPacket, nodeFactory, nodeConnectorFactory,topology,tpProvider)
 110     }
 111
 112     override protected configureGlobalInstance(Component c, Object imp) {
 113         configure(imp, c);
 114     }
 115
 116     private def dispatch configure(MDSalNodeFactory imp, Component it) {
 117         setInterface(INodeFactory.name, properties);
 118     }
 119
 120     private def dispatch configure(MDSalNodeConnectorFactory imp, Component it) {
 121         setInterface(INodeConnectorFactory.name, properties);
 122     }
 123
 124     private def dispatch configure(ComponentActivator imp, Component it) {
 125         add(
 126             createServiceDependency().setService(BindingAwareBroker) //
 127             .setCallbacks("setBroker", "setBroker") //
 128             .setRequired(true))
 129
 130
 131     }
 132
 133     private def dispatch configure(DataPacketAdapter imp, Component it) {
 134         add(
 135             createServiceDependency() //
 136             .setService(IPluginOutDataPacketService) //
 137             .setCallbacks("setDataPacketPublisher", "setDataPacketPublisher") //
 138             .setRequired(false))
 139     }
 140
 141     private def dispatch configure(FlowProgrammerAdapter imp, Component it) {
 142         setInterface(IPluginInFlowProgrammerService.name, properties)
 143         add(
 144             createServiceDependency() //
 145             .setService(IPluginOutFlowProgrammerService) //
 146             .setCallbacks("setFlowProgrammerPublisher", "setFlowProgrammerPublisher") //
 147             .setRequired(false))
 148
 149         add(
 150             createServiceDependency() //
 151             .setService(IClusterGlobalServices) //
 152             .setCallbacks("setClusterGlobalServices", "unsetClusterGlobalServices") //
 153             .setRequired(false))
 154
 155     }
 156
 157     private def dispatch configure(InventoryAndReadAdapter imp, Component it) {
 158         setInterface(Arrays.asList(IPluginInInventoryService.name, IPluginInReadService.name), properties)
 159         add(
 160             createServiceDependency() //
 161             .setService(IPluginOutReadService) //
 162             .setCallbacks("setReadPublisher", "unsetReadPublisher") //
 163             .setRequired(false))
 164         add(
 165             createServiceDependency() //
 166             .setService(IPluginOutInventoryService) //
 167             .setCallbacks("setInventoryPublisher", "setInventoryPublisher") //
 168             .setRequired(false))
 169         add(
 170             createServiceDependency() //
 171             .setService(IDiscoveryService) //
 172             .setCallbacks("setDiscoveryPublisher", "setDiscoveryPublisher") //
 173             .setRequired(false))
 174
 175
 176     }
 177
 178     private def dispatch configure (TopologyAdapter imp, Component it) {
 179         setInterface(Arrays.asList(IPluginInTopologyService.name), properties)
 180         add(
 181             createServiceDependency() //
 182             .setService(IPluginOutTopologyService) //
 183             .setCallbacks("setTopologyPublisher", "setTopologyPublisher") //
 184             .setRequired(false))
 185     }
 186
 187     private def dispatch configure (TopologyProvider imp, Component it) {
 188         add(
 189             createServiceDependency() //
 190             .setService(IPluginOutTopologyService) //
 191             .setCallbacks("setTopologyPublisher", "setTopologyPublisher") //
 192             .setRequired(false))
 193     }
 194
 195     private def Dictionary<String, Object> properties() {
 196         val props = new Hashtable<String, Object>();
 197         props.put(GlobalConstants.PROTOCOLPLUGINTYPE.toString, MD_SAL_TYPE)
 198         props.put("protocolName", MD_SAL_TYPE);
 199         return props;
 200     }
 201 }