Merge "HA testcase containerized Compass support"
[yardstick.git] / tests / unit / benchmark / scenarios / availability / test_attacker_baremetal.py
1 #!/usr/bin/env python
2
3 ##############################################################################
4 # Copyright (c) 2015 Huawei Technologies Co.,Ltd and others.
5 #
6 # All rights reserved. This program and the accompanying materials
7 # are made available under the terms of the Apache License, Version 2.0
8 # which accompanies this distribution, and is available at
9 # http://www.apache.org/licenses/LICENSE-2.0
10 ##############################################################################
11
12 # Unittest for
13 # yardstick.benchmark.scenarios.availability.attacker.attacker_baremetal
14
15 from __future__ import absolute_import
16 import mock
17 import unittest
18
19 from yardstick.benchmark.scenarios.availability.attacker import \
20     attacker_baremetal
21
22
23 @mock.patch('yardstick.benchmark.scenarios.availability.attacker.attacker_baremetal.subprocess')
24 class ExecuteShellTestCase(unittest.TestCase):
25
26     def test__fun_execute_shell_command_successful(self, mock_subprocess):
27         cmd = "env"
28         mock_subprocess.check_output.return_value = (0, 'unittest')
29         exitcode, output = attacker_baremetal._execute_shell_command(cmd)
30         self.assertEqual(exitcode, 0)
31
32     @mock.patch('yardstick.benchmark.scenarios.availability.attacker.attacker_baremetal.LOG')
33     def test__fun_execute_shell_command_fail_cmd_exception(self, mock_log, mock_subprocess):
34         cmd = "env"
35         mock_subprocess.check_output.side_effect = RuntimeError
36         exitcode, output = attacker_baremetal._execute_shell_command(cmd)
37         self.assertEqual(exitcode, -1)
38         mock_log.error.assert_called_once()
39
40
41 @mock.patch('yardstick.benchmark.scenarios.availability.attacker.attacker_baremetal.subprocess')
42 @mock.patch('yardstick.benchmark.scenarios.availability.attacker.attacker_baremetal.ssh')
43 class AttackerBaremetalTestCase(unittest.TestCase):
44
45     def setUp(self):
46         host = {
47             "ipmi_ip": "10.20.0.5",
48             "ipmi_user": "root",
49             "ipmi_pwd": "123456",
50             "ip": "10.20.0.5",
51             "user": "root",
52             "key_filename": "/root/.ssh/id_rsa"
53         }
54         self.context = {"node1": host}
55         self.attacker_cfg = {
56             'fault_type': 'bear-metal-down',
57             'host': 'node1',
58         }
59
60     def test__attacker_baremetal_all_successful(self, mock_ssh, mock_subprocess):
61         mock_ssh.SSH.from_node().execute.return_value = (0, "running", '')
62         ins = attacker_baremetal.BaremetalAttacker(self.attacker_cfg,
63                                                    self.context)
64
65         ins.setup()
66         ins.inject_fault()
67         ins.recover()
68
69     def test__attacker_baremetal_check_failuer(self, mock_ssh, mock_subprocess):
70         mock_ssh.SSH.from_node().execute.return_value = (0, "error check", '')
71         ins = attacker_baremetal.BaremetalAttacker(self.attacker_cfg,
72                                                    self.context)
73         ins.setup()
74
75     def test__attacker_baremetal_recover_successful(self, mock_ssh, mock_subprocess):
76
77         self.attacker_cfg["jump_host"] = 'node1'
78         self.context["node1"]["pwd"] = "123456"
79         mock_ssh.SSH.from_node().execute.return_value = (0, "running", '')
80         ins = attacker_baremetal.BaremetalAttacker(self.attacker_cfg,
81                                                    self.context)
82
83         ins.setup()
84         ins.recover()