X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Frepository%2FRic.java;h=6eece5ec1238b1ba550eca11258615f4c3d81a05;hb=b66dcce5210e25b2571036becb6f0e7b0c23e1b2;hp=e50a98ce517b051efdd70498fc802a878279d964;hpb=a538ca7e0b840e8dc20e85c1864697823ad96ae0;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/repository/Ric.java b/policy-agent/src/main/java/org/oransc/policyagent/repository/Ric.java index e50a98ce..6eece5ec 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/repository/Ric.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/repository/Ric.java @@ -20,14 +20,14 @@ package org.oransc.policyagent.repository; +import java.util.ArrayList; import java.util.Collection; import java.util.HashMap; +import java.util.List; import java.util.Map; import java.util.Vector; - import lombok.Getter; import lombok.Setter; - import org.oransc.policyagent.clients.A1Client.A1ProtocolType; import org.oransc.policyagent.configuration.RicConfig; @@ -36,6 +36,7 @@ import org.oransc.policyagent.configuration.RicConfig; */ public class Ric { private final RicConfig ricConfig; + private final List managedElementIds; private RicState state = RicState.UNDEFINED; private Map supportedPolicyTypes = new HashMap<>(); @@ -43,6 +44,7 @@ public class Ric { @Setter private A1ProtocolType protocolVersion = A1ProtocolType.UNKNOWN; + /** * Creates the Ric. Initial state is {@link RicState.NOT_INITIATED}. * @@ -50,6 +52,7 @@ public class Ric { */ public Ric(RicConfig ricConfig) { this.ricConfig = ricConfig; + this.managedElementIds = new ArrayList<>(ricConfig.managedElementIds()); } public String name() { @@ -74,7 +77,7 @@ public class Ric { * @return a vector containing the nodes managed by this Ric. */ public synchronized Collection getManagedElementIds() { - return new Vector<>(ricConfig.managedElementIds()); + return managedElementIds; } /** @@ -84,7 +87,7 @@ public class Ric { * @return true if the given node is managed by this Ric. */ public synchronized boolean isManaging(String managedElementId) { - return ricConfig.managedElementIds().contains(managedElementId); + return managedElementIds.contains(managedElementId); } /** @@ -93,8 +96,8 @@ public class Ric { * @param managedElementId the node to add. */ public synchronized void addManagedElement(String managedElementId) { - if (!ricConfig.managedElementIds().contains(managedElementId)) { - ricConfig.managedElementIds().add(managedElementId); + if (!managedElementIds.contains(managedElementId)) { + managedElementIds.add(managedElementId); } } @@ -104,7 +107,7 @@ public class Ric { * @param managedElementId the node to remove. */ public synchronized void removeManagedElement(String managedElementId) { - ricConfig.managedElementIds().remove(managedElementId); + managedElementIds.remove(managedElementId); } /** @@ -150,15 +153,15 @@ public class Ric { @Override public synchronized String toString() { return Ric.class.getSimpleName() + ": " + "name: " + name() + ", state: " + state + ", baseUrl: " - + ricConfig.baseUrl() + ", managedNodes: " + ricConfig.managedElementIds(); + + ricConfig.baseUrl() + ", managedNodes: " + managedElementIds; } /** * Represents the states possible for a Ric. */ - public static enum RicState { + public enum RicState { /** - * The agent view of the agent may be inconsistent. + * The agent view of the Ric may be inconsistent. */ UNDEFINED, /** @@ -166,8 +169,8 @@ public class Ric { */ IDLE, /** - * The Ric states are recovered. + * The agent is synchronizing the view of the Ric. */ - RECOVERING + SYNCHRONIZING } }