X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FServiceSupervision.java;h=751c0ac069a4b41904cbf7e1d09516f03a708b4d;hb=db6bb3802115a45cece80aed62683e02cd7d3282;hp=26509925db587160cdd121591925438e03722ba9;hpb=be2000ec2d21151b42cb559ef881695eb32e35e9;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java index 26509925..751c0ac0 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java @@ -105,9 +105,7 @@ public class ServiceSupervision { } private Flux getAllPoliciesForService(Service service) { - synchronized (policies) { - return Flux.fromIterable(policies.getForService(service.getName())); - } + return Flux.fromIterable(policies.getForService(service.getName())); } private Mono deletePolicyInRic(Policy policy) { @@ -118,7 +116,8 @@ public class ServiceSupervision { } private Mono handleDeleteFromRicFailure(Policy policy, Throwable e) { - logger.warn("Could not delete policy: {} from ric: {}", policy.id(), policy.ric().name(), e); + logger.warn("Could not delete policy: {} from ric: {}. Cause: {}", policy.id(), policy.ric().name(), + e.getMessage()); return Mono.empty(); } }