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

   1 /**
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.controller.sal.compatibility;
   9
  10 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  11 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
  12 import org.opendaylight.controller.sal.binding.api.BindingAwareProvider;
  13 import org.opendaylight.controller.sal.binding.api.NotificationService;
  14 import org.opendaylight.controller.sal.binding.api.data.DataBrokerService;
  15 import org.opendaylight.controller.sal.binding.api.data.DataProviderService;
  16 import org.opendaylight.controller.sal.compatibility.adsal.DataPacketServiceAdapter;
  17 import org.opendaylight.controller.sal.compatibility.topology.TopologyAdapter;
  18 import org.opendaylight.controller.sal.compatibility.topology.TopologyProvider;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowService;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.OpendaylightFlowStatisticsService;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.table.statistics.rev131215.OpendaylightFlowTableStatisticsService;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.FlowTopologyDiscoveryService;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingService;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.OpendaylightPortStatisticsService;
  25
  26 import com.google.common.base.Preconditions;
  27
  28 class SalCompatibilityProvider implements BindingAwareProvider {
  29     private final ComponentActivator activator;
  30
  31     public SalCompatibilityProvider(final ComponentActivator cmpAct) {
  32         this.activator = Preconditions.checkNotNull(cmpAct);
  33     }
  34
  35     @Override
  36     public void onSessionInitiated(final ProviderContext session) {
  37         final NotificationService subscribe = session.getSALService(NotificationService.class);
  38
  39         final FlowProgrammerAdapter flow = activator.getFlow();
  40         flow.setDelegate(session.getRpcService(SalFlowService.class));
  41         flow.setDataBrokerService(session.getSALService(DataBrokerService.class));
  42         // FIXME: remember registration for clean shutdown
  43         subscribe.registerNotificationListener(flow);
  44
  45         final InventoryAndReadAdapter inv = activator.getInventory();
  46         inv.setDataService(session.getSALService(DataBrokerService.class));
  47         inv.setFlowStatisticsService(session.getRpcService(OpendaylightFlowStatisticsService.class));
  48         inv.setFlowTableStatisticsService(session.getRpcService(OpendaylightFlowTableStatisticsService.class));
  49         inv.setNodeConnectorStatisticsService(session.getRpcService(OpendaylightPortStatisticsService.class));
  50         inv.setTopologyDiscovery(session.getRpcService(FlowTopologyDiscoveryService.class));
  51         inv.setDataProviderService(session.getSALService(DataProviderService.class));
  52
  53         final NodeDataChangeListener ndcl = new NodeDataChangeListener(inv,session.getSALService(DataBroker.class));
  54         final NCDataChangeListener ncdcl = new NCDataChangeListener(inv,session.getSALService(DataBroker.class));
  55
  56         // FIXME: remember registration for clean shutdown
  57         subscribe.registerNotificationListener(inv);
  58
  59         final DataPacketServiceAdapter dps = activator.getDataPacketService();
  60         dps.setDelegate(session.getRpcService(PacketProcessingService.class));
  61
  62         final TopologyAdapter topo = activator.getTopology();
  63         topo.setDataService(session.getSALService(DataProviderService.class));
  64
  65         final TopologyProvider tpp = activator.getTpProvider();
  66         tpp.setDataService(session.getSALService(DataProviderService.class));
  67
  68         inv.startAdapter();
  69         tpp.startAdapter();
  70
  71         subscribe.registerNotificationListener(activator.getDataPacket());
  72     }
  73 }