VPP IPv6 routed forwarding.
+.. topic:: LOADBALANCER
+
+ VPP Load balancer.
+
Underlay Tags
-------------
policer_classify_set_interface: '0xe09537b0' # dev
policer_classify_set_interface_reply: '0xe8d4e804' # dev
# 4x^ tc01-64B-ethip4-ip4base-ipolicemarkbase-dev
+ # ^^ tc01-64B-1c-ethip4-loadbalancer-maglev/l3dsr/nat4-mrr
+ lb_conf: '0x22ddb739' # perf
+ lb_conf_reply: '0xe8d4e804' # perf
+ lb_add_del_vip: '0xd15b7ddc' # perf
+ lb_add_del_vip_reply: '0xe8d4e804' # perf
+ lb_add_del_as: '0x78628987' # perf
+ lb_add_del_as_reply: '0xe8d4e804' # perf
+ lb_add_del_intf_nat4: '0x47d6e753' # perf
+ lb_add_del_intf_nat4_reply: '0xe8d4e804' # perf
# https://gerrit.fd.io/r/c/vpp/+/21490
policer_classify_set_interface: '0xe09537b0' # dev
policer_classify_set_interface_reply: '0xe8d4e804' # dev
# 4x^ tc01-64B-ethip4-ip4base-ipolicemarkbase-dev
+ # ^^ tc01-64B-1c-ethip4-loadbalancer-maglev/l3dsr/nat4-mrr
+ lb_conf: '0x22ddb739' # perf
+ lb_conf_reply: '0xe8d4e804' # perf
+ lb_add_del_vip: '0xd15b7ddc' # perf
+ lb_add_del_vip_reply: '0xe8d4e804' # perf
+ lb_add_del_as: '0x78628987' # perf
+ lb_add_del_as_reply: '0xe8d4e804' # perf
+ lb_add_del_intf_nat4: '0x47d6e753' # perf
+ lb_add_del_intf_nat4_reply: '0xe8d4e804' # perf
# Hint to see the currently used command messages:
--- /dev/null
+# 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']))
--- /dev/null
+# 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
| 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
--- /dev/null
+# 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.
+
+"""Stream profile for T-rex traffic generator.
+
+Stream profile:
+ - Packet: ETH / IP / UDP
+ - Direction 0 --> 1:
+ - Source IP address range: 192.168.50.74 - 192.168.50.79
+ - Destination IP address range: 90.1.2.1
+ - Direction 1 --> 0:
+ - Source IP address range: 192.168.60.74 - 192.168.60.79
+ - Destination IP address range: 192.168.50.74 - 192.168.50.79
+"""
+
+from trex.stl.api import *
+from profile_trex_stateless_base_class import TrafficStreamsBaseClass
+
+
+class TrafficStreams(TrafficStreamsBaseClass):
+ """Stream profile."""
+
+ def __init__(self):
+ """Initialization and setting of streams' parameters."""
+
+ super(TrafficStreamsBaseClass, self).__init__()
+
+ # IPs used in packet headers.
+ self.p1_src_start_ip = '192.168.50.74'
+ self.p1_src_end_ip = '192.168.50.79'
+ self.p1_dst_start_ip = '90.1.2.1'
+
+ self.p2_src_start_ip = '192.168.60.74'
+ self.p2_src_end_ip = '192.168.60.79'
+ self.p2_dst_start_ip = '192.168.50.74'
+ self.p2_dst_end_ip = '192.168.50.79'
+
+ # UDP ports used in packet headers.
+ self.p1_src_udp_port = 63
+ self.p1_dst_udp_port = 20000
+
+ self.p2_src_udp_port = 3307
+ self.p2_dst_udp_port = 63
+
+ def define_packets(self):
+ """Defines the packets to be sent from the traffic generator.
+
+ Packet definition: | ETH | IP | UDP
+
+ :returns: Packets to be sent from the traffic generator.
+ :rtype: tuple
+ """
+
+ # Direction 0 --> 1
+ base_pkt_a = Ether() / IP(src=self.p1_src_start_ip,
+ dst=self.p1_dst_start_ip,
+ proto=17) / UDP(sport=self.p1_src_udp_port,
+ dport=self.p1_dst_udp_port)
+ # Direction 1 --> 0
+ base_pkt_b = Ether() / IP(src=self.p2_src_start_ip,
+ dst=self.p2_dst_start_ip,
+ proto=17) / UDP(sport=self.p2_src_udp_port,
+ dport=self.p2_dst_udp_port)
+
+ # Direction 0 --> 1
+ vm1 = STLScVmRaw([STLVmFlowVar(name="src",
+ min_value=self.p1_src_start_ip,
+ max_value=self.p1_src_end_ip,
+ size=4, op="inc"),
+ STLVmWrFlowVar(fv_name="src", pkt_offset="IP.src"),
+ STLVmFixIpv4(offset="IP")])
+ # Direction 1 --> 0
+ vm2 = STLScVmRaw([STLVmFlowVar(name="src",
+ min_value=self.p2_src_start_ip,
+ max_value=self.p2_src_end_ip,
+ size=4, op="inc"),
+ STLVmWrFlowVar(fv_name="src", pkt_offset="IP.src"),
+ STLVmFlowVar(name="dst",
+ min_value=self.p2_dst_start_ip,
+ max_value=self.p2_dst_end_ip,
+ size=4, op="inc"),
+ STLVmWrFlowVar(fv_name="dst", pkt_offset="IP.dst"),
+ STLVmFixIpv4(offset="IP")])
+
+ return base_pkt_a, base_pkt_b, vm1, vm2
+
+
+def register():
+ """Register this traffic profile to T-rex.
+
+ Do not change this function.
+
+ :return: Traffic streams.
+ :rtype: Object
+ """
+ return TrafficStreams()
--- /dev/null
+# 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 ***
+| Resource | resources/libraries/robot/shared/default.robot
+| ...
+| Force Tags | 2_NODE_SINGLE_LINK_TOPO | PERFTEST | HW_ENV | NDRPDR
+| ... | NIC_Intel-X710 | ETH | IP4 | LOADBALANCER
+| ...
+| Suite Setup | Setup suite single link | performance
+| Suite Teardown | Tear down suite | performance
+| Test Setup | Setup test
+| Test Teardown | Tear down test | performance
+| ...
+| Test Template | Local Template
+| ...
+| Documentation | *RFC2544: Pkt throughput loadbalancer maglev test cases*
+| ...
+| ... | *[Top] Network Topologies:* TG-DUT1-TG 2-node circular topology\
+| ... | with single links between nodes.
+| ... | *[Enc] Packet Encapsulations:* Eth-IPv4-UDP for LoadBalancer maglev.
+| ... | *[Cfg] DUT configuration:* DUT1 is configured with LoadBalancer\
+| ... | maglev and one static IPv4 /24 route entries. DUT1 tested with\
+| ... | ${nic_name}.
+| ... | *[Ver] TG verification:* TG finds and reports throughput NDR (Non Drop\
+| ... | Rate) with zero packet loss tolerance and throughput PDR (Partial Drop\
+| ... | Rate) with non-zero packet loss tolerance (LT) expressed in percentage\
+| ... | of packets transmitted. NDR and PDR are discovered for different\
+| ... | Ethernet L2 frame sizes using MLRsearch library.\
+| ... | Test packets are generated by TG on links to DUT. TG traffic profile\
+| ... | contains two L4 flow-groups (maglev use flow-group is only from TG\
+| ... | to DUT, 6 flows for flow-group) with all packets containing Ethernet\
+| ... | header, IPv4 header with IP protocol=17 and static payload. MAC\
+| ... | addresses are matching MAC addresses of the TG node interfaces.
+| ... | *[Ref] Applicable standard specifications:* RFC2544.
+
+*** Variables ***
+| @{plugins_to_enable}= | dpdk_plugin.so | lb_plugin.so
+| ${osi_layer}= | L3
+| ${nic_name}= | Intel-X710
+| ${overhead}= | ${0}
+# Traffic profile:
+| ${traffic_profile}= | trex-sl-2n-ethip4udp-lb
+
+*** Keywords ***
+| Local Template
+| | [Documentation]
+| | ... | [Cfg] DUT runs LoadBalancer maglev config.\
+| | ... | Each DUT uses ${phy_cores} physical core(s) for worker threads.
+| | ... | [Ver] Measure NDR and PDR values using MLRsearch algorithm.\
+| | ...
+| | ... | *Arguments:*
+| | ... | - frame_size - Framesize in Bytes in integer or string (IMIX_v4_1).
+| | ... | Type: integer, string
+| | ... | - phy_cores - Number of physical cores. Type: integer
+| | ... | - rxq - Number of RX queues, default value: ${None}. Type: integer
+| | ...
+| | [Arguments] | ${frame_size} | ${phy_cores} | ${rxq}=${None}
+| | ...
+| | Set Test Variable | \${frame_size}
+| | ...
+| | Given Add worker threads and rxqueues to all DUTs | ${phy_cores} | ${rxq}
+| | And Add PCI devices to all DUTs
+| | And Set Max Rate And Jumbo And Handle Multi Seg
+| | And Apply startup configuration on all VPP DUTs
+| | When Initialize loadbalancer maglev
+| | Then Find NDR and PDR intervals using optimized search
+| | ... | traffic_directions=${1}
+
+*** Test Cases ***
+| tc01-64B-1c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 64B | 1C
+| | frame_size=${64} | phy_cores=${1}
+
+| tc02-64B-2c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 64B | 2C
+| | frame_size=${64} | phy_cores=${2}
+
+| tc03-64B-4c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 64B | 4C
+| | frame_size=${64} | phy_cores=${4}
+
+| tc04-1518B-1c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 1518B | 1C
+| | frame_size=${1518} | phy_cores=${1}
+
+| tc05-1518B-2c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 1518B | 2C
+| | frame_size=${1518} | phy_cores=${2}
+
+| tc06-1518B-4c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 1518B | 4C
+| | frame_size=${1518} | phy_cores=${4}
+
+| tc07-9000B-1c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 9000B | 1C
+| | frame_size=${9000} | phy_cores=${1}
+
+| tc08-9000B-2c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 9000B | 2C
+| | frame_size=${9000} | phy_cores=${2}
+
+| tc09-9000B-4c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | 9000B | 4C
+| | frame_size=${9000} | phy_cores=${4}
+
+| tc10-IMIX-1c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | IMIX | 1C
+| | frame_size=IMIX_v4_1 | phy_cores=${1}
+
+| tc11-IMIX-2c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | IMIX | 2C
+| | frame_size=IMIX_v4_1 | phy_cores=${2}
+
+| tc12-IMIX-4c-ethip4-loadbalancer-maglev-ndrpdr
+| | [Tags] | IMIX | 4C
+| | frame_size=IMIX_v4_1 | phy_cores=${4}
--- /dev/null
+#!/usr/bin/env python
+
+# Copyright (c) 2019 Inter 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.
+
+from resources.libraries.python.autogen.Regenerator import Regenerator
+
+Regenerator().regenerate_glob("*.robot")
Code Review / csit.git / commitdiff