aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java')
-rw-r--r--src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java b/src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java
index f711347..131f792 100644
--- a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java
+++ b/src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java
@@ -87,20 +87,20 @@ public class RanVesHolder {
/**
* Stops sending the report after the last cell was stopped. It send the last report before stop completely
*/
- private void stopSendingReports() {
+ private void stopSendingReports(String cellId) {
+ sendLastReport(cellId);
if (nonNull(threadSendReportFunction) && !isAnyEventRunning()) {
threadSendReportFunction.getRanPeriodicVesEvent().getScheduledFuture().cancel(false);
- sendLastReportAfterCancel();
log.info("Stop sending reports every {} seconds", vnfConfigReader.getVnfConfig().getRepPeriod());
}
}
/**
- * Sends the last report after all threads were stopped
+ * Sends the last report after specific cell was stopped
*/
- private void sendLastReportAfterCancel() {
- log.trace("Send last report after report thread was canceled");
- ranFileReadyHolder.createPMBulkFileAndSendFileReadyMessage();
+ private void sendLastReport(String cellId) {
+ log.trace("Send last report after stop for cell: {}", cellId);
+ ranFileReadyHolder.createPMBulkFileAndSendFileReadyMessageForCellId(cellId);
}
Map<String, RanPeriodicEvent> getPeriodicEventsCache() {
@@ -138,7 +138,7 @@ public class RanVesHolder {
return Optional.empty();
}
periodicEvent.getScheduledFuture().cancel(false);
- stopSendingReports();
+ stopSendingReports(identifier);
return Optional.of(periodicEvent);
}