diff options
author | decheng zhang <decheng.zhang@huawei.com> | 2022-08-23 18:02:28 -0400 |
---|---|---|
committer | decheng zhang <decheng.zhang@huawei.com> | 2022-09-08 09:30:17 -0400 |
commit | 9d6cf9dc122d8c980e1bc96b86b5c0233c372fd0 (patch) | |
tree | 9a0c4985113da0f1bd2e61c87adf1e1dec25c0d8 /components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PolicyService.java | |
parent | c21ca66f190f76feb5800ee500ff87ff7e67f5c5 (diff) |
[SLICEANALYSIS] Enhance BandwidthEvaluator to listen on user's bandwidth threshold
Put bandwidth evaluation into seperated evaluationStrategy; minor enhance to bandwidth evalution and adjustment; adding ratelimiter for each network function calling.
Issue-ID: DCAEGEN2-3239
Issue-ID: DCAEGEN2-3195
Signed-off-by: decheng zhang <decheng.zhang@huawei.com>
Change-Id: Id5e64fea0a03b0b41054840911ea6a7336956415
Signed-off-by: decheng zhang <decheng.zhang@huawei.com>
Diffstat (limited to 'components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PolicyService.java')
-rw-r--r-- | components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PolicyService.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PolicyService.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PolicyService.java index 24aeea61..da55c0b4 100644 --- a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PolicyService.java +++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PolicyService.java @@ -51,9 +51,11 @@ import com.fasterxml.jackson.databind.ObjectMapper; */ @Component public class PolicyService { + private final static int SERVICE_RATE_INTERVAL = 5000; // in ms private PolicyDmaapClient policyDmaapClient; private static Logger log = LoggerFactory.getLogger(PolicyService.class); private ObjectMapper objectMapper = new ObjectMapper(); + private RateLimiter rateLimiter; /** * Initialization @@ -62,6 +64,7 @@ public class PolicyService { public void init() { Configuration configuration = Configuration.getInstance(); policyDmaapClient = new PolicyDmaapClient(configuration); + rateLimiter = new RateLimiter(1, SERVICE_RATE_INTERVAL); } protected <T> OnsetMessage formPolicyOnsetMessage(String snssai, AdditionalProperties<T> addProps, Map<String, String> serviceDetails) { @@ -189,6 +192,7 @@ public class PolicyService { String msg = ""; try { msg = objectMapper.writeValueAsString(onsetMessage); + rateLimiter.getToken(); log.info("Sending onset message to Onap/Policy for ControlLoop-CCVPN-CLL, the msg: {}", msg); policyDmaapClient.sendNotificationToPolicy(msg); } |