diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-04-08 12:32:11 +0200 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-04-08 14:19:00 +0200 |
| commit | 6a04ae25ca18f959b8f2b768c8ce2c285ed72c09 (patch) | |
| tree | 08d59203f48ca441f8dc617f1a04ad5031b5a71e /simulator/opendc-experiments/opendc-experiments-capelin/src/main | |
| parent | 8deb1fbff56f9aee0b5f0114c026fb4e57d53f95 (diff) | |
exp: Fix metric recording of summary data
This change fixes an issue in the metric exporter for summary metrics,
where instead of some average value, the sum value was reported.
Diffstat (limited to 'simulator/opendc-experiments/opendc-experiments-capelin/src/main')
| -rw-r--r-- | simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ExperimentMetricExporter.kt | 16 |
1 files changed, 3 insertions, 13 deletions
diff --git a/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ExperimentMetricExporter.kt b/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ExperimentMetricExporter.kt index 39f18a1b..5f8002e2 100644 --- a/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ExperimentMetricExporter.kt +++ b/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ExperimentMetricExporter.kt @@ -103,19 +103,9 @@ public class ExperimentMetricExporter( val hostMetric = hostMetrics[uid] if (hostMetric != null) { - block(hostMetric, point.sum) - } - } - } - - private fun mapDoubleSum(data: MetricData?, hostMetrics: MutableMap<String, HostMetrics>, block: (HostMetrics, Double) -> Unit) { - val points = data?.doubleSumData?.points ?: emptyList() - for (point in points) { - val uid = point.labels["host"] - val hostMetric = hostMetrics[uid] - - if (hostMetric != null) { - block(hostMetric, point.value) + // Take the average of the summary + val avg = (point.percentileValues[0].value + point.percentileValues[1].value) / 2 + block(hostMetric, avg) } } } |
