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