X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FRicSynchronizationTask.java;h=0a0ab826665438fdd3b895e8350d6be55697ccc4;hb=5408c157fc8aca52731fcc2cc035ed9dbfcff219;hp=19036efb141c6b55e584c5d8b6f8f9bbe56cfc08;hpb=9033316e83ab3927034ed0380d048648813caaab;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSynchronizationTask.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSynchronizationTask.java index 19036efb..0a0ab826 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSynchronizationTask.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSynchronizationTask.java @@ -72,7 +72,7 @@ public class RicSynchronizationTask { this.services = services; } - @SuppressWarnings("squid:S2629") + @SuppressWarnings("squid:S2629") // Invoke method(s) only conditionally public void run(Ric ric) { logger.debug("Handling ric: {}", ric.getConfig().name()); @@ -101,9 +101,9 @@ public class RicSynchronizationTask { return Flux.concat(recoverTypes, policiesDeletedInRic, policiesRecreatedInRic); } - @SuppressWarnings("squid:S2629") + @SuppressWarnings("squid:S2629") // Invoke method(s) only conditionally private void onSynchronizationComplete(Ric ric) { - logger.debug("Synchronization completed for: {}", ric.name()); + logger.info("Synchronization completed for: {}", ric.name()); ric.setState(RicState.IDLE); notifyAllServices("Synchronization completed for:" + ric.name()); } @@ -124,7 +124,7 @@ public class RicSynchronizationTask { } } - @SuppressWarnings("squid:S2629") + @SuppressWarnings("squid:S2629") // Invoke method(s) only conditionally private void onSynchronizationError(Ric ric, Throwable t) { logger.warn("Synchronization failed for ric: {}, reason: {}", ric.name(), t.getMessage()); // If synchronization fails, try to remove all instances @@ -142,7 +142,7 @@ public class RicSynchronizationTask { () -> onSynchronizationComplete(ric)); } - @SuppressWarnings("squid:S2629") + @SuppressWarnings("squid:S2629") // Invoke method(s) only conditionally private void onRecoveryError(Ric ric, Throwable t) { logger.warn("Synchronization failure recovery failed for ric: {}, reason: {}", ric.name(), t.getMessage()); ric.setState(RicState.UNDEFINED);