From af58baecadb732685e29e5c1b8172d90fec1458d Mon Sep 17 00:00:00 2001 From: qingshuting Date: Mon, 26 Sep 2022 16:57:12 +0800 Subject: [SLICEMS]Fix bug that config thread hang up when cbs policy is empty Fix bug for config thread Issue-ID: DCAEGEN2-3273 Signed-off-by: qingshuting Change-Id: I3de62d62b5dc91ada70060c0820b0b4b701df728 --- .../onap/slice/analysis/ms/service/ccvpn/BandwidthEvaluator.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/ccvpn/BandwidthEvaluator.java') diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/ccvpn/BandwidthEvaluator.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/ccvpn/BandwidthEvaluator.java index 7ca100d1..67cda89a 100644 --- a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/ccvpn/BandwidthEvaluator.java +++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/ccvpn/BandwidthEvaluator.java @@ -109,16 +109,17 @@ public class BandwidthEvaluator { String serviceId = (String) event.subject(); Map maxBandwidthData = aaiService.fetchMaxBandwidthOfService(serviceId); if (maxBandwidthData.get("maxBandwidth") != null){ - log.info("Successfully retrieved bandwidth info from AAI; service: {}, bandwidth: {}", + log.debug("Successfully retrieved bandwidth info from AAI; service: {}, bandwidth: {}", serviceId, maxBandwidthData.get("maxBandwidth")); int bwValue = maxBandwidthData.get("maxBandwidth").intValue(); if (ccvpnPmDatastore.getProvBwOfSvc(serviceId) == 0){ ccvpnPmDatastore.updateProvBw(serviceId, bwValue, true); + log.debug("Provision bw of cll {} updated from 0 to {}, max bw is {}", serviceId, ccvpnPmDatastore.getProvBwOfSvc(serviceId), bwValue); } else if (ccvpnPmDatastore.getProvBwOfSvc(serviceId) != bwValue) { - log.info("Service modification complete; serviceId: {} with new bandwidth: {}", serviceId, bwValue); + log.debug("Service modification complete; serviceId: {} update prov bw from {} to {}", serviceId, ccvpnPmDatastore.getProvBwOfSvc(serviceId), bwValue); ccvpnPmDatastore.updateProvBw(serviceId, bwValue, true); ccvpnPmDatastore.updateSvcState(serviceId, ServiceState.RUNNING); - log.debug("Service state of {} is changed to running", serviceId); + log.debug("Service state of {} is changed to running, {}", serviceId, ccvpnPmDatastore.getStatusOfSvc(serviceId)); } } log.debug("=== Processing AAI network policy query complete ==="); -- cgit 1.2.3-korg