From: Perry Gagne pgagne@redhat.com
We might want to know what version of neper was used when looking at result data. Neper reports its version in one of its outputted lines (VERSION=...). So we should save that as part of the FlowMeasurement
Signed-off-by: Perry Gagne pgagne@redhat.com --- .../Perf/Measurements/NeperFlowMeasurement.py | 10 ++++++++++ 1 file changed, 10 insertions(+)
diff --git a/lnst/RecipeCommon/Perf/Measurements/NeperFlowMeasurement.py b/lnst/RecipeCommon/Perf/Measurements/NeperFlowMeasurement.py index 6976547d..236c2c9b 100644 --- a/lnst/RecipeCommon/Perf/Measurements/NeperFlowMeasurement.py +++ b/lnst/RecipeCommon/Perf/Measurements/NeperFlowMeasurement.py @@ -20,11 +20,17 @@ class NeperFlowMeasurement(BaseFlowMeasurement): self._flows = flows self._running_measurements = [] self._finished_measurements = [] + self._host_versions = {}
@property def flows(self) -> List[Flow]: return self._flows
+ @property + def version(self): + return {"measurement_version": self._MEASUREMENT_VERSION, + "hosts_neper_versions": self._host_versions} + def start(self): if len(self._running_measurements) > 0: raise MeasurementError("Measurement already running!") @@ -127,10 +133,14 @@ class NeperFlowMeasurement(BaseFlowMeasurement): generator_stats = self._parse_job_samples(test_flow.client_job) flow_results.generator_results = generator_stats[0] flow_results.generator_cpu_stats = generator_stats[1] + self._host_versions[test_flow.flow.generator] = \ + test_flow.client_job.result["data"]["VERSION"]
receiver_stats = self._parse_job_samples(test_flow.server_job) flow_results.receiver_results = receiver_stats[0] flow_results.receiver_cpu_stats = receiver_stats[1] + self._host_versions[test_flow.flow.receiver] = \ + test_flow.server_job.result["data"]["VERSION"]
results.append(flow_results)