Add vpp loadbalancer maglev mode test suite

Change-Id: I61555ba566efef0a2151db9a30bf7f5d9ccad1df
Signed-off-by: haiyanx1.zhang <haiyanx1.zhang@intel.com>

3 files changed, 241 insertions, 0 deletions

diff --git a/resources/libraries/python/LoadBalancerUtil.py b/resources/libraries/python/LoadBalancerUtil.py
new file mode 100644
index 0000000000..26bf965c39
--- /dev/null
+++ b/resources/libraries/python/LoadBalancerUtil.py
@@ -0,0 +1,176 @@
+# Copyright (c) 2019 Intel and/or its affiliates.
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at:
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+"""Loadbalancer util library."""
+
+from socket import htonl
+from ipaddress import ip_address
+from resources.libraries.python.topology import NodeType
+from resources.libraries.python.PapiExecutor import PapiSocketExecutor
+
+class LoadBalancerUtil(object):
+    """Basic Loadbalancer parameter configuration."""
+
+    @staticmethod
+    def vpp_lb_conf(node, **kwargs):
+        """Config global parameters for loadbalancer.
+
+        :param node: Node where the interface is.
+        :param kwargs: Optional key-value arguments:
+
+            ip4_src_addr: IPv4 address to be used as source for IPv4 traffic.
+                          (str)
+            ip6_src_addr: IPv6 address to be used as source for IPv6 traffic.
+                          (str)
+            flow_timeout: Time in seconds after which, if no packet is received
+                          for a given flow, the flow is removed from the
+                          established flow table. (int)
+            buckets_per_core: Number of buckets *per worker thread* in the
+                              established flow table (int)
+
+        :type node: dict
+        :type kwargs: dict
+        :returns: Nothing.
+        :raises ValueError: If the node has an unknown node type.
+        """
+        if node['type'] == NodeType.DUT:
+            ip4_src_addr = ip_address(unicode(kwargs.pop('ip4_src_addr',
+                                                         '255.255.255.255')))
+            ip6_src_addr = ip_address(unicode(kwargs.pop('ip6_src_addr',\
+                    'ffff:ffff:ffff:ffff:ffff:ffff:ffff:ffff')))
+            flow_timeout = kwargs.pop('flow_timeout', 40)
+            sticky_buckets_per_core = kwargs.pop('buckets_per_core', 1024)
+
+            cmd = 'lb_conf'
+            err_msg = 'Failed to set lb conf on host {host}'.format(
+                host=node['host'])
+
+            args = dict(ip4_src_address=str(ip4_src_addr),
+                        ip6_src_address=str(ip6_src_addr),
+                        sticky_buckets_per_core=sticky_buckets_per_core,
+                        flow_timeout=flow_timeout)
+
+            with PapiSocketExecutor(node) as papi_exec:
+                papi_exec.add(cmd, **args).get_reply(err_msg)
+        else:
+            raise ValueError('Node {host} has unknown NodeType: "{type}"'
+                             .format(host=node['host'], type=node['type']))
+
+    @staticmethod
+    def vpp_lb_add_del_vip(node, **kwargs):
+        """Config vip for loadbalancer.
+
+        :param node: Node where the interface is.
+        :param kwargs: Optional key-value arguments:
+
+            vip_addr: IPv4 address to be used as source for IPv4 traffic. (str)
+            protocol: tcp or udp. (int)
+            port: destination port. (int)
+            encap: encap is ip4 GRE(0) or ip6 (1GRE) or L3DSR(2) or NAT4(3) or
+                   NAT6(4). (int)
+            dscp: dscp bit corresponding to VIP
+            type: service type
+            target_port: Pod's port corresponding to specific service
+            node_port: Node's port
+            new_len: Size of the new connections flow table used
+                     for this VIP
+            is_del: 1 if the VIP should be removed otherwise 0.
+
+        :type node: dict
+        :type kwargs: dict
+        :returns: Nothing.
+        :raises ValueError: If the node has an unknown node type.
+        """
+        if node['type'] == NodeType.DUT:
+            vip_addr = kwargs.pop('vip_addr', '0.0.0.0')
+            protocol = kwargs.pop('protocol', 255)
+            port = kwargs.pop('port', 0)
+            encap = kwargs.pop('encap', 0)
+            dscp = kwargs.pop('dscp', 0)
+            srv_type = kwargs.pop('srv_type', 0)
+            target_port = kwargs.pop('target_port', 0)
+            node_port = kwargs.pop('node_port', 0)
+            new_len = kwargs.pop('new_len', 1024)
+            is_del = kwargs.pop('is_del', 0)
+
+            cmd = 'lb_add_del_vip'
+            err_msg = 'Failed to add vip on host {host}'.format(
+                host=node['host'])
+
+            vip_addr = ip_address(unicode(vip_addr)).packed
+            args = dict(pfx={'len': 128,
+                             'address': {'un': {'ip4': vip_addr}, 'af': 0}},
+                        protocol=protocol,
+                        port=port,
+                        encap=htonl(encap),
+                        dscp=dscp,
+                        type=srv_type,
+                        target_port=target_port,
+                        node_port=node_port,
+                        new_flows_table_length=int(new_len),
+                        is_del=is_del)
+
+            with PapiSocketExecutor(node) as papi_exec:
+                papi_exec.add(cmd, **args).get_reply(err_msg)
+        else:
+            raise ValueError('Node {host} has unknown NodeType: "{type}"'
+                             .format(host=node['host'], type=node['type']))
+
+    @staticmethod
+    def vpp_lb_add_del_as(node, **kwargs):
+        """Config AS for Loadbalancer.
+
+        :param node: Node where the interface is.
+        :param kwargs: Optional key-value arguments:
+
+            vip_addr: IPv4 address to be used as source for IPv4 traffic. (str)
+            protocol: tcp or udp. (int)
+            port: destination port. (int)
+            as_addr: The application server address. (str)
+            is_del: 1 if the VIP should be removed otherwise 0. (int)
+            is_flush: 1 if the sessions related to this AS should be flushed
+                      otherwise 0. (int)
+
+        :type node: dict
+        :type kwargs: dict
+        :returns: Nothing.
+        :raises ValueError: If the node has an unknown node type.
+        """
+        if node['type'] == NodeType.DUT:
+            cmd = 'lb_add_del_as'
+            err_msg = 'Failed to add lb as on host {host}'.format(
+                host=node['host'])
+
+            vip_addr = kwargs.pop('vip_addr', '0.0.0.0')
+            protocol = kwargs.pop('protocol', 255)
+            port = kwargs.pop('port', 0)
+            as_addr = kwargs.pop('as_addr', '0.0.0.0')
+            is_del = kwargs.pop('is_del', 0)
+            is_flush = kwargs.pop('is_flush', 0)
+
+            vip_addr = ip_address(unicode(vip_addr)).packed
+            as_addr = ip_address(unicode(as_addr)).packed
+
+            args = dict(pfx={'len': 128,
+                             'address': {'un': {'ip4': vip_addr}, 'af': 0}},
+                        protocol=protocol,
+                        port=port,
+                        as_address={'un': {'ip4': as_addr}, 'af': 0},
+                        is_del=is_del,
+                        is_flush=is_flush)
+
+            with PapiSocketExecutor(node) as papi_exec:
+                papi_exec.add(cmd, **args).get_reply(err_msg)
+        else:
+            raise ValueError('Node {host} has unknown NodeType: "{type}"'
+                             .format(host=node['host'], type=node['type']))
diff --git a/resources/libraries/robot/lb/load_balancer.robot b/resources/libraries/robot/lb/load_balancer.robot
new file mode 100644
index 0000000000..4dc66447d2
--- /dev/null
+++ b/resources/libraries/robot/lb/load_balancer.robot
@@ -0,0 +1,64 @@
+# Copyright (c) 2019 Intel and/or its affiliates.
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at:
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+*** Settings ***
+| Library | Collections
+| Library | String
+
+| Library | resources.libraries.python.InterfaceUtil
+| Library | resources.libraries.python.IPUtil
+| Library | resources.libraries.python.topology.Topology
+| Library | resources.libraries.python.LoadBalancerUtil
+| Library | resources.libraries.python.NodePath
+| ...
+| Resource | resources/libraries/robot/shared/interfaces.robot
+| ...
+| Documentation | LoadBalancer suite keywords - configuration
+
+*** Keywords ***
+| Initialize loadbalancer maglev
+| | [Documentation]
+| | ... | Set UP state on VPP interfaces in path on nodes in 2-node
+| | ... | circular topology. Get the interface MAC addresses and setup ARP on
+| | ... | all VPP interfaces. Setup IPv4 addresses with /24 prefix on DUT-TG
+| | ... | links.
+| | ...
+| | Set interfaces in path up
+| | ...
+| | ${fib_table}= | Set Variable | ${0}
+| | Add Fib Table | ${dut1} | ${fib_table}
+| | Assign Interface To Fib Table | ${dut1} | ${dut1_if1} | ${fib_table}
+| | Assign Interface To Fib Table | ${dut1} | ${dut1_if2} | ${fib_table}
+| | ...
+| | VPP Interface Set IP Address | ${dut1} | ${dut1_if1}
+| | ... | 192.168.50.72 | 24
+| | VPP Interface Set IP Address | ${dut1} | ${dut1_if2}
+| | ... | 192.168.60.73 | 24
+| | ...
+| | VPP Add IP Neighbor | ${dut1} | ${dut1_if2} | 192.168.60.74 | ${tg_if2_mac}
+| | VPP Add IP Neighbor | ${dut1} | ${dut1_if2} | 192.168.60.75 | ${tg_if2_mac}
+| | VPP Add IP Neighbor | ${dut1} | ${dut1_if2} | 192.168.60.76 | ${tg_if2_mac}
+| | VPP Add IP Neighbor | ${dut1} | ${dut1_if2} | 192.168.60.77 | ${tg_if2_mac}
+| | VPP Add IP Neighbor | ${dut1} | ${dut1_if2} | 192.168.60.78 | ${tg_if2_mac}
+| | VPP Add IP Neighbor | ${dut1} | ${dut1_if2} | 192.168.60.79 | ${tg_if2_mac}
+| | ...
+| | Vpp Route Add | ${dut1} | 192.168.60.0 | 24 | interface=${dut1_if2}
+| | ...
+| | Vpp Lb Conf | ${dut1} | ip4_src_addr=192.168.60.73 | buckets_per_core=${128}
+| | Vpp Lb Add Del Vip | ${dut1} | vip_addr=90.1.2.1 | encap=${0} | new_len=${1024}
+| | Vpp Lb Add Del As | ${dut1} | vip_addr=90.1.2.1 | as_addr=192.168.60.74
+| | Vpp Lb Add Del As | ${dut1} | vip_addr=90.1.2.1 | as_addr=192.168.60.75
+| | Vpp Lb Add Del As | ${dut1} | vip_addr=90.1.2.1 | as_addr=192.168.60.76
+| | Vpp Lb Add Del As | ${dut1} | vip_addr=90.1.2.1 | as_addr=192.168.60.77
+| | Vpp Lb Add Del As | ${dut1} | vip_addr=90.1.2.1 | as_addr=192.168.60.78
+| | Vpp Lb Add Del As | ${dut1} | vip_addr=90.1.2.1 | as_addr=192.168.60.79
diff --git a/resources/libraries/robot/shared/default.robot b/resources/libraries/robot/shared/default.robot
index c560dcf8c2..36460d1ab9 100644
--- a/resources/libraries/robot/shared/default.robot
+++ b/resources/libraries/robot/shared/default.robot
@@ -41,6 +41,7 @@
 | Library | resources.libraries.python.VppCounters
 | Library | resources.libraries.python.VPPUtil
 | ...
+| Resource | resources/libraries/robot/lb/load_balancer.robot
 | Resource | resources/libraries/robot/crypto/ipsec.robot
 | Resource | resources/libraries/robot/features/acl.robot
 | Resource | resources/libraries/robot/features/gbp.robot