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