Signed-off-by: Jan Tluka <jtluka(a)redhat.com>
---
.../RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
b/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
index 74fd0e77..e2e86ab2 100644
--- a/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
+++ b/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
@@ -17,6 +17,7 @@ class Flow(object):
parallel_streams,
generator_nic=None,
receiver_nic=None,
+ receiver_port=None,
msg_size=None,
cpupin=None):
self._type = type
@@ -27,6 +28,7 @@ class Flow(object):
self._receiver = receiver
self._receiver_bind = receiver_bind
self._receiver_nic = receiver_nic
+ self._receiver_port = receiver_port
self._msg_size = msg_size
self._duration = duration
@@ -61,6 +63,10 @@ class Flow(object):
def receiver_nic(self):
return self._receiver_nic
+ @property
+ def receiver_port(self):
+ return self._receiver_port
+
@property
def msg_size(self):
return self._msg_size
@@ -87,6 +93,7 @@ class Flow(object):
receiver={receiver},
receiver_bind={receiver_bind},
receiver_nic={receiver_nic},
+ receiver_port={receiver_port},
msg_size={msg_size},
duration={duration},
parallel_streams={parallel_streams},
@@ -99,6 +106,7 @@ class Flow(object):
receiver=str(self.receiver),
receiver_bind=self.receiver_bind,
receiver_nic=self.receiver_nic,
+ receiver_port=self.receiver_port,
msg_size=self.msg_size,
duration=self.duration,
parallel_streams=self.parallel_streams,
--
2.26.2