- case Infrastructure:
- LOG.info("RPC implementation for {}", input.getConnectionType());
- if (input.getServiceAEnd().getOtuServiceRate() != null) {
- if ((input.getServiceAEnd().getOtuServiceRate().equals(OTU4.class))
- || (input.getServiceAEnd().getOtuServiceRate().equals(OTUCn.class))) {
- // For the service of OTU4 or OTUCn infrastructure
- // Create the OCH and OTU interfaces for OTU4 class
- // Create OTSi, OTSi-group and OTUCn interface
- if (!createServicepathInput(input)) {
- return ModelMappingUtils.createServiceImplResponse(ResponseCodes.RESPONSE_FAILED,
- OPERATION_FAILED);
- }
- }
- }
- if (input.getServiceAEnd().getOduServiceRate() != null) {
- String serviceRate = null;
- if (input.getServiceAEnd().getOduServiceRate().equals(ODU4.class)) {
- // For the service of OTU4 infrastructure
- serviceRate = "100G"; // For OtnDeviceRendererServiceImpl
- }
- else if (input.getServiceAEnd().getOduServiceRate().equals(ODUCn.class)) {
- // For the service of OTUCn infrastructure
- // TODO: what happens if split-lambda where to be used? We will have ODUC2 rate,
- // TODO: which case service-rate would be 200
- // TODO: in that case it would be 200G?? Need to understand more
- serviceRate = "400G"; // For OtnDeviceRendererServiceImpl
- }
- LOG.info("Service format for {} is {} and rate is {}", input.getServiceName(),
- input.getServiceAEnd().getOduServiceRate(), serviceRate);
- // Now start rendering ODU4 or ODUC4 interface
- // This is A-Z side
- OtnServicePathInput otnServicePathInputAtoZ = ModelMappingUtils
- .rendererCreateOtnServiceInput(input.getServiceName(),
- input.getServiceAEnd().getServiceFormat().getName(),
- serviceRate,
- input.getPathDescription(), true);
- // This is Z-A side
- OtnServicePathInput otnServicePathInputZtoA = ModelMappingUtils
- .rendererCreateOtnServiceInput(input.getServiceName(),
- input.getServiceZEnd().getServiceFormat().getName(),
- serviceRate,
- input.getPathDescription(), false);
- // Rollback should be same for all conditions, so creating a new one
- RollbackProcessor rollbackProcessor = new RollbackProcessor();
- List<OtnDeviceRenderingResult> otnRenderingResults = otnDeviceRendering(rollbackProcessor,
- otnServicePathInputAtoZ, otnServicePathInputZtoA);
- if (rollbackProcessor.rollbackAllIfNecessary() > 0) {
- sendNotifications(ServicePathNotificationTypes.ServiceImplementationRequest,
- input.getServiceName(), RpcStatusEx.Failed, DEVICE_RENDERING_ROLL_BACK_MSG);
- return ModelMappingUtils.createServiceImplResponse(ResponseCodes.RESPONSE_FAILED,
- OPERATION_FAILED);
- }
- LOG.info("OTN rendering result size {}", otnRenderingResults.size());
+ case StringConstants.SERVICE_TYPE_1GE:
+ case StringConstants.SERVICE_TYPE_10GE:
+ case StringConstants.SERVICE_TYPE_100GE_M:
+ case StringConstants.SERVICE_TYPE_100GE_S:
+ case StringConstants.SERVICE_TYPE_ODU4:
+ case StringConstants.SERVICE_TYPE_ODUC4:
+ if (!manageOtnServicePathCreation(input, serviceType, serviceRate)) {
+ return ModelMappingUtils.createServiceImplResponse(ResponseCodes.RESPONSE_FAILED,
+ OPERATION_FAILED);