root / snf-cyclades-app / synnefo / logic / tests / servers.py @ 92d2d1ce
History | View | Annotate | Download (12.7 kB)
1 | 0208770b | Christos Stavrakakis | # vim: set fileencoding=utf-8 :
|
---|---|---|---|
2 | 0208770b | Christos Stavrakakis | # Copyright 2013 GRNET S.A. All rights reserved.
|
3 | 0208770b | Christos Stavrakakis | #
|
4 | 0208770b | Christos Stavrakakis | # Redistribution and use in source and binary forms, with or without
|
5 | 0208770b | Christos Stavrakakis | # modification, are permitted provided that the following conditions
|
6 | 0208770b | Christos Stavrakakis | # are met:
|
7 | 0208770b | Christos Stavrakakis | #
|
8 | 0208770b | Christos Stavrakakis | # 1. Redistributions of source code must retain the above copyright
|
9 | 0208770b | Christos Stavrakakis | # notice, this list of conditions and the following disclaimer.
|
10 | 0208770b | Christos Stavrakakis | #
|
11 | 0208770b | Christos Stavrakakis | # 2. Redistributions in binary form must reproduce the above copyright
|
12 | 0208770b | Christos Stavrakakis | # notice, this list of conditions and the following disclaimer in the
|
13 | 0208770b | Christos Stavrakakis | # documentation and/or other materials provided with the distribution.
|
14 | 0208770b | Christos Stavrakakis | #
|
15 | 0208770b | Christos Stavrakakis | # THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
|
16 | 0208770b | Christos Stavrakakis | # ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
17 | 0208770b | Christos Stavrakakis | # IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
18 | 0208770b | Christos Stavrakakis | # ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
|
19 | 0208770b | Christos Stavrakakis | # FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
20 | 0208770b | Christos Stavrakakis | # DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
21 | 0208770b | Christos Stavrakakis | # OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
22 | 0208770b | Christos Stavrakakis | # HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
23 | 0208770b | Christos Stavrakakis | # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
24 | 0208770b | Christos Stavrakakis | # OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
25 | 0208770b | Christos Stavrakakis | # SUCH DAMAGE.
|
26 | 0208770b | Christos Stavrakakis | #
|
27 | 0208770b | Christos Stavrakakis | # The views and conclusions contained in the software and documentation are
|
28 | 0208770b | Christos Stavrakakis | # those of the authors and should not be interpreted as representing official
|
29 | 0208770b | Christos Stavrakakis | # policies, either expressed or implied, of GRNET S.A.
|
30 | 0208770b | Christos Stavrakakis | |
31 | 0208770b | Christos Stavrakakis | # Provides automated tests for logic module
|
32 | 562bf712 | Christos Stavrakakis | from django.test import TransactionTestCase |
33 | 0208770b | Christos Stavrakakis | #from snf_django.utils.testing import mocked_quotaholder
|
34 | 0208770b | Christos Stavrakakis | from synnefo.logic import servers |
35 | 562bf712 | Christos Stavrakakis | from synnefo.db import models_factory as mfactory, models |
36 | 0208770b | Christos Stavrakakis | from mock import patch |
37 | 0208770b | Christos Stavrakakis | |
38 | 0208770b | Christos Stavrakakis | from snf_django.lib.api import faults |
39 | 0208770b | Christos Stavrakakis | from snf_django.utils.testing import mocked_quotaholder, override_settings |
40 | 728e8923 | Christos Stavrakakis | from django.conf import settings |
41 | 562bf712 | Christos Stavrakakis | from copy import deepcopy |
42 | 0208770b | Christos Stavrakakis | |
43 | 0208770b | Christos Stavrakakis | |
44 | 0208770b | Christos Stavrakakis | @patch("synnefo.logic.rapi_pool.GanetiRapiClient") |
45 | 562bf712 | Christos Stavrakakis | class ServerCreationTest(TransactionTestCase): |
46 | 0208770b | Christos Stavrakakis | def test_create(self, mrapi): |
47 | 0208770b | Christos Stavrakakis | flavor = mfactory.FlavorFactory() |
48 | 0208770b | Christos Stavrakakis | kwargs = { |
49 | 0208770b | Christos Stavrakakis | "userid": "test", |
50 | 0208770b | Christos Stavrakakis | "name": "test_vm", |
51 | 0208770b | Christos Stavrakakis | "password": "1234", |
52 | 0208770b | Christos Stavrakakis | "flavor": flavor,
|
53 | 0208770b | Christos Stavrakakis | "image": {"id": "foo", "backend_id": "foo", "format": "diskdump", |
54 | 0208770b | Christos Stavrakakis | "metadata": "{}"}, |
55 | 0208770b | Christos Stavrakakis | "metadata": {"foo": "bar"}, |
56 | 0208770b | Christos Stavrakakis | "personality": [],
|
57 | 0208770b | Christos Stavrakakis | } |
58 | 562bf712 | Christos Stavrakakis | # no backend!
|
59 | 562bf712 | Christos Stavrakakis | mfactory.BackendFactory(offline=True)
|
60 | 562bf712 | Christos Stavrakakis | self.assertRaises(faults.ServiceUnavailable, servers.create, **kwargs)
|
61 | 562bf712 | Christos Stavrakakis | self.assertEqual(models.VirtualMachine.objects.count(), 0) |
62 | 0208770b | Christos Stavrakakis | |
63 | 562bf712 | Christos Stavrakakis | mfactory.BackendFactory(drained=False)
|
64 | 562bf712 | Christos Stavrakakis | mfactory.BackendNetworkFactory(network__public=True)
|
65 | 562bf712 | Christos Stavrakakis | |
66 | 562bf712 | Christos Stavrakakis | # error in nics
|
67 | 562bf712 | Christos Stavrakakis | req = deepcopy(kwargs) |
68 | 562bf712 | Christos Stavrakakis | req["private_networks"] = [42] |
69 | 562bf712 | Christos Stavrakakis | self.assertRaises(faults.ItemNotFound, servers.create, **req)
|
70 | 562bf712 | Christos Stavrakakis | self.assertEqual(models.VirtualMachine.objects.count(), 0) |
71 | 562bf712 | Christos Stavrakakis | |
72 | 562bf712 | Christos Stavrakakis | # error in enqueue. check the vm is deleted and resources released
|
73 | 562bf712 | Christos Stavrakakis | mrapi().CreateInstance.side_effect = Exception("ganeti is down") |
74 | 562bf712 | Christos Stavrakakis | with mocked_quotaholder():
|
75 | 9dcfad23 | Christos Stavrakakis | servers.create(**kwargs) |
76 | 562bf712 | Christos Stavrakakis | vm = models.VirtualMachine.objects.get() |
77 | 9dcfad23 | Christos Stavrakakis | self.assertFalse(vm.deleted)
|
78 | 9dcfad23 | Christos Stavrakakis | self.assertEqual(vm.operstate, "ERROR") |
79 | 9dcfad23 | Christos Stavrakakis | self.assertEqual(len(vm.nics.all()), 1) |
80 | 9dcfad23 | Christos Stavrakakis | for nic in vm.nics.all(): |
81 | 9dcfad23 | Christos Stavrakakis | self.assertEqual(nic.state, "ERROR") |
82 | 562bf712 | Christos Stavrakakis | |
83 | 562bf712 | Christos Stavrakakis | # success with no nics
|
84 | 562bf712 | Christos Stavrakakis | mrapi().CreateInstance.side_effect = None
|
85 | 0208770b | Christos Stavrakakis | mrapi().CreateInstance.return_value = 42
|
86 | 0208770b | Christos Stavrakakis | with override_settings(settings,
|
87 | 0208770b | Christos Stavrakakis | DEFAULT_INSTANCE_NETWORKS=[]): |
88 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
89 | 0208770b | Christos Stavrakakis | vm = servers.create(**kwargs) |
90 | 562bf712 | Christos Stavrakakis | vm = models.VirtualMachine.objects.get(id=vm.id) |
91 | 0208770b | Christos Stavrakakis | self.assertEqual(vm.nics.count(), 0) |
92 | 562bf712 | Christos Stavrakakis | self.assertEqual(vm.backendjobid, 42) |
93 | 562bf712 | Christos Stavrakakis | self.assertEqual(vm.task_job_id, 42) |
94 | 562bf712 | Christos Stavrakakis | self.assertEqual(vm.task, "BUILD") |
95 | 0208770b | Christos Stavrakakis | |
96 | 0208770b | Christos Stavrakakis | # test connect in IPv6 only network
|
97 | 0208770b | Christos Stavrakakis | net = mfactory.IPv6NetworkFactory(state="ACTIVE")
|
98 | 0208770b | Christos Stavrakakis | mfactory.BackendNetworkFactory(network=net) |
99 | 0208770b | Christos Stavrakakis | with override_settings(settings,
|
100 | 0208770b | Christos Stavrakakis | DEFAULT_INSTANCE_NETWORKS=[str(net.id)]):
|
101 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
102 | 0208770b | Christos Stavrakakis | vm = servers.create(**kwargs) |
103 | 0208770b | Christos Stavrakakis | nics = vm.nics.all() |
104 | 0208770b | Christos Stavrakakis | self.assertEqual(len(nics), 1) |
105 | 0208770b | Christos Stavrakakis | self.assertEqual(nics[0].ipv4, None) |
106 | 0208770b | Christos Stavrakakis | args, kwargs = mrapi().CreateInstance.call_args |
107 | 0208770b | Christos Stavrakakis | ganeti_nic = kwargs["nics"][0] |
108 | 0208770b | Christos Stavrakakis | self.assertEqual(ganeti_nic["ip"], None) |
109 | 0208770b | Christos Stavrakakis | self.assertEqual(ganeti_nic["network"], net.backend_id) |
110 | 0208770b | Christos Stavrakakis | |
111 | 562bf712 | Christos Stavrakakis | |
112 | 562bf712 | Christos Stavrakakis | @patch("synnefo.logic.rapi_pool.GanetiRapiClient") |
113 | 562bf712 | Christos Stavrakakis | class ServerTest(TransactionTestCase): |
114 | 0208770b | Christos Stavrakakis | def test_connect_network(self, mrapi): |
115 | 0208770b | Christos Stavrakakis | # Common connect
|
116 | 0208770b | Christos Stavrakakis | net = mfactory.NetworkFactory(subnet="192.168.2.0/24",
|
117 | 0208770b | Christos Stavrakakis | gateway="192.168.2.1",
|
118 | 0208770b | Christos Stavrakakis | state="ACTIVE",
|
119 | 0208770b | Christos Stavrakakis | dhcp=True,
|
120 | 0208770b | Christos Stavrakakis | flavor="CUSTOM")
|
121 | 9599e997 | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STARTED")
|
122 | 0208770b | Christos Stavrakakis | mfactory.BackendNetworkFactory(network=net, backend=vm.backend) |
123 | 0208770b | Christos Stavrakakis | mrapi().ModifyInstance.return_value = 42
|
124 | 0208770b | Christos Stavrakakis | servers.connect(vm, net) |
125 | 92d2d1ce | Christos Stavrakakis | pool = net.get_pool(locked=False)
|
126 | 0208770b | Christos Stavrakakis | self.assertFalse(pool.is_available("192.168.2.2")) |
127 | 0208770b | Christos Stavrakakis | args, kwargs = mrapi().ModifyInstance.call_args |
128 | 0208770b | Christos Stavrakakis | nics = kwargs["nics"][0] |
129 | 6488097c | Christos Stavrakakis | self.assertEqual(kwargs["instance"], vm.backend_vm_id) |
130 | 0208770b | Christos Stavrakakis | self.assertEqual(nics[0], "add") |
131 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[1], "-1") |
132 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[2]["ip"], "192.168.2.2") |
133 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[2]["network"], net.backend_id) |
134 | 0208770b | Christos Stavrakakis | |
135 | 0208770b | Christos Stavrakakis | # No dhcp
|
136 | 9599e997 | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STARTED")
|
137 | 0208770b | Christos Stavrakakis | net = mfactory.NetworkFactory(subnet="192.168.2.0/24",
|
138 | 0208770b | Christos Stavrakakis | gateway="192.168.2.1",
|
139 | 0208770b | Christos Stavrakakis | state="ACTIVE",
|
140 | 0208770b | Christos Stavrakakis | dhcp=False)
|
141 | 0208770b | Christos Stavrakakis | mfactory.BackendNetworkFactory(network=net, backend=vm.backend) |
142 | 0208770b | Christos Stavrakakis | servers.connect(vm, net) |
143 | 92d2d1ce | Christos Stavrakakis | pool = net.get_pool(locked=False)
|
144 | 0208770b | Christos Stavrakakis | self.assertTrue(pool.is_available("192.168.2.2")) |
145 | 0208770b | Christos Stavrakakis | args, kwargs = mrapi().ModifyInstance.call_args |
146 | 0208770b | Christos Stavrakakis | nics = kwargs["nics"][0] |
147 | 6488097c | Christos Stavrakakis | self.assertEqual(kwargs["instance"], vm.backend_vm_id) |
148 | 0208770b | Christos Stavrakakis | self.assertEqual(nics[0], "add") |
149 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[1], "-1") |
150 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[2]["ip"], None) |
151 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[2]["network"], net.backend_id) |
152 | 0208770b | Christos Stavrakakis | |
153 | 0208770b | Christos Stavrakakis | # Test connect to IPv6 only network
|
154 | 9599e997 | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STARTED")
|
155 | 0208770b | Christos Stavrakakis | net = mfactory.NetworkFactory(subnet6="2000::/64",
|
156 | 0208770b | Christos Stavrakakis | state="ACTIVE",
|
157 | 0208770b | Christos Stavrakakis | gateway="2000::1")
|
158 | 0208770b | Christos Stavrakakis | mfactory.BackendNetworkFactory(network=net, backend=vm.backend) |
159 | 0208770b | Christos Stavrakakis | servers.connect(vm, net) |
160 | 0208770b | Christos Stavrakakis | args, kwargs = mrapi().ModifyInstance.call_args |
161 | 0208770b | Christos Stavrakakis | nics = kwargs["nics"][0] |
162 | 6488097c | Christos Stavrakakis | self.assertEqual(kwargs["instance"], vm.backend_vm_id) |
163 | 0208770b | Christos Stavrakakis | self.assertEqual(nics[0], "add") |
164 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[1], "-1") |
165 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[2]["ip"], None) |
166 | a1baa42b | Christos Stavrakakis | self.assertEqual(nics[2]["network"], net.backend_id) |
167 | 0208770b | Christos Stavrakakis | |
168 | 0208770b | Christos Stavrakakis | |
169 | 0208770b | Christos Stavrakakis | @patch("synnefo.logic.rapi_pool.GanetiRapiClient") |
170 | 562bf712 | Christos Stavrakakis | class ServerCommandTest(TransactionTestCase): |
171 | 0208770b | Christos Stavrakakis | def test_pending_task(self, mrapi): |
172 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(task="REBOOT", task_job_id=1) |
173 | 0208770b | Christos Stavrakakis | self.assertRaises(faults.BadRequest, servers.start, vm)
|
174 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(task="BUILD", task_job_id=1) |
175 | 0208770b | Christos Stavrakakis | self.assertRaises(faults.BuildInProgress, servers.start, vm)
|
176 | 0208770b | Christos Stavrakakis | # Assert always succeeds
|
177 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(task="BUILD", task_job_id=1) |
178 | 0208770b | Christos Stavrakakis | mrapi().DeleteInstance.return_value = 1
|
179 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
180 | 0208770b | Christos Stavrakakis | servers.destroy(vm) |
181 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(task="REBOOT", task_job_id=1) |
182 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
183 | 0208770b | Christos Stavrakakis | servers.destroy(vm) |
184 | 0208770b | Christos Stavrakakis | |
185 | 0208770b | Christos Stavrakakis | def test_deleted_vm(self, mrapi): |
186 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(deleted=True)
|
187 | 0208770b | Christos Stavrakakis | self.assertRaises(faults.BadRequest, servers.start, vm)
|
188 | 0208770b | Christos Stavrakakis | |
189 | 0208770b | Christos Stavrakakis | def test_invalid_operstate_for_action(self, mrapi): |
190 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STARTED")
|
191 | 0208770b | Christos Stavrakakis | self.assertRaises(faults.BadRequest, servers.start, vm)
|
192 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STOPPED")
|
193 | 0208770b | Christos Stavrakakis | self.assertRaises(faults.BadRequest, servers.stop, vm)
|
194 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STARTED")
|
195 | 0208770b | Christos Stavrakakis | self.assertRaises(faults.BadRequest, servers.resize, vm)
|
196 | 9599e997 | Christos Stavrakakis | # Check that connect/disconnect is allowed only in STOPPED vms
|
197 | 9599e997 | Christos Stavrakakis | # if hotplug is disabled.
|
198 | 9599e997 | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STARTED")
|
199 | 9599e997 | Christos Stavrakakis | network = mfactory.NetworkFactory(state="ACTIVE")
|
200 | 9599e997 | Christos Stavrakakis | with override_settings(settings, GANETI_USE_HOTPLUG=False): |
201 | 9599e997 | Christos Stavrakakis | self.assertRaises(faults.BadRequest, servers.connect, vm, network)
|
202 | 9599e997 | Christos Stavrakakis | self.assertRaises(faults.BadRequest, servers.disconnect, vm,
|
203 | 9599e997 | Christos Stavrakakis | network) |
204 | 0208770b | Christos Stavrakakis | #test valid
|
205 | 9599e997 | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STOPPED")
|
206 | 0208770b | Christos Stavrakakis | mrapi().StartupInstance.return_value = 1
|
207 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
208 | 0208770b | Christos Stavrakakis | servers.start(vm) |
209 | 0208770b | Christos Stavrakakis | vm.task = None
|
210 | 0208770b | Christos Stavrakakis | vm.task_job_id = None
|
211 | 0208770b | Christos Stavrakakis | vm.save() |
212 | 0208770b | Christos Stavrakakis | mrapi().RebootInstance.return_value = 1
|
213 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
214 | 0208770b | Christos Stavrakakis | servers.reboot(vm, "HARD")
|
215 | 0208770b | Christos Stavrakakis | |
216 | 0208770b | Christos Stavrakakis | def test_commission(self, mrapi): |
217 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory(operstate="STOPPED")
|
218 | 0208770b | Christos Stavrakakis | # Still pending
|
219 | 0208770b | Christos Stavrakakis | vm.serial = mfactory.QuotaHolderSerialFactory(serial=200,
|
220 | 0208770b | Christos Stavrakakis | resolved=False,
|
221 | 0208770b | Christos Stavrakakis | pending=True)
|
222 | 0208770b | Christos Stavrakakis | serial = vm.serial |
223 | 0208770b | Christos Stavrakakis | mrapi().StartupInstance.return_value = 1
|
224 | 0208770b | Christos Stavrakakis | with mocked_quotaholder() as m: |
225 | 0208770b | Christos Stavrakakis | servers.start(vm) |
226 | 0208770b | Christos Stavrakakis | m.resolve_commissions.assert_called_once_with('', [],
|
227 | 0208770b | Christos Stavrakakis | [serial.serial]) |
228 | 0208770b | Christos Stavrakakis | self.assertTrue(m.issue_one_commission.called)
|
229 | 0208770b | Christos Stavrakakis | # Not pending, rejct
|
230 | 0208770b | Christos Stavrakakis | vm.task = None
|
231 | 0208770b | Christos Stavrakakis | vm.serial = mfactory.QuotaHolderSerialFactory(serial=400,
|
232 | 0208770b | Christos Stavrakakis | resolved=False,
|
233 | 0208770b | Christos Stavrakakis | pending=False,
|
234 | 0208770b | Christos Stavrakakis | accept=False)
|
235 | 0208770b | Christos Stavrakakis | serial = vm.serial |
236 | 0208770b | Christos Stavrakakis | mrapi().StartupInstance.return_value = 1
|
237 | 0208770b | Christos Stavrakakis | with mocked_quotaholder() as m: |
238 | 0208770b | Christos Stavrakakis | servers.start(vm) |
239 | 0208770b | Christos Stavrakakis | m.resolve_commissions.assert_called_once_with('', [],
|
240 | 0208770b | Christos Stavrakakis | [serial.serial]) |
241 | 0208770b | Christos Stavrakakis | self.assertTrue(m.issue_one_commission.called)
|
242 | 0208770b | Christos Stavrakakis | # Not pending, accept
|
243 | 0208770b | Christos Stavrakakis | vm.task = None
|
244 | 0208770b | Christos Stavrakakis | vm.serial = mfactory.QuotaHolderSerialFactory(serial=600,
|
245 | 0208770b | Christos Stavrakakis | resolved=False,
|
246 | 0208770b | Christos Stavrakakis | pending=False,
|
247 | 0208770b | Christos Stavrakakis | accept=True)
|
248 | 0208770b | Christos Stavrakakis | serial = vm.serial |
249 | 0208770b | Christos Stavrakakis | mrapi().StartupInstance.return_value = 1
|
250 | 0208770b | Christos Stavrakakis | with mocked_quotaholder() as m: |
251 | 0208770b | Christos Stavrakakis | servers.start(vm) |
252 | 0208770b | Christos Stavrakakis | m.resolve_commissions.assert_called_once_with('', [serial.serial],
|
253 | 0208770b | Christos Stavrakakis | []) |
254 | 0208770b | Christos Stavrakakis | self.assertTrue(m.issue_one_commission.called)
|
255 | 0208770b | Christos Stavrakakis | |
256 | 0208770b | Christos Stavrakakis | mrapi().StartupInstance.side_effect = ValueError
|
257 | 0208770b | Christos Stavrakakis | vm.task = None
|
258 | 0208770b | Christos Stavrakakis | vm.serial = None
|
259 | 0208770b | Christos Stavrakakis | # Test reject if Ganeti erro
|
260 | 0208770b | Christos Stavrakakis | with mocked_quotaholder() as m: |
261 | 0208770b | Christos Stavrakakis | try:
|
262 | 0208770b | Christos Stavrakakis | servers.start(vm) |
263 | 0208770b | Christos Stavrakakis | except:
|
264 | 0208770b | Christos Stavrakakis | m.resolve_commissions\ |
265 | 0208770b | Christos Stavrakakis | .assert_called_once_with('', [], [vm.serial.serial])
|
266 | 0208770b | Christos Stavrakakis | |
267 | 0208770b | Christos Stavrakakis | def test_task_after(self, mrapi): |
268 | 0208770b | Christos Stavrakakis | return
|
269 | 0208770b | Christos Stavrakakis | vm = mfactory.VirtualMachineFactory() |
270 | 0208770b | Christos Stavrakakis | mrapi().StartupInstance.return_value = 1
|
271 | 0208770b | Christos Stavrakakis | mrapi().ShutdownInstance.return_value = 2
|
272 | 0208770b | Christos Stavrakakis | mrapi().RebootInstance.return_value = 2
|
273 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
274 | 0208770b | Christos Stavrakakis | vm.task = None
|
275 | 0208770b | Christos Stavrakakis | vm.operstate = "STOPPED"
|
276 | 0208770b | Christos Stavrakakis | servers.start(vm) |
277 | 0208770b | Christos Stavrakakis | self.assertEqual(vm.task, "START") |
278 | 0208770b | Christos Stavrakakis | self.assertEqual(vm.task_job_id, 1) |
279 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
280 | 0208770b | Christos Stavrakakis | vm.task = None
|
281 | 0208770b | Christos Stavrakakis | vm.operstate = "STARTED"
|
282 | 0208770b | Christos Stavrakakis | servers.stop(vm) |
283 | 0208770b | Christos Stavrakakis | self.assertEqual(vm.task, "STOP") |
284 | 0208770b | Christos Stavrakakis | self.assertEqual(vm.task_job_id, 2) |
285 | 0208770b | Christos Stavrakakis | with mocked_quotaholder():
|
286 | 0208770b | Christos Stavrakakis | vm.task = None
|
287 | 0208770b | Christos Stavrakakis | servers.reboot(vm) |
288 | 0208770b | Christos Stavrakakis | self.assertEqual(vm.task, "REBOOT") |
289 | 0208770b | Christos Stavrakakis | self.assertEqual(vm.task_job_id, 3) |