diff options
Diffstat (limited to 'src/main/java/org/onap')
12 files changed, 430 insertions, 94 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/Configuration.java b/src/main/java/org/onap/dcaegen2/services/sonhms/Configuration.java index a0dc6c5..5cb145a 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/Configuration.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/Configuration.java @@ -42,7 +42,8 @@ public class Configuration { private int minConfusion; private String sourceId; private String callbackUrl; - private List<String> optimizers; + private String pciOptimizer; + private String pciAnrOptimizer; private int numSolutions; private int bufferTime; private int maximumClusters; @@ -52,7 +53,53 @@ public class Configuration { private Map<String, Object> streamsPublishes; private int badThreshold; private int poorThreshold; + private int poorCountThreshold; + private int badCountThreshold; + private int oofTriggerCountTimer; + private int oofTriggerCountThreshold; + private int policyRespTimer; + + public int getPoorCountThreshold() { + return poorCountThreshold; + } + + public void setPoorCountThreshold(int poorCountThreshold) { + this.poorCountThreshold = poorCountThreshold; + } + + public int getBadCountThreshold() { + return badCountThreshold; + } + + public void setBadCountThreshold(int badCountThreshold) { + this.badCountThreshold = badCountThreshold; + } + + public int getOofTriggerCountTimer() { + return oofTriggerCountTimer; + } + + public void setOofTriggerCountTimer(int oofTriggerCountTimer) { + this.oofTriggerCountTimer = oofTriggerCountTimer; + } + + public int getOofTriggerCountThreshold() { + return oofTriggerCountThreshold; + } + + public void setOofTriggerCountThreshold(int oofTriggerCountThreshold) { + this.oofTriggerCountThreshold = oofTriggerCountThreshold; + } + + public int getPolicyRespTimer() { + return policyRespTimer; + } + + public void setPolicyRespTimer(int policyRespTimer) { + this.policyRespTimer = policyRespTimer; + } + public int getBadThreshold() { return badThreshold; } @@ -203,14 +250,6 @@ public class Configuration { this.callbackUrl = callbackUrl; } - public List<String> getOptimizers() { - return optimizers; - } - - public void setOptimizers(List<String> optimizers) { - this.optimizers = optimizers; - } - public int getNumSolutions() { return numSolutions; } @@ -275,16 +314,38 @@ public class Configuration { this.configDbService = configDbService; } + public String getPciOptimizer() { + return pciOptimizer; + } + + public void setPciOptimizer(String pciOptimizer) { + this.pciOptimizer = pciOptimizer; + } + + public String getPciAnrOptimizer() { + return pciAnrOptimizer; + } + + public void setPciAnrOptimizer(String pciAnrOptimizer) { + this.pciAnrOptimizer = pciAnrOptimizer; + } + @Override public String toString() { return "Configuration [pgHost=" + pgHost + ", pgPort=" + pgPort + ", pgUsername=" + pgUsername + ", pgPassword=" + pgPassword + ", dmaapServers=" + dmaapServers + ", configDbService=" + configDbService + ", oofService=" + oofService + ", cg=" + cg + ", cid=" + cid + ", pollingInterval=" + pollingInterval + ", pollingTimeout=" + pollingTimeout + ", minCollision=" + minCollision + ", minConfusion=" - + minConfusion + ", sourceId=" + sourceId + ", callbackUrl=" + callbackUrl + ", optimizers=" - + optimizers + ", numSolutions=" + numSolutions + ", bufferTime=" + bufferTime + ", maximumClusters=" - + maximumClusters + ", aafUsername=" + aafUsername + ", aafPassword=" + aafPassword - + ", streamsSubscribes=" + streamsSubscribes + ", streamsPublishes=" + streamsPublishes + "]"; + + minConfusion + ", sourceId=" + sourceId + ", callbackUrl=" + callbackUrl + ", pciOptimizer=" + + pciOptimizer + ", pciAnrOptimizer=" + pciAnrOptimizer + ", numSolutions=" + numSolutions + + ", bufferTime=" + bufferTime + ", maximumClusters=" + maximumClusters + ", aafUsername=" + aafUsername + + ", aafPassword=" + aafPassword + ", streamsSubscribes=" + streamsSubscribes + ", streamsPublishes=" + + streamsPublishes + ", badThreshold=" + badThreshold + ", poorThreshold=" + poorThreshold + + ", poorCountThreshold=" + poorCountThreshold + ", badCountThreshold=" + badCountThreshold + + ", oofTriggerCountTimer=" + oofTriggerCountTimer + ", oofTriggerCountThreshold=" + + oofTriggerCountThreshold + ", policyRespTimer=" + policyRespTimer + "]"; } + + } diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/HoMetricsComponent.java b/src/main/java/org/onap/dcaegen2/services/sonhms/HoMetricsComponent.java index cf1cf45..eca0930 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/HoMetricsComponent.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/HoMetricsComponent.java @@ -27,9 +27,11 @@ import com.fasterxml.jackson.databind.ObjectMapper; import fj.data.Either; import java.util.ArrayList; +import java.util.Iterator; import java.util.List; import org.onap.dcaegen2.services.sonhms.dao.HandOverMetricsRepository; +import org.onap.dcaegen2.services.sonhms.entity.HandOverMetrics; import org.onap.dcaegen2.services.sonhms.model.HoDetails; import org.onap.dcaegen2.services.sonhms.utils.BeanUtil; import org.slf4j.Logger; @@ -61,4 +63,30 @@ public class HoMetricsComponent { return Either.right(404); } } + + public Boolean update(String hoDetails, String srcCellId) { + try { + HandOverMetricsRepository handOverMetricsRepository = BeanUtil.getBean(HandOverMetricsRepository.class); + handOverMetricsRepository.updateHoMetrics(hoDetails, srcCellId); + return true; + }catch(Exception e) { + log.info("Exception in updating ho metrics {}",e); + return false; + } + } + public Either<List<HandOverMetrics>, Integer> getAll() { + HandOverMetricsRepository handOverMetricsRepository = BeanUtil.getBean(HandOverMetricsRepository.class); + try { + Iterable<HandOverMetrics> hoMetrics = handOverMetricsRepository.findAll(); + List<HandOverMetrics> hoMetricsList = new ArrayList<>(); + Iterator<HandOverMetrics> hoMetricsIterator = hoMetrics.iterator(); + while (hoMetricsIterator.hasNext()) { + hoMetricsList.add(hoMetricsIterator.next()); + } + return Either.left(hoMetricsList); + } catch (Exception e) { + log.info("error in getAll() hoMetrics"); + return Either.right(500); + } + } } diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java b/src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java index e2223d7..fe809ec 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java @@ -23,8 +23,13 @@ package org.onap.dcaegen2.services.sonhms; import com.fasterxml.jackson.annotation.JsonInclude.Include; import com.fasterxml.jackson.databind.ObjectMapper; + +import fj.data.Either; + import java.util.ArrayList; +import java.util.HashMap; import java.util.List; +import java.util.Map; import java.util.UUID; import org.onap.dcaegen2.services.sonhms.child.ChildThreadUtils; @@ -67,34 +72,94 @@ public class PmNotificationHandler { /** * handle PM notifications. */ - public Boolean handlePmNotifications(PmNotification pmNotification, int badThreshold) { - HandOverMetricsRepository handOverMetricsRepository = BeanUtil.getBean(HandOverMetricsRepository.class); + public Boolean handlePmNotifications(PmNotification pmNotification, int badThreshold, int poorThreshold, + int badCountThreshold) { Boolean result; + Boolean newEntryFlag = false; try { List<HoDetails> hoDetailsList = new ArrayList<>(); List<LteCell> lteCellList = new ArrayList<>(); String srcCellId = pmNotification.getEvent().getCommonEventHeader().getSourceName(); + /* + * check whether entry already exists if yes : read the hometrics and update it + * with latest info else store the current data + */ + HoMetricsComponent hoMetricsComponent = new HoMetricsComponent(); + Either<List<HoDetails>, Integer> hoMetrics = hoMetricsComponent.getHoMetrics(srcCellId); + Map<String, Integer> dstCellIdPcPair = new HashMap<>(); + Map<String, Integer> dstCellIdBcPair = new HashMap<>(); + if (hoMetrics.isLeft()) { + List<HoDetails> oldHoDetailsList = hoMetrics.left().value(); + for (HoDetails hodetail : oldHoDetailsList) { + dstCellIdBcPair.put(hodetail.getDstCellId(), hodetail.getBadCount()); + dstCellIdPcPair.put(hodetail.getDstCellId(), hodetail.getPoorCount()); + } + + } else if (hoMetrics.right().value() == 404) { + newEntryFlag = true; + log.info("no history of srcCell found"); + } for (AdditionalMeasurements additionalMeasurements : pmNotification.getEvent().getMeasurementFields() .getAdditionalMeasurements()) { int attemptsCount = Integer.parseInt(additionalMeasurements.getHashMap().get("InterEnbOutAtt_X2HO")); int successCount = Integer.parseInt(additionalMeasurements.getHashMap().get("InterEnbOutSucc_X2HO")); float successRate = ((float) successCount / attemptsCount) * 100; - if (successRate >= badThreshold) { + + if (successRate >= badThreshold && successRate <= poorThreshold) { // poor neighbor HoDetails hoDetails = new HoDetails(); hoDetails.setDstCellId(additionalMeasurements.getName()); hoDetails.setAttemptsCount(attemptsCount); hoDetails.setSuccessCount(successCount); hoDetails.setSuccessRate(successRate); + int pc = 1; + int bc = 0; + if (dstCellIdPcPair.containsKey(additionalMeasurements.getName())) { + pc = dstCellIdPcPair.get(additionalMeasurements.getName()) + 1; + } + hoDetails.setBadCount(bc); + hoDetails.setPoorCount(pc); hoDetailsList.add(hoDetails); - log.info("not bad neighbor {}", additionalMeasurements.getName()); - } else { + log.info("poor neighbor {}", additionalMeasurements.getName()); + } else if (successRate < badThreshold) { // bad neighbor log.info(" bad neighbor {}", additionalMeasurements.getName()); - LteCell lteCell = new LteCell(); - lteCell.setBlacklisted("true"); - lteCell.setCid(additionalMeasurements.getName()); - lteCell.setPlmnId(additionalMeasurements.getHashMap().get("networkId")); - lteCell.setPnfName(pmNotification.getEvent().getCommonEventHeader().getReportingEntityName()); - lteCellList.add(lteCell); + HoDetails hoDetails = new HoDetails(); + hoDetails.setDstCellId(additionalMeasurements.getName()); + hoDetails.setAttemptsCount(attemptsCount); + hoDetails.setSuccessCount(successCount); + hoDetails.setSuccessRate(successRate); + int bc = 1; + int pc = 0; + if (dstCellIdBcPair.containsKey(additionalMeasurements.getName())) { + bc = dstCellIdBcPair.get(additionalMeasurements.getName()) + 1; + } + if (dstCellIdPcPair.containsKey(additionalMeasurements.getName())) { + pc = dstCellIdPcPair.get(additionalMeasurements.getName()); + } + hoDetails.setBadCount(bc); + hoDetails.setPoorCount(pc); + hoDetailsList.add(hoDetails); + if (bc >= badCountThreshold) { + LteCell lteCell = new LteCell(); + lteCell.setBlacklisted("true"); + lteCell.setCid(additionalMeasurements.getName()); + lteCell.setPlmnId(additionalMeasurements.getHashMap().get("networkId")); + lteCell.setPnfName(pmNotification.getEvent().getCommonEventHeader().getReportingEntityName()); + lteCellList.add(lteCell); + hoDetailsList.remove(hoDetails); + } + + } else if (successRate > poorThreshold) { // good neighbor + HoDetails hoDetails = new HoDetails(); + hoDetails.setDstCellId(additionalMeasurements.getName()); + hoDetails.setAttemptsCount(attemptsCount); + hoDetails.setSuccessCount(successCount); + hoDetails.setSuccessRate(successRate); + int pc = 0; + int bc = 0; + hoDetails.setBadCount(bc); + hoDetails.setPoorCount(pc); + hoDetailsList.add(hoDetails); + log.info("good neighbor {}", additionalMeasurements.getName()); } } if (!lteCellList.isEmpty()) { @@ -109,24 +174,21 @@ public class PmNotificationHandler { result = sendAnrUpdateToPolicy(pmNotification, lteCellList); log.info("Sent ANR update to policy {}", result); policyTriggerFlag.setHolder("NONE"); - - String hoDetailsString = handOverMetricsRepository.getHandOverMetrics(srcCellId); - if (hoDetailsString != null) { - ObjectMapper mapper = new ObjectMapper(); - String newHoDetailsString = null; - try { - newHoDetailsString = mapper.writeValueAsString(hoDetailsList); - } catch (Exception e) { - log.error("Error in writing handover metrics json ", e); - return false; - } - handOverMetricsRepository.updateHoMetrics(newHoDetailsString, srcCellId); - } } - if (!hoDetailsList.isEmpty()) { + if (!hoDetailsList.isEmpty() && newEntryFlag) { result = saveToHandOverMetrics(hoDetailsList, srcCellId); log.debug("save HO metrics result {} ", result); + } else if (!hoDetailsList.isEmpty()) { + String hoDetailsString = null; + ObjectMapper mapper = new ObjectMapper(); + try { + hoDetailsString = mapper.writeValueAsString(hoDetailsList); + } catch (Exception e) { + log.error("Error in writing handover metrics json ", e); + return false; + } + hoMetricsComponent.update(hoDetailsString, srcCellId); } } catch (Exception e) { @@ -153,7 +215,7 @@ public class PmNotificationHandler { log.info("payload : {}", payload); String anrUpdateString = mapper.writeValueAsString(payload); ChildThreadUtils childUtils = new ChildThreadUtils(ConfigPolicy.getInstance(), new PnfUtils(), - new PolicyDmaapClient(new DmaapUtils(), Configuration.getInstance())); + new PolicyDmaapClient(new DmaapUtils(), Configuration.getInstance()), new HoMetricsComponent()); String requestId = UUID.randomUUID().toString(); String notification = childUtils.getNotificationString( pmNotification.getEvent().getCommonEventHeader().getReportingEntityName(), requestId, @@ -182,15 +244,10 @@ public class PmNotificationHandler { log.error("Error in writing handover metrics json ", e); return false; } - - if (handOverMetricsRepository.getHandOverMetrics(srcCellId) == null) { - HandOverMetrics handOverMetrics = new HandOverMetrics(); - handOverMetrics.setHoDetails(hoDetailsString); - handOverMetrics.setSrcCellId(srcCellId); - handOverMetricsRepository.save(handOverMetrics); - } else { - handOverMetricsRepository.updateHoMetrics(hoDetailsString, srcCellId); - } + HandOverMetrics handOverMetrics = new HandOverMetrics(); + handOverMetrics.setHoDetails(hoDetailsString); + handOverMetrics.setSrcCellId(srcCellId); + handOverMetricsRepository.save(handOverMetrics); return true; } } diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/PmThread.java b/src/main/java/org/onap/dcaegen2/services/sonhms/PmThread.java index 49f0c56..b2d4568 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/PmThread.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/PmThread.java @@ -72,7 +72,8 @@ public class PmThread implements Runnable { } else if (pmNotification.isLeft()) { Configuration configuration = Configuration.getInstance(); Boolean result = pmNotificationHandler.handlePmNotifications(pmNotification.left().value(), - configuration.getBadThreshold()); + configuration.getBadThreshold(), configuration.getPoorThreshold(), + configuration.getBadCountThreshold()); log.info("pm notification handler result {}", result); } diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/Timer.java b/src/main/java/org/onap/dcaegen2/services/sonhms/Timer.java new file mode 100644 index 0000000..aff5fe5 --- /dev/null +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/Timer.java @@ -0,0 +1,75 @@ +/******************************************************************************* + * ============LICENSE_START======================================================= + * son-handler + * ================================================================================ + * Copyright (C) 2019 Wipro Limited. + * ============================================================================== + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + * + *******************************************************************************/ + +package org.onap.dcaegen2.services.sonhms; + +import java.sql.Timestamp; + +import javax.annotation.PostConstruct; +import org.springframework.stereotype.Component; + +@Component +public class Timer { + + private Timestamp startTime; + private Timestamp currentTime; + private Boolean isTimer; + private int count; + + @PostConstruct + void init() { + isTimer = false; + count = 0; + } + + public Timestamp getStartTime() { + return startTime; + } + + public void setStartTime(Timestamp startTime) { + this.startTime = startTime; + } + + public Timestamp getCurrentTime() { + return currentTime; + } + + public void setCurrentTime(Timestamp currentTime) { + this.currentTime = currentTime; + } + + public Boolean getIsTimer() { + return isTimer; + } + + public void setIsTimer(Boolean isTimer) { + this.isTimer = isTimer; + } + + public int getCount() { + return count; + } + + public void setCount(int count) { + this.count = count; + } + +}
\ No newline at end of file diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/child/ChildThread.java b/src/main/java/org/onap/dcaegen2/services/sonhms/child/ChildThread.java index b053467..0170f90 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/child/ChildThread.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/child/ChildThread.java @@ -21,6 +21,7 @@ package org.onap.dcaegen2.services.sonhms.child; +import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.databind.ObjectMapper; import fj.data.Either; @@ -42,9 +43,11 @@ import org.onap.dcaegen2.services.sonhms.ClusterDetailsComponent; import org.onap.dcaegen2.services.sonhms.ConfigPolicy; import org.onap.dcaegen2.services.sonhms.Configuration; import org.onap.dcaegen2.services.sonhms.HoMetricsComponent; +import org.onap.dcaegen2.services.sonhms.Timer; import org.onap.dcaegen2.services.sonhms.dao.ClusterDetailsRepository; import org.onap.dcaegen2.services.sonhms.dao.SonRequestsRepository; import org.onap.dcaegen2.services.sonhms.dmaap.PolicyDmaapClient; +import org.onap.dcaegen2.services.sonhms.entity.HandOverMetrics; import org.onap.dcaegen2.services.sonhms.exceptions.ConfigDbNotFoundException; import org.onap.dcaegen2.services.sonhms.model.AnrInput; import org.onap.dcaegen2.services.sonhms.model.CellPciPair; @@ -150,7 +153,7 @@ public class ChildThread implements Runnable { ClusterUtils clusterUtils = new ClusterUtils(); Detection detect = new Detection(); ChildThreadUtils childUtils = new ChildThreadUtils(ConfigPolicy.getInstance(), new PnfUtils(), - new PolicyDmaapClient(new DmaapUtils(), Configuration.getInstance())); + new PolicyDmaapClient(new DmaapUtils(), Configuration.getInstance()), new HoMetricsComponent()); try { String networkId = cluster.getNetworkId(); @@ -217,7 +220,7 @@ public class ChildThread implements Runnable { cellidList.add(cell); } UUID transactionId; - + Flag policyTriggerFlag = BeanUtil.getBean(Flag.class); while (policyTriggerFlag.getHolder().equals("PM")) { Thread.sleep(100); @@ -225,21 +228,55 @@ public class ChildThread implements Runnable { policyTriggerFlag.setHolder("CHILD"); policyTriggerFlag.setNumChilds(policyTriggerFlag.getNumChilds() + 1); - Either<List<AnrInput>, Integer> anrTriggerResponse = checkAnrTrigger(cellidList); - if (anrTriggerResponse.isRight()) { + Timer timerOof = BeanUtil.getBean(Timer.class); + if (!timerOof.getIsTimer()) { + log.info("Starting timer"); + timerOof.setIsTimer(true); + Timestamp startTime = new Timestamp(System.currentTimeMillis()); + timerOof.setStartTime(startTime); + timerOof.setCount(0); + log.info("startTime {}", startTime); + + } + Timestamp currentTime = new Timestamp(System.currentTimeMillis()); + Long difference = currentTime.getTime() - timerOof.getStartTime().getTime(); + int timerThreshold = (Configuration.getInstance().getOofTriggerCountTimer() * 60000); + int triggerCountThreshold = Configuration.getInstance().getOofTriggerCountThreshold(); + log.info("Time threshold {}, triggerCountThreshold {}", timerThreshold, triggerCountThreshold); + log.info("oof trigger count {}", timerOof.getCount()); + timerOof.setCount(timerOof.getCount()+1); + if (difference < timerThreshold && timerOof.getCount() > triggerCountThreshold) { + log.info("difference {}", difference); + + Either<List<AnrInput>, Integer> anrTriggerResponse = checkAnrTrigger(); + if (anrTriggerResponse.isRight()) { + log.info("ANR trigger response right {}", anrTriggerResponse.right().value()); + if (anrTriggerResponse.right().value() == 404) { + log.info("No poor neighbors found"); + } else if (anrTriggerResponse.right().value() == 500) { + log.info("Failed to fetch HO details from DB "); + } + transactionId = oof.triggerOof(cellidList, networkId, new ArrayList<>()); + + + } else { + log.info("ANR trigger response left {}", anrTriggerResponse.left().value()); + List<AnrInput> anrInputList = anrTriggerResponse.left().value(); + log.info("Trigger oof for joint optimization"); + transactionId = oof.triggerOof(cellidList, networkId, anrInputList); - if (anrTriggerResponse.right().value() == 404) { - log.debug("No poor neighbors found"); - } else if (anrTriggerResponse.right().value() == 500) { - log.debug("Failed to fetch HO details from DB "); } - transactionId = oof.triggerOof(cellidList, networkId, new ArrayList<>()); } else { - List<AnrInput> anrInputList = anrTriggerResponse.left().value(); - log.info("Trigger oof for joint optimization"); - transactionId = oof.triggerOof(cellidList, networkId, anrInputList); + + transactionId = oof.triggerOof(cellidList, networkId, new ArrayList<>()); + + if (difference > timerThreshold) { + timerOof.setIsTimer(false); + timerOof.setCount(0); + } } + long childThreadId = Thread.currentThread().getId(); childUtils.saveRequest(transactionId.toString(), childThreadId); while (!ChildThread.getResponseMap().containsKey(childThreadId)) { @@ -248,15 +285,12 @@ public class ChildThread implements Runnable { AsyncResponseBody asynResponseBody = ChildThread.getResponseMap().get(childThreadId); - - try { childUtils.sendToPolicy(asynResponseBody); policyTriggerFlag.setNumChilds(policyTriggerFlag.getNumChilds() - 1); if (policyTriggerFlag.getNumChilds() == 0) { policyTriggerFlag.setHolder("NONE"); } - } catch (ConfigDbNotFoundException e1) { log.debug("Config DB is unreachable: {}", e1); @@ -404,34 +438,38 @@ public class ChildThread implements Runnable { /** * Check if ANR to be triggered. */ - public Either<List<AnrInput>, Integer> checkAnrTrigger(List<String> cellidList) { + public Either<List<AnrInput>, Integer> checkAnrTrigger() { List<AnrInput> anrInputList = new ArrayList<>(); Configuration configuration = Configuration.getInstance(); - int poorThreshold = configuration.getPoorThreshold(); List<HoDetails> hoDetailsList; - Either<List<HoDetails>, Integer> response; - for (String cellId : cellidList) { - response = hoMetricsComponent.getHoMetrics(cellId); + Either<List<HandOverMetrics>, Integer> hoMetrics = hoMetricsComponent.getAll(); + if(hoMetrics.isRight()) { + log.error("Error in getting HO details from db"); + return Either.right(500); + } + List<HandOverMetrics> hoMetricsList = hoMetrics.left().value(); + for (HandOverMetrics hoMetric : hoMetricsList) { + String hoDetailsListString = hoMetric.getHoDetails(); + ObjectMapper mapper = new ObjectMapper(); + try { + hoDetailsList = mapper.readValue(hoDetailsListString, new TypeReference<ArrayList<HoDetails>>() { + }); + } catch (Exception e) { + log.error("Exception in parsing HO metrics", hoDetailsListString, e); + continue; + } List<String> removeableNeighbors = new ArrayList<>(); - if (response.isLeft()) { - hoDetailsList = response.left().value(); - for (HoDetails hoDetail : hoDetailsList) { - if (hoDetail.getSuccessRate() < poorThreshold) { + log.info("Checking poor count for src cell {}", hoMetric.getSrcCellId()); + for (HoDetails hoDetail : hoDetailsList) { + if (hoDetail.getPoorCount() >= configuration.getPoorCountThreshold()) { removeableNeighbors.add(hoDetail.getDstCellId()); } } - } else { - if (response.right().value() == 400) { - log.error("Error in getting HO details from db"); - return Either.right(500); - } else { - log.info("no HO metrics found"); - } - } + if (!removeableNeighbors.isEmpty()) { - AnrInput anrInput = new AnrInput(cellId, removeableNeighbors); + AnrInput anrInput = new AnrInput(hoMetric.getSrcCellId(), removeableNeighbors); anrInputList.add(anrInput); } } @@ -440,4 +478,4 @@ public class ChildThread implements Runnable { } return Either.right(404); } -} +}
\ No newline at end of file diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/child/ChildThreadUtils.java b/src/main/java/org/onap/dcaegen2/services/sonhms/child/ChildThreadUtils.java index 183de84..d567c8a 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/child/ChildThreadUtils.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/child/ChildThreadUtils.java @@ -25,6 +25,8 @@ import com.fasterxml.jackson.annotation.JsonInclude.Include; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; +import fj.data.Either; + import java.util.ArrayList; import java.util.List; import java.util.Map; @@ -32,6 +34,7 @@ import java.util.UUID; import org.onap.dcaegen2.services.sonhms.ConfigPolicy; import org.onap.dcaegen2.services.sonhms.Configuration; +import org.onap.dcaegen2.services.sonhms.HoMetricsComponent; import org.onap.dcaegen2.services.sonhms.dao.SonRequestsRepository; import org.onap.dcaegen2.services.sonhms.dmaap.PolicyDmaapClient; import org.onap.dcaegen2.services.sonhms.entity.SonRequests; @@ -42,6 +45,7 @@ import org.onap.dcaegen2.services.sonhms.model.Common; import org.onap.dcaegen2.services.sonhms.model.Configurations; import org.onap.dcaegen2.services.sonhms.model.Data; import org.onap.dcaegen2.services.sonhms.model.FapService; +import org.onap.dcaegen2.services.sonhms.model.HoDetails; import org.onap.dcaegen2.services.sonhms.model.Lte; import org.onap.dcaegen2.services.sonhms.model.LteCell; import org.onap.dcaegen2.services.sonhms.model.NeighborListInUse; @@ -61,14 +65,16 @@ public class ChildThreadUtils { private ConfigPolicy configPolicy; private PnfUtils pnfUtils; private PolicyDmaapClient policyDmaapClient; + private HoMetricsComponent hoMetricsComponent; /** * Parameterized constructor. */ - public ChildThreadUtils(ConfigPolicy configPolicy, PnfUtils pnfUtils, PolicyDmaapClient policyDmaapClient) { + public ChildThreadUtils(ConfigPolicy configPolicy, PnfUtils pnfUtils, PolicyDmaapClient policyDmaapClient, HoMetricsComponent hoMetricsComponent) { this.configPolicy = configPolicy; this.pnfUtils = pnfUtils; this.policyDmaapClient = policyDmaapClient; + this.hoMetricsComponent = hoMetricsComponent; } /** @@ -219,7 +225,29 @@ public class ChildThreadUtils { lteCellList, String.valueOf(lteCellList.size()))))))), null); configurations.add(configuration); + Either<List<HoDetails>, Integer> hoMetrics = hoMetricsComponent.getHoMetrics(cellId); + if(hoMetrics.isLeft()) { + List<HoDetails> hoDetailsList = hoMetrics.left().value(); + for(LteCell lteCell:lteCellList) { + String removedNbr = lteCell.getCid(); + for(HoDetails hoDetail:hoDetailsList) { + if(removedNbr.equals(hoDetail.getDstCellId())) { + hoDetailsList.remove(hoDetail); + break; + } + } + } + String hoDetailsString = null; + ObjectMapper mapper = new ObjectMapper(); + try { + hoDetailsString = mapper.writeValueAsString(hoDetailsList); + } catch (Exception e) { + log.error("Error in writing handover metrics json ", e); + return false; + } + hoMetricsComponent.update(hoDetailsString, cellId); } + } Payload payload = new Payload(configurations); ObjectMapper mapper = new ObjectMapper(); @@ -238,6 +266,8 @@ public class ChildThreadUtils { log.info("send notification to policy result {} ", result); policyDmaapClient.handlePolicyResponse(requestId); log.info("handled policy response in ModifyConfigANR"); + + } } diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/child/StateOof.java b/src/main/java/org/onap/dcaegen2/services/sonhms/child/StateOof.java index acfa1a4..8eb5a40 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/child/StateOof.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/child/StateOof.java @@ -66,10 +66,20 @@ public class StateOof { Configuration config = Configuration.getInstance(); int numSolutions = config.getNumSolutions(); - List<String> optimizers = config.getOptimizers(); - - String oofResponse = OofRestClient.queryOof(numSolutions, transactionId.toString(), "create", cellidList, - networkId, optimizers, anrInputList); + List<String> pciOptimizerList = new ArrayList<>(); + List<String> pciAnrOptimizerList = new ArrayList<>(); + + pciOptimizerList.add(config.getPciOptimizer()); + pciAnrOptimizerList.add(config.getPciAnrOptimizer()); + + String oofResponse =null; + if(!anrInputList.isEmpty()) { + oofResponse = OofRestClient.queryOof(numSolutions, transactionId.toString(), "create", cellidList, + networkId, pciAnrOptimizerList, anrInputList); + }else { + oofResponse = OofRestClient.queryOof(numSolutions, transactionId.toString(), "create", cellidList, + networkId, pciOptimizerList, anrInputList); + } log.info("Synchronous Response {}", oofResponse); List<String> childStatus = new ArrayList<>(); diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/controller/ConfigFetchFromCbs.java b/src/main/java/org/onap/dcaegen2/services/sonhms/controller/ConfigFetchFromCbs.java index 548cb4d..7ec446c 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/controller/ConfigFetchFromCbs.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/controller/ConfigFetchFromCbs.java @@ -114,8 +114,8 @@ public class ConfigFetchFromCbs { String namespace = jsonObject.get("sonhandler.namespace").getAsString(); String callbackUrl = "http://" + System.getenv("HOSTNAME") + "." + namespace + ":8080/callbackUrl"; - JsonArray optimizersJson = jsonObject.getAsJsonArray("sonhandler.optimizers"); - List<String> optimizers = new Gson().fromJson(optimizersJson, listType); + String pciOptimizer = jsonObject.get("sonhandler.pciOptimizer").getAsString(); + String pciAnrOptimizer = jsonObject.get("sonhandler.pciAnrOptimizer").getAsString(); String oofService = jsonObject.get("sonhandler.oof.service").getAsString(); int pollingTimeout = jsonObject.get("sonhandler.pollingTimeout").getAsInt(); @@ -123,6 +123,12 @@ public class ConfigFetchFromCbs { int badThreshold = jsonObject.get("sonhandler.badThreshold").getAsInt(); int poorThreshold = jsonObject.get("sonhandler.poorThreshold").getAsInt(); + int poorCountThreshold = jsonObject.get("sonhandler.poorCountThreshold").getAsInt(); + int badCountThreshold = jsonObject.get("sonhandler.badCountThreshold").getAsInt(); + int oofTriggerCountTimer = jsonObject.get("sonhandler.oofTriggerCountTimer").getAsInt(); + int oofTriggerCountThreshold = jsonObject.get("sonhandler.oofTriggerCountThreshold").getAsInt(); + int policyRespTimer = jsonObject.get("sonhandler.policyRespTimer").getAsInt(); + configuration.setStreamsSubscribes(streamsSubscribes); configuration.setStreamsPublishes(streamsPublishes); configuration.setPgPassword(pgPassword); @@ -141,11 +147,18 @@ public class ConfigFetchFromCbs { configuration.setBufferTime(bufferTime); configuration.setConfigDbService(configDbService); configuration.setCallbackUrl(callbackUrl); - configuration.setOptimizers(optimizers); + configuration.setPciOptimizer(pciOptimizer); + configuration.setPciAnrOptimizer(pciAnrOptimizer); configuration.setOofService(oofService); configuration.setPollingTimeout(pollingTimeout); configuration.setBadThreshold(badThreshold); configuration.setPoorThreshold(poorThreshold); + configuration.setPoorCountThreshold(poorCountThreshold); + configuration.setBadCountThreshold(badCountThreshold); + configuration.setOofTriggerCountTimer(oofTriggerCountTimer); + configuration.setOofTriggerCountThreshold(oofTriggerCountThreshold); + configuration.setPolicyRespTimer(policyRespTimer); + log.info("configuration from CBS {}", configuration.toString()); } diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java b/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java index d5371eb..a0a1274 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java @@ -90,8 +90,8 @@ public class PolicyDmaapClient { Timestamp currentTime = new Timestamp(System.currentTimeMillis()); Long difference = currentTime.getTime() - startTimer.getTime(); - - while (difference < 10000) { + int policyRespTimer = configuration.getPolicyRespTimer(); // Timer in seconds + while (difference < (policyRespTimer*1000)) { Iterable<String> policyResponseMessages; try { policyResponseMessages = policyResponseCambriaConsumer.fetch(); diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/model/HoDetails.java b/src/main/java/org/onap/dcaegen2/services/sonhms/model/HoDetails.java index 1d43f09..b6e2ab9 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/model/HoDetails.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/model/HoDetails.java @@ -27,6 +27,8 @@ public class HoDetails { private int attemptsCount; private int successCount; private float successRate; + private int poorCount; + private int badCount; /** * default constructor. @@ -35,6 +37,27 @@ public class HoDetails { } + + public int getPoorCount() { + return poorCount; + } + + + public void setPoorCount(int poorCount) { + this.poorCount = poorCount; + } + + + public int getBadCount() { + return badCount; + } + + + public void setBadCount(int badCount) { + this.badCount = badCount; + } + + public String getDstCellId() { return dstCellId; } diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/utils/ThreadUtils.java b/src/main/java/org/onap/dcaegen2/services/sonhms/utils/ThreadUtils.java index 5889b63..2c2a764 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/utils/ThreadUtils.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/utils/ThreadUtils.java @@ -88,4 +88,4 @@ public class ThreadUtils { } } -} +}
\ No newline at end of file |