X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FRicRecoveryTask.java;h=ab25eab46382bb66d89e0da707c58548250e00c2;hb=80ebd8eb750de60424ffb3895fbc7b2032bd1a50;hp=b67dbe0cabd1c23b7720113ee5d4a28e0624ed46;hpb=9fb9f6e4fe8eb9425d848ae576c0e755dfca22df;p=nonrtric.git

diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicRecoveryTask.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicRecoveryTask.java
index b67dbe0c..ab25eab4 100644
--- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicRecoveryTask.java
+++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicRecoveryTask.java
@@ -41,7 +41,8 @@ import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 /**
- * Recovery handling of RIC, which means:
+ * Recovery handling of RIC.
+ * This means:
  * - load all policy types
  * - send all policy instances to the RIC
  * --- if that fails remove all policy instances
@@ -68,7 +69,7 @@ public class RicRecoveryTask {
         logger.debug("Handling ric: {}", ric.getConfig().name());
 
         synchronized (ric) {
-            if (ric.getState() == (Ric.RicState.RECOVERING)) {
+            if (ric.getState() == Ric.RicState.RECOVERING) {
                 return; // Already running
             }
             ric.setState(Ric.RicState.RECOVERING);