From bf378f2973e129527f2abde54094799303db0d07 Mon Sep 17 00:00:00 2001 From: Martin Klozik Date: Tue, 18 Aug 2015 15:33:14 +0100 Subject: Support of configurable background load and implementation of LTD.CPU.RFC2544.0PacketLoss and LTD.Memory.RFC2544.0PacketLoss Every testcase can be configured to run background load on the DUT. Load is generated by chosen command line tool, which must be installed according to the installation.md. Currently 'stress' and 'stress-ng' tools are supported, but support for new tool can be easily added. Load can be configured by testcase configuration option 'load'. Details about supported load generator options can be found in conf/01_testcases.conf. JIRA: VSPERF-23 JIRA: VSPERF-24 Change-Id: I3e1aebc0d41357f5a2764015c41ffc7e50fdbf8b Signed-off-by: Martin Klozik Reviewed-by: Billy O Mahony Reviewed-by: Maryam Tahhan Reviewed-by: Al Morton --- tools/load_gen/stress/__init__.py | 16 +++++ tools/load_gen/stress/stress.py | 124 ++++++++++++++++++++++++++++++++++++++ 2 files changed, 140 insertions(+) create mode 100644 tools/load_gen/stress/__init__.py create mode 100644 tools/load_gen/stress/stress.py (limited to 'tools/load_gen/stress') diff --git a/tools/load_gen/stress/__init__.py b/tools/load_gen/stress/__init__.py new file mode 100644 index 00000000..6b04c74d --- /dev/null +++ b/tools/load_gen/stress/__init__.py @@ -0,0 +1,16 @@ +# Copyright 2015 Intel Corporation. +# +# 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. + +"""Package with wrapper of stress tool +""" diff --git a/tools/load_gen/stress/stress.py b/tools/load_gen/stress/stress.py new file mode 100644 index 00000000..4a53f2d2 --- /dev/null +++ b/tools/load_gen/stress/stress.py @@ -0,0 +1,124 @@ +# Copyright 2015 Intel Corporation. +# +# 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. + +"""Module with implementation of wrapper around the stress tool +""" + +import logging +import subprocess +import copy +from tools import tasks +from tools import systeminfo +from tools.load_gen.load_gen import ILoadGenerator + +class Stress(ILoadGenerator): + """Wrapper around stress tool, which generates load based on testcase + configuration parameter 'load' + """ + _process_args = { + 'cmd': ['sudo', 'stress'], + 'timeout': 5, + 'logfile': '/tmp/stress.log', + 'expect': r'stress: info:', + 'name': 'stress' + } + _logger = logging.getLogger(__name__) + + def __init__(self, stress_config): + self._running = False + # copy stress process setings before its modification + process_args = copy.deepcopy(self._process_args) + # check if load is requested and correctly configured + if not (stress_config and 'load' in stress_config and + 'pattern' in stress_config and stress_config['load'] > 0): + self._logger.error('stress test is not enabled') + return + + if stress_config['load'] < 0 or stress_config['load'] > 100: + self._logger.error('defined load %s is out of range 0-100', + stress_config['load']) + return + + # check if load tool binary is available + if not ('tool' in stress_config) or subprocess.call("which " + stress_config['tool'], shell=True) > 0: + self._logger.error("stress tool binary '%s' is not available", stress_config['tool']) + return + + # calculate requested load details and load split among different + # types of workers + cpus = systeminfo.get_cpu_cores() + if 'reserved' in stress_config: + cpus = cpus - int(stress_config['reserved']) + if cpus < 1: + cpus = 1 + + workers = round(cpus/100 * int(stress_config['load'])) + cmd_dict = {} + p_types = {} + p_total = 0 + for p_type in ('c', 'i', 'm'): + p_count = stress_config['pattern'].lower().count(p_type) + if p_count > 0: + p_types[p_type] = p_count + p_total += p_count + if p_total < 1: + self._logger.error('stress test pattern does not contain any of ' \ + 'c, i or m pattern types') + return + for p_type in p_types: + cmd_dict['-'+p_type] = round(workers* p_types[p_type] / p_total) + + # check for memory load in case that memory workers are detected + # in case of error or 0%, memory size is not specified and default + # amount of memory will be used by stress tool + if '-m' in cmd_dict and cmd_dict['-m'] > 0: + if 'load_memory' in stress_config and \ + stress_config['load_memory'] > 0 and \ + stress_config['load_memory'] <= 100: + + mem = systeminfo.get_memory_bytes() + if mem: + cmd_dict['--vm-bytes'] = round(int(mem) / 100 * \ + stress_config['load_memory'] / cmd_dict['-m']) + + # append stress arguments to cmd list used by parent class Process + for key, value in cmd_dict.items(): + process_args['cmd'].append(key) + process_args['cmd'].append(str(value)) + + # append load generator options if specified + if 'options' in stress_config: + process_args['cmd'].append(stress_config['options']) + + # initialize load generator and remember it + super(Stress, self).__init__(**process_args) + self._running = True + + def start(self): + """Start stress load if it was requested + """ + if self._running: + super(Stress, self).start() + + def kill(self): + """ + Kill stress load if it is active + """ + if self._running and self._child and self._child.isalive(): + tasks.run_task(['sudo', 'pkill', self._proc_name], + self._logger) + + self._logger.info( + 'Log available at %s', self._logfile) + self._running = False -- cgit 1.2.3-korg