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 org.opendaylight.yangtools.yang.binding.NotificationListener
12 import java.util.Dictionary
13 import java.util.Hashtable
14 import org.opendaylight.controller.sal.utils.GlobalConstants
15 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker
16 import org.opendaylight.controller.sal.flowprogrammer.IPluginInFlowProgrammerService
17 import org.opendaylight.controller.sal.inventory.IPluginInInventoryService
18 import org.opendaylight.controller.sal.reader.IPluginInReadService
19 import org.opendaylight.controller.sal.flowprogrammer.IPluginOutFlowProgrammerService
20 import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer
21 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowService
23 import org.opendaylight.controller.sal.binding.api.NotificationService
24 import org.opendaylight.controller.sal.binding.api.data.DataBrokerService
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.OpendaylightFlowStatisticsService
26 import org.opendaylight.controller.sal.packet.IPluginOutDataPacketService
27 import org.osgi.framework.BundleContext
28 import org.opendaylight.controller.sal.reader.IPluginOutReadService
29 import org.opendaylight.controller.sal.inventory.IPluginOutInventoryService
30 import org.opendaylight.controller.sal.discovery.IDiscoveryService
31 import org.opendaylight.controller.sal.topology.IPluginOutTopologyService
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.FlowTopologyDiscoveryService
34 class ComponentActivator extends ComponentActivatorAbstractBase implements BindingAwareConsumer {
36 private BundleContext context;
39 FlowProgrammerAdapter flow = new FlowProgrammerAdapter;
42 InventoryAndReadAdapter inventory = new InventoryAndReadAdapter;
45 DataPacketAdapter dataPacket = new DataPacketAdapter;
48 org.opendaylight.controller.sal.utils.INodeFactory nodeFactory = new MDSalNodeFactory
50 override protected init() {
51 Node.NodeIDType.registerIDType(MD_SAL_TYPE, NodeKey);
52 NodeConnector.NodeConnectorIDType.registerIDType(MD_SAL_TYPE, NodeConnectorKey, MD_SAL_TYPE);
55 override start(BundleContext context) {
57 this.context = context;
60 def setBroker(BindingAwareBroker broker) {
61 broker.registerConsumer(this, context)
64 override onSessionInitialized(ConsumerContext session) {
65 val subscribe = session.getSALService(NotificationService)
67 // Registration of Flow Service
68 flow.delegate = session.getRpcService(SalFlowService)
69 subscribe.registerNotificationListener(flow);
71 // Data Packet Service
72 subscribe.registerNotificationListener(inventory);
75 inventory.dataService = session.getSALService(DataBrokerService);
76 inventory.flowStatisticsService = session.getRpcService(OpendaylightFlowStatisticsService);
77 inventory.topologyDiscovery = session.getRpcService(FlowTopologyDiscoveryService);
79 subscribe.registerNotificationListener(dataPacket)
83 override protected getGlobalImplementations() {
84 return Arrays.asList(this, flow, inventory, dataPacket, nodeFactory)
87 override protected configureGlobalInstance(Component c, Object imp) {
91 private def dispatch configure(MDSalNodeFactory imp, Component it) {
92 setInterface(org.opendaylight.controller.sal.utils.INodeFactory.name, properties);
95 private def dispatch configure(ComponentActivator imp, Component it) {
97 createServiceDependency().setService(BindingAwareBroker) //
98 .setCallbacks("setBroker", "setBroker") //
104 private def dispatch configure(DataPacketAdapter imp, Component it) {
106 createServiceDependency() //
107 .setService(IPluginOutDataPacketService) //
108 .setCallbacks("setDataPacketPublisher", "setDataPacketPublisher") //
112 private def dispatch configure(FlowProgrammerAdapter imp, Component it) {
113 setInterface(IPluginInFlowProgrammerService.name, properties)
115 createServiceDependency() //
116 .setService(IPluginOutFlowProgrammerService) //
117 .setCallbacks("setFlowProgrammerPublisher", "setFlowProgrammerPublisher") //
121 private def dispatch configure(InventoryAndReadAdapter imp, Component it) {
122 setInterface(Arrays.asList(IPluginInInventoryService.name, IPluginInReadService.name), properties)
124 createServiceDependency() //
125 .setService(IPluginOutReadService) //
126 .setCallbacks("setReadPublisher", "setReadPublisher") //
129 createServiceDependency() //
130 .setService(IPluginOutInventoryService) //
131 .setCallbacks("setInventoryPublisher", "setInventoryPublisher") //
134 createServiceDependency() //
135 .setService(IPluginOutTopologyService) //
136 .setCallbacks("setTopologyPublisher", "setTopologyPublisher") //
139 createServiceDependency() //
140 .setService(IDiscoveryService) //
141 .setCallbacks("setDiscoveryPublisher", "setDiscoveryPublisher") //
146 private def Dictionary<String, Object> properties() {
147 val props = new Hashtable<String, Object>();
148 props.put(GlobalConstants.PROTOCOLPLUGINTYPE.toString, MD_SAL_TYPE)
149 props.put("protocolName", MD_SAL_TYPE);