X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Frepository%2FPolicies.java;h=2a4eb5afaf56593704db86a87f7aab1c50ddac14;hb=ffe0c150f08205d73ee362f58f492aeb2703f295;hp=7b7b17c31424c5f8b1210cedc86e46948d1033a8;hpb=89537fa85fdb1c0ce75e469674785d08dc62b986;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/repository/Policies.java b/policy-agent/src/main/java/org/oransc/policyagent/repository/Policies.java index 7b7b17c3..2a4eb5af 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/repository/Policies.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/repository/Policies.java @@ -23,6 +23,7 @@ package org.oransc.policyagent.repository; import java.util.Collection; import java.util.HashMap; import java.util.Map; +import java.util.Set; import java.util.Vector; import org.oransc.policyagent.exceptions.ServiceException; @@ -70,6 +71,10 @@ public class Policies { return map.values(); } + public synchronized boolean containsPolicy(String id) { + return policiesId.containsKey(id); + } + public synchronized Policy getPolicy(String id) throws ServiceException { Policy p = policiesId.get(id); if (p == null) { @@ -113,10 +118,10 @@ public class Policies { return policiesId.size(); } - public void clear() { - for (String id : policiesId.keySet()) { - removeId(id); + public synchronized void clear() { + while (policiesId.size() > 0) { + Set keys = policiesId.keySet(); + removeId(keys.iterator().next()); } } - }