import org.opendaylight.transportpce.networkmodel.NetworkModelProvider;
import org.opendaylight.transportpce.networkmodel.NetworkUtilsImpl;
import org.opendaylight.transportpce.networkmodel.R2RLinkDiscovery;
+import org.opendaylight.transportpce.networkmodel.service.FrequenciesService;
+import org.opendaylight.transportpce.networkmodel.service.FrequenciesServiceImpl;
import org.opendaylight.transportpce.networkmodel.service.NetworkModelService;
import org.opendaylight.transportpce.networkmodel.service.NetworkModelServiceImpl;
-import org.opendaylight.transportpce.networkmodel.service.NetworkModelWavelengthService;
-import org.opendaylight.transportpce.networkmodel.service.NetworkModelWavelengthServiceImpl;
import org.opendaylight.transportpce.olm.OlmPowerServiceRpcImpl;
import org.opendaylight.transportpce.olm.OlmProvider;
import org.opendaylight.transportpce.olm.power.PowerMgmt;
PortMapping portMapping = initPortMapping(lightyServices, openRoadmInterfaces);
NetworkModelService networkModelService = new NetworkModelServiceImpl(networkTransaction, linkDiscoveryImpl,
portMapping);
- NetworkModelWavelengthService networkModelWavelengthService =
- new NetworkModelWavelengthServiceImpl(lightyServices.getBindingDataBroker());
+ FrequenciesService networkModelWavelengthService =
+ new FrequenciesServiceImpl(lightyServices.getBindingDataBroker());
NetConfTopologyListener netConfTopologyListener = new NetConfTopologyListener(networkModelService,
lightyServices.getBindingDataBroker(), deviceTransactionManager);
networkModelProvider = new NetworkModelProvider(networkTransaction, lightyServices.getBindingDataBroker(),
import org.opendaylight.transportpce.common.NetworkUtils;
import org.opendaylight.transportpce.common.network.NetworkTransactionService;
import org.opendaylight.transportpce.networkmodel.listeners.ServiceHandlerListener;
-import org.opendaylight.transportpce.networkmodel.service.NetworkModelWavelengthService;
+import org.opendaylight.transportpce.networkmodel.service.FrequenciesService;
import org.opendaylight.transportpce.networkmodel.util.TpceNetwork;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev170818.TransportpceNetworkutilsService;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.servicehandler.rev201125.TransportpceServicehandlerListener;
private TpceNetwork tpceNetwork;
private ListenerRegistration<TransportpceServicehandlerListener> serviceHandlerListenerRegistration;
private NotificationService notificationService;
- private NetworkModelWavelengthService networkModelWavelengthService;
+ private FrequenciesService networkModelWavelengthService;
public NetworkModelProvider(NetworkTransactionService networkTransactionService, final DataBroker dataBroker,
final RpcProviderService rpcProviderService, final TransportpceNetworkutilsService networkutilsService,
final NetConfTopologyListener topologyListener, NotificationService notificationService,
- NetworkModelWavelengthService networkModelWavelengthService) {
+ FrequenciesService networkModelWavelengthService) {
this.dataBroker = dataBroker;
this.rpcProviderService = rpcProviderService;
this.networkutilsService = networkutilsService;
package org.opendaylight.transportpce.networkmodel.listeners;
-import org.opendaylight.transportpce.networkmodel.service.NetworkModelWavelengthService;
+import org.opendaylight.transportpce.networkmodel.service.FrequenciesService;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.servicehandler.rev201125.ServiceRpcResultSh;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.servicehandler.rev201125.TransportpceServicehandlerListener;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev190531.ServiceNotificationTypes;
public class ServiceHandlerListener implements TransportpceServicehandlerListener {
private static final Logger LOG = LoggerFactory.getLogger(ServiceHandlerListener.class);
- private final NetworkModelWavelengthService service;
+ private final FrequenciesService service;
- public ServiceHandlerListener(NetworkModelWavelengthService service) {
+ public ServiceHandlerListener(FrequenciesService service) {
LOG.info("Init service handler listener for network");
this.service = service;
}
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev201126.path.description.AToZDirection;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev201126.path.description.ZToADirection;
-public interface NetworkModelWavelengthService {
+public interface FrequenciesService {
/**
* Allocate frequency in network topology.
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class NetworkModelWavelengthServiceImpl implements NetworkModelWavelengthService {
+public class FrequenciesServiceImpl implements FrequenciesService {
- private static final Logger LOG = LoggerFactory.getLogger(NetworkModelWavelengthServiceImpl.class);
+ private static final Logger LOG = LoggerFactory.getLogger(FrequenciesServiceImpl.class);
private final DataBroker dataBroker;
private final AvailFreqMapsKey availFreqMapKey = new AvailFreqMapsKey(GridConstant.C_BAND);
- public NetworkModelWavelengthServiceImpl(DataBroker dataBroker) {
+ public FrequenciesServiceImpl(DataBroker dataBroker) {
this.dataBroker = dataBroker;
}
<argument ref="networkutilsServiceImpl" />
<argument ref="netconfTopologyListener" />
<argument ref="notificationService" />
- <argument ref="networkModelWavelengthService" />
+ <argument ref="frequenciesService" />
</bean>
<bean id="netconfTopologyListener" class="org.opendaylight.transportpce.networkmodel.NetConfTopologyListener">
<argument ref="networkTransactionImpl" />
</bean>
- <bean id="networkModelWavelengthService" class="org.opendaylight.transportpce.networkmodel.service.NetworkModelWavelengthServiceImpl">
+ <bean id="frequenciesService" class="org.opendaylight.transportpce.networkmodel.service.FrequenciesServiceImpl">
<argument ref="dataBroker" />
</bean>
<service ref="networkModelService" interface="org.opendaylight.transportpce.networkmodel.service.NetworkModelService" />
- <service ref="networkModelWavelengthService" interface="org.opendaylight.transportpce.networkmodel.service.NetworkModelWavelengthService" />
+ <service ref="frequenciesService" interface="org.opendaylight.transportpce.networkmodel.service.FrequenciesService" />
</blueprint>
import org.opendaylight.mdsal.binding.api.RpcProviderService;
import org.opendaylight.mdsal.common.api.CommitInfo;
import org.opendaylight.transportpce.common.network.NetworkTransactionService;
-import org.opendaylight.transportpce.networkmodel.service.NetworkModelWavelengthService;
+import org.opendaylight.transportpce.networkmodel.service.FrequenciesService;
import org.opendaylight.transportpce.test.AbstractTest;
import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev170818.TransportpceNetworkutilsService;
@Mock
private NotificationService notificationService;
@Mock
- private NetworkModelWavelengthService networkModelWavelengthService;
+ private FrequenciesService networkModelWavelengthService;
@Test
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class NetworkModelWavelengthServiceTest extends AbstractTest {
- private static final Logger LOG = LoggerFactory.getLogger(NetworkModelWavelengthServiceTest.class);
+public class FrequenciesServiceTest extends AbstractTest {
+ private static final Logger LOG = LoggerFactory.getLogger(FrequenciesServiceTest.class);
private static final String OPENROADM_TOPOLOGY_FILE = "src/test/resources/openroadm-topology.xml";
private static final String PATH_DESCRIPTION_FILE = "src/test/resources/path_description.json";
private static PathDescription pathDescription;
@Test
public void allocateFrequenciesTest() throws IOException {
- NetworkModelWavelengthService service = new NetworkModelWavelengthServiceImpl(getDataBroker());
+ FrequenciesService service = new FrequenciesServiceImpl(getDataBroker());
service.allocateFrequencies(pathDescription.getAToZDirection(), pathDescription.getZToADirection());
TerminationPoint1 terminationPoint = getNetworkTerminationPointFromDatastore("ROADM-A1-DEG2", "DEG2-CTP-TXRX");
assertEquals("Lambda 1 should not be available for ctp-attributes",
@Test
public void releaseFrequenciesTest() throws IOException {
- NetworkModelWavelengthService service = new NetworkModelWavelengthServiceImpl(getDataBroker());
+ FrequenciesService service = new FrequenciesServiceImpl(getDataBroker());
service.allocateFrequencies(pathDescription.getAToZDirection(), pathDescription.getZToADirection());
service.releaseFrequencies(pathDescription.getAToZDirection(), pathDescription.getZToADirection());
TerminationPoint1 terminationPoint = getNetworkTerminationPointFromDatastore("ROADM-A1-DEG2", "DEG2-CTP-TXRX");