diff options
Diffstat (limited to 'components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmDataQueue.java')
-rw-r--r-- | components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmDataQueue.java | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmDataQueue.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmDataQueue.java index 4f196979..868b94c7 100644 --- a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmDataQueue.java +++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmDataQueue.java @@ -79,6 +79,19 @@ public class PmDataQueue { } return sampleList; } + + /** + * check whether the queue has enough number of samples for that subcounter + */ + public boolean checkSamplesInQueue(SubCounter subCounter, int samples) { + if (subCounterMap.containsKey(subCounter)){ + Queue<List<MeasurementObject>> measQueue = subCounterMap.get(subCounter); + if(measQueue.size() >= samples) { + return true; + } + } + return false; + } /** * put S-NSSAI to the queue |