[PATCH] RecipeCommon.BaseFlowMeasurement.Flow: add aggregated_flow property

[Jan Tluka]

This property can be used to distinguish the aggregated flow from the
individual flows used to create the aggregated flow.

Signed-off-by: Jan Tluka 
---
 .../Perf/Measurements/BaseFlowMeasurement.py        | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py b/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
index 41d5c777..9cc91ab5 100644
--- a/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
+++ b/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
@@ -19,7 +19,8 @@ class Flow(object):
                  receiver_nic=None,
                  receiver_port=None,
                  msg_size=None,
-                 cpupin=None):
+                 cpupin=None,
+                 aggregated_flow=False):
         self._type = type

self._generator = generator
@@ -34,6 +35,7 @@ class Flow(object):
         self._duration = duration
         self._parallel_streams = parallel_streams
         self._cpupin = cpupin
+        self._aggregated_flow=aggregated_flow

@property
     def type(self):
@@ -83,6 +85,10 @@ class Flow(object):
     def cpupin(self):
         return self._cpupin

+    @property
+    def aggregated_flow(self):
+        return self._aggregated_flow
+
     def __repr__(self):
         string = """
         Flow(
@@ -98,6 +104,7 @@ class Flow(object):
             duration={duration},
             parallel_streams={parallel_streams},
             cpupin={cpupin},
+            aggregated_flow={aggregated_flow},
         )""".format(
             type=self.type,
             generator=str(self.generator),
@@ -111,6 +118,7 @@ class Flow(object):
             duration=self.duration,
             parallel_streams=self.parallel_streams,
             cpupin=self.cpupin,
+            aggregated_flow=self._aggregated_flow,
         )
         string = textwrap.dedent(string).strip()
         return string
@@ -340,7 +348,8 @@ class BaseFlowMeasurement(BaseMeasurement):
              msg_size=sample_flow.msg_size,
              duration=sample_flow.duration,
              parallel_streams=sample_flow.parallel_streams,
-             cpupin=None
+             cpupin=None,
+             aggregated_flow=True,
         )

aggregated_result = AggregatedFlowMeasurementResults(

[Ondrej Lichtner]

pushed, thanks.

-Ondrej

On Fri, Mar 05, 2021 at 02:04:14PM +0100, Jan Tluka wrote:
> This property can be used to distinguish the aggregated flow from the
> individual flows used to create the aggregated flow.
> Signed-off-by: Jan Tluka
>
> .../Perf/Measurements/BaseFlowMeasurement.py        | 13 +++++++++++--
>  1 file changed, 11 insertions(+), 2 deletions(-)
>
> diff --git a/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py b/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
> index 41d5c777..9cc91ab5 100644
> --- a/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
> +++ b/lnst/RecipeCommon/Perf/Measurements/BaseFlowMeasurement.py
> @@ -19,7 +19,8 @@ class Flow(object):
>                   receiver_nic=None,
>                   receiver_port=None,
>                   msg_size=None,
>             cpupin=None):
>             cpupin=None,
>             aggregated_flow=False):
>    self._type = type
>
>    self._generator = generator
>
> @@ -34,6 +35,7 @@ class Flow(object):
>          self._duration = duration
>          self._parallel_streams = parallel_streams
>          self._cpupin = cpupin
>    self._aggregated_flow=aggregated_flow
>
> @property
>    def type(self):
>
> @@ -83,6 +85,10 @@ class Flow(object):
>      def cpupin(self):
>          return self._cpupin
> @property
> def aggregated_flow(self):
>    return self._aggregated_flow
> def __repr__(self):
>        string = """
>        Flow(
>
> @@ -98,6 +104,7 @@ class Flow(object):
>              duration={duration},
>              parallel_streams={parallel_streams},
>              cpupin={cpupin},
>        aggregated_flow={aggregated_flow},
>    )""".format(
>        type=self.type,
>        generator=str(self.generator),
>
> @@ -111,6 +118,7 @@ class Flow(object):
>              duration=self.duration,
>              parallel_streams=self.parallel_streams,
>              cpupin=self.cpupin,
>        aggregated_flow=self._aggregated_flow,
>    )
>    string = textwrap.dedent(string).strip()
>    return string
>
> @@ -340,7 +348,8 @@ class BaseFlowMeasurement(BaseMeasurement):
>               msg_size=sample_flow.msg_size,
>               duration=sample_flow.duration,
>               parallel_streams=sample_flow.parallel_streams,
>         cpupin=None
>         cpupin=None,
>         aggregated_flow=True,
>    )
>
>    aggregated_result = AggregatedFlowMeasurementResults(
>
> -- 
> 2.26.2
> _______________________________________________
> LNST-developers mailing list -- [e-mail]
> To unsubscribe send an email to [e-mail]
> Fedora Code of Conduct: https://docs.fedoraproject.org/en-US/project/code-of-conduct/
> List Guidelines: https://fedoraproject.org/wiki/Mailing_list_guidelines
> List Archives: https://lists.fedorahosted.org/archives/list/[e-mail]...
> Do not reply to spam on the list, report it: https://pagure.io/fedora-infrastructure