[PATCH-next 23/25] lnst.Recipes.ENRT: add SimplePerfRecipe

From: Ondrej Lichtner <olichtne(a)redhat.com&gt;

Adding the first ported recipe SimplePerfRecipe, based on the old
simple_netperf.xml recipe. The test defines a simple one to one host
topology and implements the test_wide_configuration method corresponding
to this topology.

Signed-off-by: Ondrej Lichtner <olichtne(a)redhat.com&gt;
---
 lnst/Recipes/ENRT/SimplePerfRecipe.py | 75 +++++++++++++++++++++++++++
 1 file changed, 75 insertions(+)
 create mode 100644 lnst/Recipes/ENRT/SimplePerfRecipe.py

diff --git a/lnst/Recipes/ENRT/SimplePerfRecipe.py
b/lnst/Recipes/ENRT/SimplePerfRecipe.py
new file mode 100644
index 0000000..7c0a401
--- /dev/null
+++ b/lnst/Recipes/ENRT/SimplePerfRecipe.py
@@ -0,0 +1,75 @@
+
+from lnst.Common.LnstError import LnstError
+from lnst.Common.Parameters import IntParam, Param, StrParam, BoolParam
+from lnst.Common.IpAddress import ipaddress, AF_INET, AF_INET6
+
+from lnst.Controller import HostReq, DeviceReq
+
+from lnst.Recipes.ENRT.BaseEnrtRecipe import BaseEnrtRecipe, EnrtConfiguration
+
+class SimplePerfRecipe(BaseEnrtRecipe):
+    m1 = HostReq()
+    m1.eth0 = DeviceReq(label="net1")
+
+    m2 = HostReq()
+    m2.eth0 = DeviceReq(label="net1")
+
+    offload_combinations = Param(default=(
+        dict(gro="on", gso="on", tso="on",
tx="on", rx="on"),
+        dict(gro="off", gso="on", tso="on",
tx="on", rx="on"),
+        dict(gro="on", gso="off", tso="off",
tx="on", rx="on"),
+        dict(gro="on", gso="on", tso="off",
tx="off", rx="on"),
+        dict(gro="on", gso="on", tso="on",
tx="on", rx="off")))
+
+    def test_wide_configuration(self):
+        m1, m2 = self.matched.m1, self.matched.m2
+
+        configuration = EnrtConfiguration()
+        configuration.endpoint1 = m1.eth0
+        configuration.endpoint2 = m2.eth0
+
+        if "mtu" in self.params:
+            m1.eth0.mtu = self.params.mtu
+            m2.eth0.mtu = self.params.mtu
+
+        #TODO redo
+        # configuration.saved_coalescing_state = dict(
+                # m1_if = dict(tx = m1.eth0.adaptive_tx_coalescing,
+                             # rx = m1.eth0.adaptive_rx_coalescing),
+                # m2_if = dict(tx = m2.eth0.adaptive_tx_coalescing,
+                             # rx = m2.eth0.adaptive_rx_coalescing))
+
+        # m1.eth0.adaptive_tx_coalescing = self.params.adaptive_coalescing
+        # m1.eth0.adaptive_rx_coalescing = self.params.adaptive_coalescing
+        # m2.eth0.adaptive_tx_coalescing = self.params.adaptive_coalescing
+        # m2.eth0.adaptive_rx_coalescing = self.params.adaptive_coalescing
+
+        m1.eth0.ip_add(ipaddress("192.168.101.1/24"))
+        m1.eth0.ip_add(ipaddress("fc00::1/64"))
+        m1.eth0.up()
+
+        m2.eth0.ip_add(ipaddress("192.168.101.2/24"))
+        m2.eth0.ip_add(ipaddress("fc00::2/64"))
+        m2.eth0.up()
+
+        #TODO better service handling through HostAPI
+        m1.run("service irqbalance stop")
+        m2.run("service irqbalance stop")
+        for m in self.matched:
+            for dev in m.devices:
+                self._pin_dev_interrupts(dev, self.params.dev_intr_cpu)
+
+        return configuration
+
+    def test_wide_deconfiguration(self, config):
+        m1, m2 = self.matched.m1, self.matched.m2
+
+        #TODO better service handling through HostAPI
+        m1.run("service irqbalance start")
+        m2.run("service irqbalance start")
+
+        # redo
+        # m1.eth0.adaptive_tx_coalescing =
self.saved_coalescing_state["m1_if"]["tx"]
+        # m1.eth0.adaptive_rx_coalescing =
self.saved_coalescing_state["m1_if"]["rx"]
+        # m2.eth0.adaptive_tx_coalescing =
self.saved_coalescing_state["m2_if"]["tx"]
+        # m2.eth0.adaptive_rx_coalescing =
self.saved_coalescing_state["m2_if"]["rx"]
-- 
2.17.0