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 import org.opendaylight.transportpce.networkmodel.util.OpenRoadmFactory;
  33 import org.opendaylight.transportpce.networkmodel.util.OpenRoadmTopology121;
  34 import org.opendaylight.transportpce.networkmodel.util.OpenRoadmTopology22;
  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 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
  47 import org.opendaylight.transportpce.renderer.provisiondevice.DeviceRendererServiceImpl;
  48 import org.opendaylight.transportpce.renderer.provisiondevice.RendererServiceOperationsImpl;
  49 import org.opendaylight.transportpce.renderer.rpcs.DeviceRendererRPCImpl;
  50 import org.opendaylight.transportpce.servicehandler.impl.ServicehandlerProvider;
  51 import org.slf4j.Logger;
  52 import org.slf4j.LoggerFactory;
  53
  54 public class TransportPCEImpl extends AbstractLightyModule implements TransportPCE {
  55
  56     private static final Logger LOG = LoggerFactory.getLogger(TransportPCEImpl.class);
  57     private static final long MaxDurationToSubmitTransaction = 1500;
  58
  59     // common beans
  60     private final DeviceTransactionManagerImpl deviceTransactionManager;
  61     private final MappingUtilsImpl mappingUtils;
  62     private final OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
  63     private final OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
  64     private final OpenRoadmInterfacesImpl openRoadmInterfaces;
  65     private final PortMappingVersion221 portMappingVersion221;
  66     private final RequestProcessor requestProcessor;
  67     private final NetworkTransactionImpl networkTransaction;
  68     private final PortMappingVersion121 portMappingVersion121;
  69     private final PortMappingImpl portMapping;
  70     private final CrossConnectImpl121 crossConnectImpl121;
  71     private final CrossConnectImpl221 crossConnectImpl221;
  72     private final CrossConnectImpl crossConnect;
  73     private final FixedFlexImpl fixedFlex;
  74
  75     // pce beans
  76     private final PathComputationServiceImpl pathComputationService;
  77     private final PceProvider pceProvider;
  78
  79     // network model beans
  80     private final OpenRoadmTopology121 openRoadmTopology121;
  81     private final OpenRoadmTopology22 openRoadmTopology22;
  82     private final OpenRoadmFactory openRoadmFactory;
  83     private final R2RLinkDiscovery linkDiscoveryImpl;
  84     private final NetworkUtilsImpl networkutilsServiceImpl;
  85     private final NetworkModelServiceImpl networkModelService;
  86     private final NetConfTopologyListener netConfTopologyListener;
  87     private final NetworkModelProvider networkModelProvider;
  88
  89     // OLM beans
  90     private final PowerMgmt powerMgmt;
  91     private final OlmPowerServiceImpl olmPowerService;
  92     private final OlmProvider olmProvider;
  93     private final OlmPowerServiceRpcImpl olmPowerServiceRpc;
  94
  95     // renderer beans
  96     private final OpenRoadmInterface121 openRoadmInterface121;
  97     private final OpenRoadmInterface221 openRoadmInterface22;
  98     private final OpenRoadmInterfaceFactory openRoadmInterfaceFactory;
  99     private final DeviceRendererServiceImpl deviceRendererService;
 100     private final DeviceRendererRPCImpl deviceRendererRPC;
 101     private final NetworkModelWavelengthServiceImpl networkModelWavelengthService;
 102     private final RendererServiceOperationsImpl rendererServiceOperations;
 103     private final RendererProvider rendererProvider;
 104
 105     // service-handler beans
 106     private final ServicehandlerProvider servicehandlerProvider;
 107
 108     public TransportPCEImpl(LightyServices lightyServices) {
 109         LOG.info("Creating common beans ...");
 110         deviceTransactionManager = new DeviceTransactionManagerImpl(lightyServices.getControllerBindingMountPointService(), MaxDurationToSubmitTransaction);
 111         mappingUtils = new MappingUtilsImpl(lightyServices.getControllerBindingPingPongDataBroker());
 112         openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
 113         openRoadmInterfacesImpl221 = new OpenRoadmInterfacesImpl221(deviceTransactionManager);
 114         openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils, openRoadmInterfacesImpl121, openRoadmInterfacesImpl221);
 115         portMappingVersion221 = new PortMappingVersion221(lightyServices.getControllerBindingPingPongDataBroker(), deviceTransactionManager, openRoadmInterfaces);
 116         requestProcessor = new RequestProcessor(lightyServices.getControllerBindingPingPongDataBroker());
 117         networkTransaction = new NetworkTransactionImpl(requestProcessor);
 118         portMappingVersion121 = new PortMappingVersion121(lightyServices.getControllerBindingPingPongDataBroker(), deviceTransactionManager, openRoadmInterfaces);
 119         portMapping = new PortMappingImpl(lightyServices.getControllerBindingPingPongDataBroker(), portMappingVersion221, mappingUtils, portMappingVersion121);
 120         crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager);
 121         crossConnectImpl221 = new CrossConnectImpl221(deviceTransactionManager);
 122         crossConnect = new CrossConnectImpl(deviceTransactionManager, mappingUtils, crossConnectImpl121, crossConnectImpl221);
 123         fixedFlex = new FixedFlexImpl();
 124
 125         LOG.info("Creating PCE beans ...");
 126         pathComputationService = new PathComputationServiceImpl(lightyServices.getControllerBindingPingPongDataBroker(), lightyServices.getControllerBindingNotificationPublishService());
 127         pceProvider = new PceProvider(lightyServices.getControllerRpcProviderRegistry(), pathComputationService);
 128
 129         LOG.info("Creating network-model beans ...");
 130         openRoadmTopology121 = new OpenRoadmTopology121(networkTransaction, deviceTransactionManager);
 131         openRoadmTopology22 = new OpenRoadmTopology22(networkTransaction, deviceTransactionManager);
 132         openRoadmFactory = new OpenRoadmFactory(mappingUtils, openRoadmTopology121, openRoadmTopology22);
 133         linkDiscoveryImpl = new R2RLinkDiscovery(lightyServices.getControllerBindingPingPongDataBroker(), deviceTransactionManager, openRoadmFactory, networkTransaction);
 134         networkutilsServiceImpl = new NetworkUtilsImpl(lightyServices.getControllerBindingPingPongDataBroker(), openRoadmFactory);
 135         networkModelService = new NetworkModelServiceImpl(networkTransaction, linkDiscoveryImpl, deviceTransactionManager, openRoadmFactory, portMapping);
 136         netConfTopologyListener = new NetConfTopologyListener(networkModelService, lightyServices.getControllerBindingPingPongDataBroker(), deviceTransactionManager);
 137         networkModelProvider = new NetworkModelProvider(networkTransaction, lightyServices.getControllerBindingPingPongDataBroker(), lightyServices.getControllerRpcProviderRegistry(), networkutilsServiceImpl, netConfTopologyListener, openRoadmFactory);
 138
 139         LOG.info("Creating OLM beans ...");
 140         powerMgmt = new PowerMgmtImpl(lightyServices.getControllerBindingPingPongDataBroker(), openRoadmInterfaces, crossConnect, deviceTransactionManager);
 141         olmPowerService = new OlmPowerServiceImpl(lightyServices.getControllerBindingPingPongDataBroker(), powerMgmt, deviceTransactionManager, portMapping, mappingUtils, openRoadmInterfaces);
 142         olmProvider = new OlmProvider(lightyServices.getControllerRpcProviderRegistry(), olmPowerService);
 143         olmPowerServiceRpc = new OlmPowerServiceRpcImpl(olmPowerService);
 144
 145         LOG.info("Creating renderer beans ...");
 146         openRoadmInterface121 = new OpenRoadmInterface121(portMapping, openRoadmInterfaces);
 147         openRoadmInterface22 = new OpenRoadmInterface221(portMapping, openRoadmInterfaces, fixedFlex);
 148         openRoadmInterfaceFactory = new OpenRoadmInterfaceFactory(mappingUtils, openRoadmInterface121, openRoadmInterface22);
 149         deviceRendererService = new DeviceRendererServiceImpl(lightyServices.getControllerBindingPingPongDataBroker(), deviceTransactionManager, openRoadmInterfaceFactory, openRoadmInterfaces, crossConnect, portMapping);
 150         deviceRendererRPC = new DeviceRendererRPCImpl(deviceRendererService);
 151         networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(lightyServices.getControllerBindingPingPongDataBroker());
 152         rendererServiceOperations = new RendererServiceOperationsImpl(deviceRendererService, olmPowerServiceRpc, lightyServices.getControllerBindingPingPongDataBroker(), networkModelWavelengthService, lightyServices.getControllerBindingNotificationPublishService());
 153         rendererProvider = new RendererProvider(lightyServices.getControllerRpcProviderRegistry(), deviceRendererRPC, rendererServiceOperations);
 154
 155         LOG.info("Creating service-handler beans ...");
 156         servicehandlerProvider = new ServicehandlerProvider(lightyServices.getControllerBindingPingPongDataBroker(), lightyServices.getControllerRpcProviderRegistry(), lightyServices.getControllerBindingNotificationService(),
 157                 pathComputationService, rendererServiceOperations, networkModelWavelengthService, lightyServices.getControllerBindingNotificationPublishService());
 158
 159     }
 160
 161     @Override
 162     protected boolean initProcedure() {
 163         LOG.info("Initializing common beans ...");
 164         LOG.info("Initializing PCE beans ...");
 165         pathComputationService.init();
 166         pceProvider.init();
 167         LOG.info("Initializing network-model beans ...");
 168         networkModelProvider.init();
 169         LOG.info("Initializing OLM beans ...");
 170         olmPowerService.init();
 171         olmProvider.init();
 172         LOG.info("Initializing renderer beans ...");
 173         rendererProvider.init();
 174         LOG.info("Initializing service-handler beans ...");
 175         servicehandlerProvider.init();
 176         LOG.info("Init done.");
 177         return true;
 178     }
 179
 180     @Override
 181     protected boolean stopProcedure() {
 182         LOG.info("Shutting down service-handler beans ...");
 183         servicehandlerProvider.close();
 184         LOG.info("Shutting down renderer beans ...");
 185         rendererProvider.close();
 186         LOG.info("Shutting down OLM beans ...");
 187         olmProvider.close();
 188         olmPowerService.close();
 189         LOG.info("Shutting down network-model beans ...");
 190         networkModelProvider.close();
 191         LOG.info("Shutting down PCE beans ...");
 192         pathComputationService.close();
 193         pceProvider.close();
 194         LOG.info("Shutting down common beans ...");
 195         networkTransaction.close();
 196         deviceTransactionManager.preDestroy();
 197         LOG.info("Shutdown done.");
 198         return true;
 199     }
 200
 201 }