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=54f876ac44a8d261d36292a80792af4b4d492d86;hb=9013ed7ad46ce6927fbf69890487e8df61b7d7ee;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..54f876ac 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 @@ -21,9 +21,10 @@ package org.oransc.policyagent.repository; import java.util.Collection; +import java.util.Collections; import java.util.HashMap; import java.util.Map; -import java.util.Vector; +import java.util.Set; import org.oransc.policyagent.exceptions.ServiceException; @@ -33,9 +34,6 @@ public class Policies { private Map> policiesService = new HashMap<>(); private Map> policiesType = new HashMap<>(); - public Policies() { - } - public synchronized void put(Policy policy) { policiesId.put(policy.id(), policy); multiMapPut(policiesRic, policy.ric().name(), policy); @@ -44,12 +42,7 @@ public class Policies { } private void multiMapPut(Map> multiMap, String key, Policy value) { - Map map = multiMap.get(key); - if (map == null) { - map = new HashMap<>(); - multiMap.put(key, map); - } - map.put(value.id(), value); + multiMap.computeIfAbsent(key, k -> new HashMap<>()).put(value.id(), value); } private void multiMapRemove(Map> multiMap, String key, Policy value) { @@ -65,9 +58,17 @@ public class Policies { private Collection multiMapGet(Map> multiMap, String key) { Map map = multiMap.get(key); if (map == null) { - return new Vector(); + return Collections.emptyList(); } - return map.values(); + return Collections.unmodifiableCollection(map.values()); + } + + public synchronized boolean containsPolicy(String id) { + return policiesId.containsKey(id); + } + + public synchronized Policy get(String id) { + return policiesId.get(id); } public synchronized Policy getPolicy(String id) throws ServiceException { @@ -79,7 +80,7 @@ public class Policies { } public synchronized Collection getAll() { - return policiesId.values(); + return Collections.unmodifiableCollection(policiesId.values()); } public synchronized Collection getForService(String service) { @@ -113,10 +114,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()); } } - }