diff options
Diffstat (limited to 'ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java')
-rw-r--r-- | ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java b/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java index 1a74c25..e61e14f 100644 --- a/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java +++ b/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/rest/api/services/SlicingPMDataGenerator.java @@ -31,6 +31,7 @@ import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.Objects; import java.util.Random; import java.util.Set; import java.util.concurrent.atomic.AtomicInteger; @@ -104,10 +105,12 @@ public class SlicingPMDataGenerator { List<NRCellDUModel> duCellList = du.getCellDUList(); int ricId = du.getNearRTRICId(); List<PLMNInfoModel> plmnInfoList = new ArrayList<>(); + duCellList.stream().filter(cell -> (!Objects.isNull(cell.getpLMNInfoList()))); duCellList.forEach(cell -> plmnInfoList.addAll(cell.getpLMNInfoList())); List<NSSAIData> nssaiData = new ArrayList<>(); plmnInfoList.forEach(plmnInfo -> nssaiData.add(plmnInfo.getsNSSAI())); - nssaiData.stream().filter(nssai -> nssai.getStatus().equalsIgnoreCase("active")) + nssaiData.stream().filter( + nssai -> (!(Objects.isNull(nssai.getStatus()))) && nssai.getStatus().equalsIgnoreCase("active")) .forEach(x -> activeNssaiDetails.put(x.getsNSSAI(), x.getConfigData())); produceMeasurementCollectionFile(du, activeNssaiDetails, duCellList, ricId); logger.info("PM data generated for DU : " + du.getgNBDUName() + " Id: " + du.getgNBDUId()); |