--- /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']))
Code Review / csit.git / blobdiff