X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=tapi%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Ftapi%2Fimpl%2FTapiProvider.java;h=fd1f87e6851d934bc767656abdce96f8c64f8c34;hb=eedfcf046eadaa5ca9d38792c0af8769a4006f32;hp=8ce95c33956f0c65f4ff2bc78227ad279a5a2726;hpb=5e89fe2242ea395f6aee61b1f060c7b6183aeb27;p=transportpce.git diff --git a/tapi/src/main/java/org/opendaylight/transportpce/tapi/impl/TapiProvider.java b/tapi/src/main/java/org/opendaylight/transportpce/tapi/impl/TapiProvider.java index 8ce95c339..fd1f87e68 100644 --- a/tapi/src/main/java/org/opendaylight/transportpce/tapi/impl/TapiProvider.java +++ b/tapi/src/main/java/org/opendaylight/transportpce/tapi/impl/TapiProvider.java @@ -7,7 +7,9 @@ */ package org.opendaylight.transportpce.tapi.impl; +import java.util.ArrayList; import java.util.HashMap; +import java.util.List; import org.opendaylight.mdsal.binding.api.DataBroker; import org.opendaylight.mdsal.binding.api.DataTreeIdentifier; import org.opendaylight.mdsal.binding.api.NotificationPublishService; @@ -20,9 +22,10 @@ import org.opendaylight.transportpce.common.network.NetworkTransactionService; import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperations; import org.opendaylight.transportpce.tapi.connectivity.ConnectivityUtils; import org.opendaylight.transportpce.tapi.connectivity.TapiConnectivityImpl; -import org.opendaylight.transportpce.tapi.listeners.TapiPceListenerImpl; -import org.opendaylight.transportpce.tapi.listeners.TapiRendererListenerImpl; -import org.opendaylight.transportpce.tapi.listeners.TapiServiceHandlerListenerImpl; +import org.opendaylight.transportpce.tapi.listeners.TapiNetworkModelNotificationHandler; +import org.opendaylight.transportpce.tapi.listeners.TapiPceNotificationHandler; +import org.opendaylight.transportpce.tapi.listeners.TapiRendererNotificationHandler; +import org.opendaylight.transportpce.tapi.listeners.TapiServiceNotificationHandler; import org.opendaylight.transportpce.tapi.topology.TapiNetconfTopologyListener; import org.opendaylight.transportpce.tapi.topology.TapiNetworkModelService; import org.opendaylight.transportpce.tapi.topology.TapiOrLinkListener; @@ -34,26 +37,17 @@ import org.opendaylight.transportpce.tapi.utils.TapiInitialORMapping; import org.opendaylight.transportpce.tapi.utils.TapiLink; import org.opendaylight.transportpce.tapi.utils.TapiLinkImpl; import org.opendaylight.transportpce.tapi.utils.TapiListener; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.TransportpcePceListener; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.Network; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.network.Nodes; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.TransportpceRendererListener; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.servicehandler.rev201125.TransportpceServicehandlerListener; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.tapinetworkutils.rev210408.TransportpceTapinetworkutilsService; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.OrgOpenroadmServiceService; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.OrgOpenroadmServiceService; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link; -import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.TapiCommonService; -import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev181210.TapiConnectivityService; -import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.notification.rev181210.TapiNotificationListener; -import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.TapiTopologyService; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.tapi.rev180928.ServiceInterfacePoints; import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node; -import org.opendaylight.yangtools.concepts.ListenerRegistration; -import org.opendaylight.yangtools.concepts.ObjectRegistration; +import org.opendaylight.yangtools.concepts.Registration; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.osgi.service.component.annotations.Activate; import org.osgi.service.component.annotations.Component; @@ -81,22 +75,15 @@ public class TapiProvider { new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class) .child(Link.class); private final DataBroker dataBroker; - private final RpcProviderService rpcProviderService; - private final NotificationService notificationService; private final NetworkTransactionService networkTransactionService; private final OrgOpenroadmServiceService serviceHandler; private final ServiceDataStoreOperations serviceDataStoreOperations; - private final TransportpceTapinetworkutilsService tapiNetworkUtils; - private TapiNotificationListener tapiNetworkModelListenerImpl; - private ObjectRegistration rpcRegistration; - private ObjectRegistration tapiNetworkutilsServiceRpcRegistration; - private ListenerRegistration dataTreeChangeListenerRegistration; - private ListenerRegistration dataTreeChangeListenerRegistration1; - private ListenerRegistration mappingListenerListenerRegistration; - private ListenerRegistration pcelistenerRegistration; - private ListenerRegistration rendererlistenerRegistration; - private ListenerRegistration servicehandlerlistenerRegistration; - private ListenerRegistration tapinetworkmodellistenerRegistration; + private List listeners; + private List rpcRegistrations = new ArrayList<>(); + private Registration pcelistenerRegistration; + private Registration rendererlistenerRegistration; + private Registration servicehandlerlistenerRegistration; + private Registration tapinetworkmodellistenerRegistration; @Activate public TapiProvider(@Reference DataBroker dataBroker, @@ -106,18 +93,12 @@ public class TapiProvider { @Reference NetworkTransactionService networkTransactionService, @Reference OrgOpenroadmServiceService serviceHandler, @Reference ServiceDataStoreOperations serviceDataStoreOperations, - @Reference TransportpceTapinetworkutilsService tapiNetworkUtils, - @Reference TapiNotificationListener tapiNetworkModelListenerImpl, + @Reference TapiNetworkModelNotificationHandler tapiNetworkModelNotificationHandler, @Reference TapiNetworkModelService tapiNetworkModelServiceImpl) { this.dataBroker = dataBroker; - this.rpcProviderService = rpcProviderService; - this.notificationService = notificationService; this.networkTransactionService = networkTransactionService; this.serviceHandler = serviceHandler; this.serviceDataStoreOperations = serviceDataStoreOperations; - this.tapiNetworkUtils = tapiNetworkUtils; - this.tapiNetworkModelListenerImpl = tapiNetworkModelListenerImpl; - LOG.info("TapiProvider Session Initiated"); TapiContext tapiContext = new TapiContext(this.networkTransactionService); LOG.info("Empty TAPI context created: {}", tapiContext.getTapiContext()); @@ -129,47 +110,43 @@ public class TapiProvider { tapiContext, this.serviceDataStoreOperations); tapiInitialORMapping.performTopoInitialMapping(); tapiInitialORMapping.performServInitialMapping(); - TapiPceListenerImpl pceListenerImpl = new TapiPceListenerImpl(dataBroker); - TapiRendererListenerImpl rendererListenerImpl = new TapiRendererListenerImpl(dataBroker, + TapiPceNotificationHandler pceListenerImpl = new TapiPceNotificationHandler(dataBroker); + TapiRendererNotificationHandler rendererListenerImpl = new TapiRendererNotificationHandler(dataBroker, notificationPublishService); - TapiConnectivityImpl tapi = new TapiConnectivityImpl(this.serviceHandler, tapiContext, connectivityUtils, - pceListenerImpl, rendererListenerImpl); + TapiConnectivityImpl tapiConnectivity = new TapiConnectivityImpl(this.serviceHandler, tapiContext, + connectivityUtils, pceListenerImpl, rendererListenerImpl); + rpcRegistrations.add(rpcProviderService.registerRpcImplementations(tapiConnectivity.registerRPCs())); TapiTopologyImpl topo = new TapiTopologyImpl(this.dataBroker, tapiContext, topologyUtils, tapiLink); + rpcRegistrations.add(rpcProviderService.registerRpcImplementations(topo.registerRPCs())); - rpcRegistration = rpcProviderService.registerRpcImplementation(TapiConnectivityService.class, tapi); - rpcProviderService.registerRpcImplementation(TapiTopologyService.class, topo); - rpcProviderService.registerRpcImplementation(TapiCommonService.class, topo); - + this.listeners = new ArrayList<>(); TapiNetconfTopologyListener topologyListener = new TapiNetconfTopologyListener(tapiNetworkModelServiceImpl); TapiOrLinkListener orLinkListener = new TapiOrLinkListener(tapiLink, networkTransactionService); TapiPortMappingListener tapiPortMappingListener = new TapiPortMappingListener(tapiNetworkModelServiceImpl); - dataTreeChangeListenerRegistration1 = - dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, - LINK_II), orLinkListener); - dataTreeChangeListenerRegistration = - dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(LogicalDatastoreType.OPERATIONAL, - InstanceIdentifiers.NETCONF_TOPOLOGY_II.child(Node.class)), topologyListener); - mappingListenerListenerRegistration = - dataBroker.registerDataTreeChangeListener(DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, - MAPPING_II), tapiPortMappingListener); - tapiNetworkutilsServiceRpcRegistration = - rpcProviderService.registerRpcImplementation(TransportpceTapinetworkutilsService.class, - this.tapiNetworkUtils); + listeners.add(dataBroker.registerDataTreeChangeListener( + DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, LINK_II), orLinkListener)); + listeners.add(dataBroker.registerDataTreeChangeListener( + DataTreeIdentifier.create(LogicalDatastoreType.OPERATIONAL, InstanceIdentifiers.NETCONF_TOPOLOGY_II + .child(Node.class)), + topologyListener)); + listeners.add(dataBroker.registerDataTreeChangeListener( + DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, MAPPING_II), tapiPortMappingListener)); TapiListener tapiListener = new TapiListener(); - dataBroker.registerDataTreeChangeListener( + listeners.add(dataBroker.registerDataTreeChangeListener( DataTreeIdentifier.create( LogicalDatastoreType.CONFIGURATION, InstanceIdentifier.create(ServiceInterfacePoints.class)), - tapiListener); + tapiListener)); // Notification Listener - pcelistenerRegistration = notificationService.registerNotificationListener(pceListenerImpl); - rendererlistenerRegistration = notificationService.registerNotificationListener(rendererListenerImpl); - TapiServiceHandlerListenerImpl serviceHandlerListenerImpl = new TapiServiceHandlerListenerImpl(dataBroker); + pcelistenerRegistration = notificationService.registerCompositeListener(pceListenerImpl.getCompositeListener()); + rendererlistenerRegistration = notificationService + .registerCompositeListener(rendererListenerImpl.getCompositeListener()); + TapiServiceNotificationHandler serviceHandlerListenerImpl = new TapiServiceNotificationHandler(dataBroker); servicehandlerlistenerRegistration = notificationService - .registerNotificationListener(serviceHandlerListenerImpl); + .registerCompositeListener(serviceHandlerListenerImpl.getCompositeListener()); tapinetworkmodellistenerRegistration = notificationService - .registerNotificationListener(tapiNetworkModelListenerImpl); + .registerCompositeListener(tapiNetworkModelNotificationHandler.getCompositeListener()); } /** @@ -177,23 +154,20 @@ public class TapiProvider { */ @Deactivate public void close() { - LOG.info("TapiProvider Session Closed"); - if (dataTreeChangeListenerRegistration != null) { - dataTreeChangeListenerRegistration.close(); - } - if (mappingListenerListenerRegistration != null) { - mappingListenerListenerRegistration.close(); - } - if (dataTreeChangeListenerRegistration1 != null) { - dataTreeChangeListenerRegistration1.close(); - } - if (tapiNetworkutilsServiceRpcRegistration != null) { - tapiNetworkutilsServiceRpcRegistration.close(); - } + listeners.forEach(lis -> lis.close()); + listeners.clear(); pcelistenerRegistration.close(); rendererlistenerRegistration.close(); servicehandlerlistenerRegistration.close(); - rpcRegistration.close(); tapinetworkmodellistenerRegistration.close(); + for (Registration reg : rpcRegistrations) { + reg.close(); + } + LOG.info("TapiProvider Session Closed"); } + + public List getRegisteredRpcs() { + return rpcRegistrations; + } + }