1 package org.opendaylight.controller.sal.compatibility
3 import org.opendaylight.controller.sal.core.ComponentActivatorAbstractBase
4 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey
5 import org.opendaylight.controller.sal.core.Node
6 import org.opendaylight.controller.sal.core.NodeConnector
7 import static org.opendaylight.controller.sal.compatibility.NodeMapping.*
8 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey
9 import org.apache.felix.dm.Component
10 import java.util.Arrays
11 import java.util.Dictionary
12 import java.util.Hashtable
13 import org.opendaylight.controller.sal.utils.GlobalConstants
14 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker
15 import org.opendaylight.controller.sal.flowprogrammer.IPluginInFlowProgrammerService
16 import org.opendaylight.controller.sal.inventory.IPluginInInventoryService
17 import org.opendaylight.controller.sal.reader.IPluginInReadService
18 import org.opendaylight.controller.sal.flowprogrammer.IPluginOutFlowProgrammerService
19 import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer
20 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowService
22 import org.opendaylight.controller.sal.binding.api.NotificationService
23 import org.opendaylight.controller.sal.binding.api.data.DataBrokerService
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.OpendaylightFlowStatisticsService
25 import org.opendaylight.controller.sal.packet.IPluginOutDataPacketService
26 import org.osgi.framework.BundleContext
27 import org.opendaylight.controller.sal.reader.IPluginOutReadService
28 import org.opendaylight.controller.sal.inventory.IPluginOutInventoryService
29 import org.opendaylight.controller.sal.discovery.IDiscoveryService
30 import org.opendaylight.controller.sal.topology.IPluginOutTopologyService
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.FlowTopologyDiscoveryService
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.table.statistics.rev131215.OpendaylightFlowTableStatisticsService
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.OpendaylightPortStatisticsService
34 import org.opendaylight.controller.sal.binding.api.data.DataProviderService
36 class ComponentActivator extends ComponentActivatorAbstractBase implements BindingAwareConsumer {
38 private BundleContext context;
41 FlowProgrammerAdapter flow = new FlowProgrammerAdapter;
44 InventoryAndReadAdapter inventory = new InventoryAndReadAdapter;
47 DataPacketAdapter dataPacket = new DataPacketAdapter;
50 org.opendaylight.controller.sal.utils.INodeFactory nodeFactory = new MDSalNodeFactory
53 org.opendaylight.controller.sal.utils.INodeConnectorFactory nodeConnectorFactory = new MDSalNodeConnectorFactory
56 override protected init() {
57 Node.NodeIDType.registerIDType(MD_SAL_TYPE, String);
58 NodeConnector.NodeConnectorIDType.registerIDType(MD_SAL_TYPE, String, MD_SAL_TYPE);
61 override start(BundleContext context) {
63 this.context = context;
66 def setBroker(BindingAwareBroker broker) {
67 broker.registerConsumer(this, context)
70 override onSessionInitialized(ConsumerContext session) {
71 val subscribe = session.getSALService(NotificationService)
73 // Registration of Flow Service
74 flow.delegate = session.getRpcService(SalFlowService)
75 subscribe.registerNotificationListener(flow);
77 // Data Packet Service
78 subscribe.registerNotificationListener(inventory);
81 inventory.dataService = session.getSALService(DataBrokerService);
82 inventory.flowStatisticsService = session.getRpcService(OpendaylightFlowStatisticsService);
83 inventory.flowTableStatisticsService = session.getRpcService(OpendaylightFlowTableStatisticsService);
84 inventory.nodeConnectorStatisticsService = session.getRpcService(OpendaylightPortStatisticsService);
85 inventory.topologyDiscovery = session.getRpcService(FlowTopologyDiscoveryService);
86 inventory.dataProviderService = session.getSALService(DataProviderService)
88 subscribe.registerNotificationListener(dataPacket)
92 override protected getGlobalImplementations() {
93 return Arrays.asList(this, flow, inventory, dataPacket, nodeFactory, nodeConnectorFactory)
96 override protected configureGlobalInstance(Component c, Object imp) {
100 private def dispatch configure(MDSalNodeFactory imp, Component it) {
101 setInterface(org.opendaylight.controller.sal.utils.INodeFactory.name, properties);
104 private def dispatch configure(MDSalNodeConnectorFactory imp, Component it) {
105 setInterface(org.opendaylight.controller.sal.utils.INodeConnectorFactory.name, properties);
108 private def dispatch configure(ComponentActivator imp, Component it) {
110 createServiceDependency().setService(BindingAwareBroker) //
111 .setCallbacks("setBroker", "setBroker") //
117 private def dispatch configure(DataPacketAdapter imp, Component it) {
119 createServiceDependency() //
120 .setService(IPluginOutDataPacketService) //
121 .setCallbacks("setDataPacketPublisher", "setDataPacketPublisher") //
125 private def dispatch configure(FlowProgrammerAdapter imp, Component it) {
126 setInterface(IPluginInFlowProgrammerService.name, properties)
128 createServiceDependency() //
129 .setService(IPluginOutFlowProgrammerService) //
130 .setCallbacks("setFlowProgrammerPublisher", "setFlowProgrammerPublisher") //
134 private def dispatch configure(InventoryAndReadAdapter imp, Component it) {
135 setInterface(Arrays.asList(IPluginInInventoryService.name, IPluginInReadService.name), properties)
137 createServiceDependency() //
138 .setService(IPluginOutReadService) //
139 .setCallbacks("setReadPublisher", "unsetReadPublisher") //
142 createServiceDependency() //
143 .setService(IPluginOutInventoryService) //
144 .setCallbacks("setInventoryPublisher", "setInventoryPublisher") //
147 createServiceDependency() //
148 .setService(IPluginOutTopologyService) //
149 .setCallbacks("setTopologyPublisher", "setTopologyPublisher") //
152 createServiceDependency() //
153 .setService(IDiscoveryService) //
154 .setCallbacks("setDiscoveryPublisher", "setDiscoveryPublisher") //
159 private def Dictionary<String, Object> properties() {
160 val props = new Hashtable<String, Object>();
161 props.put(GlobalConstants.PROTOCOLPLUGINTYPE.toString, MD_SAL_TYPE)
162 props.put("protocolName", MD_SAL_TYPE);