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 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
  33
  34 class ComponentActivator extends ComponentActivatorAbstractBase implements BindingAwareConsumer {
  35
  36     private BundleContext context;
  37
  38     @Property
  39     FlowProgrammerAdapter flow = new FlowProgrammerAdapter;
  40
  41     @Property
  42     InventoryAndReadAdapter inventory = new InventoryAndReadAdapter;
  43
  44     @Property
  45     DataPacketAdapter dataPacket = new DataPacketAdapter;
  46
  47     @Property
  48     org.opendaylight.controller.sal.utils.INodeFactory nodeFactory = new MDSalNodeFactory
  49
  50     override protected init() {
  51         Node.NodeIDType.registerIDType(MD_SAL_TYPE, NodeKey);
  52         NodeConnector.NodeConnectorIDType.registerIDType(MD_SAL_TYPE, NodeConnectorKey, MD_SAL_TYPE);
  53     }
  54
  55     override start(BundleContext context) {
  56         super.start(context)
  57         this.context = context;
  58     }
  59
  60     def setBroker(BindingAwareBroker broker) {
  61         broker.registerConsumer(this, context)
  62     }
  63
  64     override onSessionInitialized(ConsumerContext session) {
  65         val subscribe = session.getSALService(NotificationService)
  66
  67         // Registration of Flow Service
  68         flow.delegate = session.getRpcService(SalFlowService)
  69         subscribe.registerNotificationListener(flow);
  70
  71         // Data Packet Service
  72         subscribe.registerNotificationListener(inventory);
  73
  74         // Inventory Service
  75         inventory.dataService = session.getSALService(DataBrokerService);
  76         inventory.flowStatisticsService = session.getRpcService(OpendaylightFlowStatisticsService);
  77         inventory.topologyDiscovery = session.getRpcService(FlowTopologyDiscoveryService);
  78
  79         subscribe.registerNotificationListener(dataPacket)
  80
  81     }
  82
  83     override protected getGlobalImplementations() {
  84         return Arrays.asList(this, flow, inventory, dataPacket, nodeFactory)
  85     }
  86
  87     override protected configureGlobalInstance(Component c, Object imp) {
  88         configure(imp, c);
  89     }
  90
  91     private def dispatch configure(MDSalNodeFactory imp, Component it) {
  92         setInterface(org.opendaylight.controller.sal.utils.INodeFactory.name, properties);
  93     }
  94
  95     private def dispatch configure(ComponentActivator imp, Component it) {
  96         add(
  97             createServiceDependency().setService(BindingAwareBroker) //
  98             .setCallbacks("setBroker", "setBroker") //
  99             .setRequired(true))
 100
 101
 102     }
 103
 104     private def dispatch configure(DataPacketAdapter imp, Component it) {
 105         add(
 106             createServiceDependency() //
 107             .setService(IPluginOutDataPacketService) //
 108             .setCallbacks("setDataPacketPublisher", "setDataPacketPublisher") //
 109             .setRequired(false))
 110     }
 111
 112     private def dispatch configure(FlowProgrammerAdapter imp, Component it) {
 113         setInterface(IPluginInFlowProgrammerService.name, properties)
 114         add(
 115             createServiceDependency() //
 116             .setService(IPluginOutFlowProgrammerService) //
 117             .setCallbacks("setFlowProgrammerPublisher", "setFlowProgrammerPublisher") //
 118             .setRequired(false))
 119     }
 120
 121     private def dispatch configure(InventoryAndReadAdapter imp, Component it) {
 122         setInterface(Arrays.asList(IPluginInInventoryService.name, IPluginInReadService.name), properties)
 123         add(
 124             createServiceDependency() //
 125             .setService(IPluginOutReadService) //
 126             .setCallbacks("setReadPublisher", "setReadPublisher") //
 127             .setRequired(false))
 128         add(
 129             createServiceDependency() //
 130             .setService(IPluginOutInventoryService) //
 131             .setCallbacks("setInventoryPublisher", "setInventoryPublisher") //
 132             .setRequired(false))
 133         add(
 134             createServiceDependency() //
 135             .setService(IPluginOutTopologyService) //
 136             .setCallbacks("setTopologyPublisher", "setTopologyPublisher") //
 137             .setRequired(false))
 138         add(
 139             createServiceDependency() //
 140             .setService(IDiscoveryService) //
 141             .setCallbacks("setDiscoveryPublisher", "setDiscoveryPublisher") //
 142             .setRequired(false))
 143
 144     }
 145
 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);
 150         return props;
 151     }
 152 }