X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Frepository%2FRics.java;h=bdf993021de2dfb12ff832083797040f2e063885;hb=f694dec2ff16069e6bb5c9de845278f44e8c9591;hp=9ea6db640e6e53d58119b5704c9b578f21d9e959;hpb=8831a02bce715562f3cacce1691bf4d9d3af206b;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/repository/Rics.java b/policy-agent/src/main/java/org/oransc/policyagent/repository/Rics.java index 9ea6db64..bdf99302 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/repository/Rics.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/repository/Rics.java @@ -20,33 +20,46 @@ package org.oransc.policyagent.repository; -import java.util.Collection; import java.util.HashMap; import java.util.Map; +import org.oransc.policyagent.exceptions.ServiceException; + /** * Dynamic representation of all Rics in the system. */ public class Rics { Map rics = new HashMap<>(); - public void put(Ric ric) { + public synchronized void put(Ric ric) { rics.put(ric.name(), ric); } - public Collection getRics() { + public synchronized Iterable getRics() { return rics.values(); } - public Ric getRic(String name) { + public synchronized Ric getRic(String name) throws ServiceException { + Ric ric = rics.get(name); + if (ric == null) { + throw new ServiceException("Could not find ric: " + name); + } + return ric; + } + + public synchronized Ric get(String name) { return rics.get(name); } - public int size() { + public synchronized void remove(String name) { + rics.remove(name); + } + + public synchronized int size() { return rics.size(); } - public void clear() { + public synchronized void clear() { this.rics.clear(); } }