summaryrefslogtreecommitdiffstats
path: root/tests/unit/benchmark/scenarios/compute/test_cpuload.py
diff options
context:
space:
mode:
authorJo¶rgen Karlsson <jorgen.w.karlsson@ericsson.com>2015-11-20 17:42:59 +0100
committerJörgen Karlsson <jorgen.w.karlsson@ericsson.com>2015-12-08 00:32:37 +0000
commitc9f8bbe529efe6843437d1810e51e8767f18535c (patch)
treec9dbaaf3bffcc116894af9e1d67c4a1dfed042f6 /tests/unit/benchmark/scenarios/compute/test_cpuload.py
parent0b63746b81091a6875deca452bab7d7961638ea5 (diff)
Add scenario for reading processor load
This scenario reads processor and system load statistics and does not run any benchmark tests. The scenario is intended to be run in parallell with other scenarios in order to collect processor and system load statistics. System load is read from /proc/loadavg. Processor usage stats is read using the 'mpstat' utility if it has been installed on the host. If 'mpstat' is not installed on the host processor usage stats is read from /proc/stats. Change-Id: I7156e0c941100023571db750de7540786a4fedb8 JIRA: YARDSTICK-181 Signed-off-by: Jo¶rgen Karlsson <jorgen.w.karlsson@ericsson.com>
Diffstat (limited to 'tests/unit/benchmark/scenarios/compute/test_cpuload.py')
-rw-r--r--tests/unit/benchmark/scenarios/compute/test_cpuload.py238
1 files changed, 238 insertions, 0 deletions
diff --git a/tests/unit/benchmark/scenarios/compute/test_cpuload.py b/tests/unit/benchmark/scenarios/compute/test_cpuload.py
new file mode 100644
index 000000000..22c4419b2
--- /dev/null
+++ b/tests/unit/benchmark/scenarios/compute/test_cpuload.py
@@ -0,0 +1,238 @@
+#!/usr/bin/env python
+
+##############################################################################
+# Copyright (c) 2015 Ericsson AB and others.
+#
+# All rights reserved. This program and the accompanying materials
+# are made available under the terms of the Apache License, Version 2.0
+# which accompanies this distribution, and is available at
+# http://www.apache.org/licenses/LICENSE-2.0
+##############################################################################
+
+# Unittest for yardstick.benchmark.scenarios.compute.lmbench.Lmbench
+
+import mock
+import unittest
+import os
+
+from yardstick.benchmark.scenarios.compute import cpuload
+
+
+@mock.patch('yardstick.benchmark.scenarios.compute.cpuload.ssh')
+class CPULoadTestCase(unittest.TestCase):
+
+ def setUp(self):
+ self.ctx = {
+ 'host': {
+ 'ip': '172.16.0.137',
+ 'user': 'cirros',
+ 'key_filename': "mykey.key"
+ }
+ }
+
+ self.result = {}
+
+ def test_setup_mpstat_installed(self, mock_ssh):
+ l = cpuload.CPULoad({}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (0, '', '')
+
+ l.setup()
+ self.assertIsNotNone(l.client)
+ self.assertTrue(l.setup_done)
+ self.assertTrue(l.has_mpstat)
+
+ def test_setup_mpstat_not_installed(self, mock_ssh):
+ l = cpuload.CPULoad({}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (127, '', '')
+
+ l.setup()
+ self.assertIsNotNone(l.client)
+ self.assertTrue(l.setup_done)
+ self.assertFalse(l.has_mpstat)
+
+ def test_execute_command_success(self, mock_ssh):
+ l = cpuload.CPULoad({}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (0, '', '')
+ l.setup()
+
+ expected_result = 'abcdefg'
+ mock_ssh.SSH().execute.return_value = (0, expected_result, '')
+ result = l._execute_command("foo")
+ self.assertEqual(result, expected_result)
+
+ def test_execute_command_failed(self, mock_ssh):
+ l = cpuload.CPULoad({}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (0, '', '')
+ l.setup()
+
+ mock_ssh.SSH().execute.return_value = (127, '', 'abcdefg')
+ self.assertRaises(RuntimeError, l._execute_command,
+ "cat /proc/loadavg")
+
+ def test_get_loadavg(self, mock_ssh):
+ l = cpuload.CPULoad({}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (0, '', '')
+ l.setup()
+
+ mock_ssh.SSH().execute.return_value = \
+ (0, '1.50 1.45 1.51 3/813 14322', '')
+ result = l._get_loadavg()
+ expected_result = \
+ {'loadavg': ['1.50', '1.45', '1.51', '3/813', '14322']}
+ self.assertEqual(result, expected_result)
+
+ def test_get_cpu_usage_mpstat(self, mock_ssh):
+ l = cpuload.CPULoad({}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (0, '', '')
+ l.setup()
+
+ l.interval = 0
+ mpstat_output = self._read_file("cpuload_sample_output1.txt")
+ mock_ssh.SSH().execute.return_value = (0, mpstat_output, '')
+ result = l._get_cpu_usage_mpstat()
+
+ expected_result = \
+ {'mpstat':
+ {'cpu':
+ {'%gnice': '0.00',
+ '%guest': '5.51',
+ '%idle': '81.77',
+ '%iowait': '0.18',
+ '%irq': '0.00',
+ '%nice': '0.03',
+ '%soft': '0.01',
+ '%steal': '0.00',
+ '%sys': '1.19',
+ '%usr': '11.31'},
+ 'cpu0':
+ {'%gnice': '0.00',
+ '%guest': '6.62',
+ '%idle': '71.56',
+ '%iowait': '0.33',
+ '%irq': '0.00',
+ '%nice': '0.03',
+ '%soft': '0.06',
+ '%steal': '0.00',
+ '%sys': '1.36',
+ '%usr': '20.03'}}}
+
+ self.assertDictEqual(result, expected_result)
+
+ def test_get_cpu_usage(self, mock_ssh):
+ l = cpuload.CPULoad({}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (0, '', '')
+ l.setup()
+
+ l.interval = 0
+ output = self._read_file("cpuload_sample_output2.txt")
+ mock_ssh.SSH().execute.return_value = (0, output, '')
+ result = l._get_cpu_usage()
+
+ expected_result = \
+ {'mpstat':
+ {'cpu':
+ {'%steal': '0.00',
+ '%usr': '11.31',
+ '%gnice': '0.00',
+ '%idle': '81.78',
+ '%iowait': '0.18',
+ '%guest': '5.50',
+ '%sys': '1.19',
+ '%soft': '0.01',
+ '%irq': '0.00',
+ '%nice': '0.03'},
+ 'cpu0':
+ {'%steal': '0.00',
+ '%usr': '20.00',
+ '%gnice': '0.00',
+ '%idle': '71.60',
+ '%iowait': '0.33',
+ '%guest': '6.61',
+ '%sys': '1.37',
+ '%soft': '0.06',
+ '%irq': '0.00',
+ '%nice': '0.03'}}}
+
+ self.assertDictEqual(result, expected_result)
+
+ def test_run_mpstat(self, mock_ssh):
+ l = cpuload.CPULoad({'options': {'interval': 1}}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (0, '', '')
+
+ mpstat_output = self._read_file("cpuload_sample_output1.txt")
+ mock_ssh.SSH().execute.side_effect = \
+ [(0, '', ''), (0, '1.50 1.45 1.51 3/813 14322', ''), (0, mpstat_output, '')]
+
+ l.run(self.result)
+
+ expected_result = {
+ 'loadavg': ['1.50', '1.45', '1.51', '3/813', '14322'],
+ 'mpstat':
+ {'cpu': {'%gnice': '0.00',
+ '%guest': '5.51',
+ '%idle': '81.77',
+ '%iowait': '0.18',
+ '%irq': '0.00',
+ '%nice': '0.03',
+ '%soft': '0.01',
+ '%steal': '0.00',
+ '%sys': '1.19',
+ '%usr': '11.31'},
+ 'cpu0': {'%gnice': '0.00',
+ '%guest': '6.62',
+ '%idle': '71.56',
+ '%iowait': '0.33',
+ '%irq': '0.00',
+ '%nice': '0.03',
+ '%soft': '0.06',
+ '%steal': '0.00',
+ '%sys': '1.36',
+ '%usr': '20.03'}}}
+
+ self.assertDictEqual(self.result, expected_result)
+
+ def test_run_proc_stat(self, mock_ssh):
+ l = cpuload.CPULoad({}, self.ctx)
+ mock_ssh.SSH().execute.return_value = (1, '', '')
+ l.setup()
+
+ l.interval = 0
+ stat_output = self._read_file("cpuload_sample_output2.txt")
+ mock_ssh.SSH().execute.side_effect = \
+ [(0, '1.50 1.45 1.51 3/813 14322', ''), (0, stat_output, '')]
+
+ l.run(self.result)
+ expected_result = {
+ 'loadavg': ['1.50', '1.45', '1.51', '3/813', '14322'],
+ 'mpstat':
+ {'cpu':
+ {'%steal': '0.00',
+ '%usr': '11.31',
+ '%gnice': '0.00',
+ '%idle': '81.78',
+ '%iowait': '0.18',
+ '%guest': '5.50',
+ '%sys': '1.19',
+ '%soft': '0.01',
+ '%irq': '0.00',
+ '%nice': '0.03'},
+ 'cpu0':
+ {'%steal': '0.00',
+ '%usr': '20.00',
+ '%gnice': '0.00',
+ '%idle': '71.60',
+ '%iowait': '0.33',
+ '%guest': '6.61',
+ '%sys': '1.37',
+ '%soft': '0.06',
+ '%irq': '0.00',
+ '%nice': '0.03'}}}
+
+ self.assertDictEqual(self.result, expected_result)
+
+ def _read_file(self, filename):
+ curr_path = os.path.dirname(os.path.abspath(__file__))
+ output = os.path.join(curr_path, filename)
+ with open(output) as f:
+ sample_output = f.read()
+ return sample_output