lighty/src/main/java/io/lighty/controllers/tpce/module/TransportPCEImpl.java

   1 /*
   2  * Copyright (c) 2018 Pantheon Technologies s.r.o. 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 https://www.eclipse.org/legal/epl-v10.html
   7  */
   8
   9 package io.lighty.controllers.tpce.module;
  10
  11 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl;
  12 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl121;
  13 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl221;
  14 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
  15 import org.opendaylight.transportpce.common.fixedflex.FixedFlexImpl;
  16 import org.opendaylight.transportpce.common.mapping.MappingUtilsImpl;
  17 import org.opendaylight.transportpce.common.mapping.PortMappingImpl;
  18 import org.opendaylight.transportpce.common.mapping.PortMappingVersion121;
  19 import org.opendaylight.transportpce.common.mapping.PortMappingVersion221;
  20 import org.opendaylight.transportpce.common.network.NetworkTransactionImpl;
  21 import org.opendaylight.transportpce.common.network.RequestProcessor;
  22 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
  23 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl121;
  24 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl221;
  25 import org.opendaylight.transportpce.networkmodel.NetConfTopologyListener;
  26 import org.opendaylight.transportpce.networkmodel.NetworkModelProvider;
  27 import org.opendaylight.transportpce.networkmodel.NetworkUtilsImpl;
  28 import org.opendaylight.transportpce.networkmodel.R2RLinkDiscovery;
  29 import org.opendaylight.transportpce.networkmodel.service.NetworkModelServiceImpl;
  30 import org.opendaylight.transportpce.olm.OlmPowerServiceRpcImpl;
  31 import org.opendaylight.transportpce.olm.OlmProvider;
  32 import org.opendaylight.transportpce.olm.power.PowerMgmt;
  33 import org.opendaylight.transportpce.olm.power.PowerMgmtImpl;
  34 import org.opendaylight.transportpce.olm.service.OlmPowerServiceImpl;
  35 import org.opendaylight.transportpce.pce.impl.PceProvider;
  36 import org.opendaylight.transportpce.pce.service.PathComputationServiceImpl;
  37 import org.opendaylight.transportpce.renderer.NetworkModelWavelengthServiceImpl;
  38 import org.opendaylight.transportpce.renderer.RendererProvider;
  39 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface121;
  40 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface221;
  41 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
  42 // Adding OTN interface
  43 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmOtnInterface221;
  44 import org.opendaylight.transportpce.renderer.provisiondevice.DeviceRendererServiceImpl;
  45 // Add OTN
  46 import org.opendaylight.transportpce.renderer.provisiondevice.OtnDeviceRendererServiceImpl;
  47 import org.opendaylight.transportpce.renderer.provisiondevice.RendererServiceOperationsImpl;
  48 import org.opendaylight.transportpce.renderer.rpcs.DeviceRendererRPCImpl;
  49 import org.opendaylight.transportpce.servicehandler.impl.ServicehandlerProvider;
  50 import org.opendaylight.transportpce.servicehandler.listeners.PceListenerImpl;
  51 import org.opendaylight.transportpce.servicehandler.listeners.RendererListenerImpl;
  52 import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperations;
  53 import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperationsImpl;
  54 import org.opendaylight.transportpce.servicehandler.service.ServiceHandlerOperations;
  55 import org.opendaylight.transportpce.servicehandler.service.ServiceHandlerOperationsImpl;
  56 import org.opendaylight.transportpce.tapi.impl.TapiProvider;
  57 import org.opendaylight.transportpce.tapi.utils.TapiListener;
  58 import org.slf4j.Logger;
  59 import org.slf4j.LoggerFactory;
  60
  61 import io.lighty.core.controller.api.AbstractLightyModule;
  62 import io.lighty.core.controller.api.LightyServices;
  63
  64 public class TransportPCEImpl extends AbstractLightyModule implements TransportPCE {
  65
  66     private static final Logger LOG = LoggerFactory.getLogger(TransportPCEImpl.class);
  67     private static final long MaxDurationToSubmitTransaction = 1500;
  68
  69     // common beans
  70     private final DeviceTransactionManagerImpl deviceTransactionManager;
  71     private final MappingUtilsImpl mappingUtils;
  72     private final OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
  73     private final OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
  74     private final OpenRoadmInterfacesImpl openRoadmInterfaces;
  75     private final PortMappingVersion221 portMappingVersion221;
  76     private final RequestProcessor requestProcessor;
  77     private final NetworkTransactionImpl networkTransaction;
  78     private final PortMappingVersion121 portMappingVersion121;
  79     private final PortMappingImpl portMapping;
  80     private final CrossConnectImpl121 crossConnectImpl121;
  81     private final CrossConnectImpl221 crossConnectImpl221;
  82     private final CrossConnectImpl crossConnect;
  83     private final FixedFlexImpl fixedFlex;
  84
  85     // pce beans
  86     private final PathComputationServiceImpl pathComputationService;
  87     private final PceProvider pceProvider;
  88
  89     // network model beans
  90     // private final OpenRoadmTopology22 openRoadmTopology22;
  91     // private final OpenRoadmFactory openRoadmFactory;
  92     // private final OpenRoadmTopology openRoadmTopology;
  93
  94     private final R2RLinkDiscovery linkDiscoveryImpl;
  95     private final NetworkUtilsImpl networkutilsServiceImpl;
  96     private final NetworkModelServiceImpl networkModelService;
  97     private final NetConfTopologyListener netConfTopologyListener;
  98     private final NetworkModelProvider networkModelProvider;
  99
 100     // OLM beans
 101     private final PowerMgmt powerMgmt;
 102     private final OlmPowerServiceImpl olmPowerService;
 103     private final OlmProvider olmProvider;
 104     private final OlmPowerServiceRpcImpl olmPowerServiceRpc;
 105
 106     // renderer beans
 107     private final OpenRoadmInterface121 openRoadmInterface121;
 108     private final OpenRoadmInterface221 openRoadmInterface221;
 109     private final OpenRoadmOtnInterface221 openRoadmOtnInterface221;
 110
 111     private final OpenRoadmInterfaceFactory openRoadmInterfaceFactory;
 112     private final DeviceRendererServiceImpl deviceRendererService;
 113     private final OtnDeviceRendererServiceImpl otnDeviceRendererService;
 114     private final DeviceRendererRPCImpl deviceRendererRPC;
 115     private final NetworkModelWavelengthServiceImpl networkModelWavelengthService;
 116     private final RendererServiceOperationsImpl rendererServiceOperations;
 117     private final RendererProvider rendererProvider;
 118     private final TapiProvider tapiProvider;
 119
 120     // service-handler beans
 121     private final ServicehandlerProvider servicehandlerProvider;
 122
 123     public TransportPCEImpl(LightyServices lightyServices) {
 124         LOG.info("Creating common beans ...");
 125         deviceTransactionManager = new DeviceTransactionManagerImpl(lightyServices.getBindingMountPointService(), MaxDurationToSubmitTransaction);
 126         mappingUtils = new MappingUtilsImpl(lightyServices.getBindingDataBroker());
 127         openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
 128         openRoadmInterfacesImpl221 = new OpenRoadmInterfacesImpl221(deviceTransactionManager);
 129         openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils, openRoadmInterfacesImpl121, openRoadmInterfacesImpl221);
 130         portMappingVersion221 = new PortMappingVersion221(lightyServices.getBindingDataBroker(), deviceTransactionManager, openRoadmInterfaces);
 131         requestProcessor = new RequestProcessor(lightyServices.getBindingDataBroker());
 132         networkTransaction = new NetworkTransactionImpl(requestProcessor);
 133         portMappingVersion121 = new PortMappingVersion121(lightyServices.getBindingDataBroker(), deviceTransactionManager, openRoadmInterfaces);
 134         portMapping = new PortMappingImpl(lightyServices.getBindingDataBroker(), portMappingVersion221, portMappingVersion121);
 135         crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager);
 136         crossConnectImpl221 = new CrossConnectImpl221(deviceTransactionManager);
 137         crossConnect = new CrossConnectImpl(deviceTransactionManager, mappingUtils, crossConnectImpl121, crossConnectImpl221);
 138         fixedFlex = new FixedFlexImpl();
 139
 140         LOG.info("Creating PCE beans ...");
 141         pathComputationService = new PathComputationServiceImpl(networkTransaction, lightyServices.getBindingNotificationPublishService());
 142         pceProvider = new PceProvider(lightyServices.getRpcProviderService(), pathComputationService);
 143
 144         LOG.info("Creating network-model beans ...");
 145         // TODO: Need to look into it
 146
 147
 148
 149         // TODO: Add OTN network model
 150         //
 151         linkDiscoveryImpl = new R2RLinkDiscovery(lightyServices.getBindingDataBroker(), deviceTransactionManager, networkTransaction);
 152         networkutilsServiceImpl = new NetworkUtilsImpl(lightyServices.getBindingDataBroker());
 153         networkModelService = new NetworkModelServiceImpl(networkTransaction, linkDiscoveryImpl, portMapping);
 154         netConfTopologyListener = new NetConfTopologyListener(networkModelService, lightyServices.getBindingDataBroker(), deviceTransactionManager);
 155         networkModelProvider = new NetworkModelProvider(networkTransaction, lightyServices.getBindingDataBroker(),
 156             lightyServices.getRpcProviderService(), networkutilsServiceImpl, netConfTopologyListener);
 157
 158         LOG.info("Creating OLM beans ...");
 159         powerMgmt = new PowerMgmtImpl(lightyServices.getBindingDataBroker(), openRoadmInterfaces, crossConnect, deviceTransactionManager);
 160         olmPowerService = new OlmPowerServiceImpl(lightyServices.getBindingDataBroker(), powerMgmt, deviceTransactionManager, portMapping, mappingUtils, openRoadmInterfaces);
 161         olmProvider = new OlmProvider(lightyServices.getRpcProviderService(), olmPowerService);
 162         olmPowerServiceRpc = new OlmPowerServiceRpcImpl(olmPowerService);
 163
 164         LOG.info("Creating renderer beans ...");
 165         openRoadmInterface121 = new OpenRoadmInterface121(portMapping, openRoadmInterfaces);
 166         openRoadmInterface221 = new OpenRoadmInterface221(portMapping, openRoadmInterfaces, fixedFlex);
 167         openRoadmOtnInterface221 = new OpenRoadmOtnInterface221(portMapping, openRoadmInterfaces);
 168         openRoadmInterfaceFactory = new OpenRoadmInterfaceFactory(mappingUtils, openRoadmInterface121,
 169             openRoadmInterface221, openRoadmOtnInterface221);
 170         deviceRendererService = new DeviceRendererServiceImpl(lightyServices.getBindingDataBroker(), deviceTransactionManager,
 171             openRoadmInterfaceFactory, openRoadmInterfaces, crossConnect, portMapping, networkModelService);
 172         otnDeviceRendererService = new OtnDeviceRendererServiceImpl(openRoadmInterfaceFactory, crossConnect, openRoadmInterfaces,
 173             deviceTransactionManager, networkModelService);
 174         deviceRendererRPC = new DeviceRendererRPCImpl(deviceRendererService, otnDeviceRendererService);
 175         networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(lightyServices.getBindingDataBroker());
 176         rendererServiceOperations = new RendererServiceOperationsImpl(deviceRendererService, olmPowerServiceRpc, lightyServices.getBindingDataBroker(), networkModelWavelengthService, lightyServices.getBindingNotificationPublishService());
 177         rendererProvider = new RendererProvider(lightyServices.getRpcProviderService(), deviceRendererRPC, rendererServiceOperations);
 178
 179         LOG.info("Creating service-handler beans ...");
 180         servicehandlerProvider = new ServicehandlerProvider(lightyServices.getBindingDataBroker(), lightyServices.getRpcProviderService(), lightyServices.getNotificationService(),
 181                 pathComputationService, rendererServiceOperations, networkModelWavelengthService, lightyServices.getBindingNotificationPublishService());
 182         tapiProvider = initTapi(lightyServices);
 183
 184     }
 185
 186     @Override
 187     protected boolean initProcedure() {
 188         LOG.info("Initializing common beans ...");
 189         LOG.info("Initializing PCE beans ...");
 190         pathComputationService.init();
 191         pceProvider.init();
 192         LOG.info("Initializing network-model beans ...");
 193         networkModelProvider.init();
 194         LOG.info("Initializing OLM beans ...");
 195         olmPowerService.init();
 196         olmProvider.init();
 197         LOG.info("Initializing renderer beans ...");
 198         rendererProvider.init();
 199         LOG.info("Initializing service-handler beans ...");
 200         servicehandlerProvider.init();
 201         LOG.info("Initializing tapi beans ...");
 202         tapiProvider.init();
 203         LOG.info("Init done.");
 204         return true;
 205     }
 206
 207     @Override
 208     protected boolean stopProcedure() {
 209         tapiProvider.close();
 210         LOG.info("Shutting down service-handler beans ...");
 211         servicehandlerProvider.close();
 212         LOG.info("Shutting down renderer beans ...");
 213         rendererProvider.close();
 214         LOG.info("Shutting down OLM beans ...");
 215         olmProvider.close();
 216         olmPowerService.close();
 217         LOG.info("Shutting down network-model beans ...");
 218         networkModelProvider.close();
 219         LOG.info("Shutting down PCE beans ...");
 220         pathComputationService.close();
 221         pceProvider.close();
 222         LOG.info("Shutting down common beans ...");
 223         networkTransaction.close();
 224         deviceTransactionManager.preDestroy();
 225         LOG.info("Shutdown done.");
 226         return true;
 227     }
 228
 229     /**
 230      * Init tapi provider beans
 231      * @param lightyServices
 232      * @return TapiProvider
 233      */
 234     private TapiProvider initTapi(LightyServices lightyServices) {
 235         RendererListenerImpl rendererListenerImpl = new RendererListenerImpl(
 236                 pathComputationService,
 237                 lightyServices.getBindingNotificationPublishService());
 238         ServiceDataStoreOperations serviceDataStoreOperations = new ServiceDataStoreOperationsImpl(
 239                 lightyServices.getBindingDataBroker());
 240         PceListenerImpl pceListenerImpl  = new PceListenerImpl(
 241                 rendererServiceOperations,
 242                 pathComputationService,
 243                 lightyServices.getBindingNotificationPublishService(),
 244                 serviceDataStoreOperations ) ;
 245         ServiceHandlerOperations serviceHandlerOperations = new ServiceHandlerOperationsImpl(
 246                 lightyServices.getBindingDataBroker(),
 247                 pathComputationService,
 248                 rendererServiceOperations,
 249                 lightyServices.getBindingNotificationPublishService(),
 250                 pceListenerImpl,
 251                 rendererListenerImpl,
 252                 networkModelWavelengthService);
 253         return new TapiProvider(
 254                 lightyServices.getBindingDataBroker(),
 255                 lightyServices.getRpcProviderService(),
 256                 serviceHandlerOperations,
 257                 new TapiListener());
 258     }
 259
 260 }