This extends the IperfMeasurementGenerator with perf_parallel_processes parameter.
This is to allow user to run multiple processes of iperf server/client as an
alternative to running multiple streams within one iperf client/server process
specified by perf_parallel_streams.
This also updates the Flow object with this configuration.
Signed-off-by: Jan Tluka <jtluka(a)redhat.com>
---
lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py | 7 ++++++-
.../MeasurementGenerators/IperfMeasurementGenerator.py | 2 ++
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
b/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
index 2d1f911e..6973ae73 100644
--- a/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
+++ b/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
@@ -11,7 +11,7 @@ class Flow(object):
type,
generator, generator_bind, generator_nic,
receiver, receiver_bind, receiver_nic,
- msg_size, duration, parallel_streams, cpupin):
+ msg_size, duration, parallel_streams, parallel_processes, cpupin):
self._type = type
self._generator = generator
@@ -24,6 +24,7 @@ class Flow(object):
self._msg_size = msg_size
self._duration = duration
self._parallel_streams = parallel_streams
+ self._parallel_processes = parallel_processes
self._cpupin = cpupin
@property
@@ -66,6 +67,10 @@ class Flow(object):
def parallel_streams(self):
return self._parallel_streams
+ @property
+ def parallel_processes(self):
+ return self._parallel_processes
+
@property
def cpupin(self):
return self._cpupin
diff --git a/lnst/Recipes/ENRT/MeasurementGenerators/IperfMeasurementGenerator.py
b/lnst/Recipes/ENRT/MeasurementGenerators/IperfMeasurementGenerator.py
index 4ccf9227..9d757ca5 100644
--- a/lnst/Recipes/ENRT/MeasurementGenerators/IperfMeasurementGenerator.py
+++ b/lnst/Recipes/ENRT/MeasurementGenerators/IperfMeasurementGenerator.py
@@ -56,6 +56,7 @@ class IperfMeasurementGenerator(BaseMeasurementGenerator):
perf_duration = IntParam(default=60)
perf_iterations = IntParam(default=5)
perf_parallel_streams = IntParam(default=1)
+ perf_parallel_processes = IntParam(default=1)
perf_msg_sizes = ListParam(default=[123])
net_perf_tool = Param(default=IperfFlowMeasurement)
@@ -138,6 +139,7 @@ class IperfMeasurementGenerator(BaseMeasurementGenerator):
msg_size=msg_size,
duration=self.params.perf_duration,
parallel_streams=self.params.perf_parallel_streams,
+ parallel_processes=self.params.perf_parallel_processes,
cpupin=(
self.params.perf_tool_cpu
if "perf_tool_cpu" in self.params
--
2.26.2