b5f5468cec48d1460a2ff6fd49c8f0429a7a75b5
[yardstick.git] / yardstick / tests / unit / benchmark / contexts / test_model.py
1 #!/usr/bin/env python
2
3 ##############################################################################
4 # Copyright (c) 2015 Ericsson AB 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 yardstick.benchmark.contexts.model
13
14 from __future__ import absolute_import
15 import unittest
16 import mock
17
18 from yardstick.benchmark.contexts import model
19
20
21 class ObjectTestCase(unittest.TestCase):
22
23     def setUp(self):
24         self.mock_context = mock.Mock()
25
26     def test_construct(self):
27
28         test_object = model.Object('foo', self.mock_context)
29
30         self.assertEqual(test_object.name, 'foo')
31         self.assertEqual(test_object._context, self.mock_context)
32         self.assertIsNone(test_object.stack_name)
33         self.assertIsNone(test_object.stack_id)
34
35     def test_dn(self):
36
37         self.mock_context.name = 'bar'
38         test_object = model.Object('foo', self.mock_context)
39
40         self.assertEqual('foo.bar', test_object.dn)
41
42
43 class PlacementGroupTestCase(unittest.TestCase):
44
45     def setUp(self):
46         self.mock_context = mock.Mock()
47         self.mock_context.name = 'bar'
48
49     def tearDown(self):
50         model.PlacementGroup.map = {}
51
52     def test_sucessful_construct(self):
53
54         test_pg = model.PlacementGroup('foo', self.mock_context, 'affinity')
55
56         self.assertEqual(test_pg.name, 'foo')
57         self.assertEqual(test_pg.members, set())
58         self.assertEqual(test_pg.stack_name, 'bar-foo')
59         self.assertEqual(test_pg.policy, 'affinity')
60
61         test_map = {'foo': test_pg}
62         self.assertEqual(model.PlacementGroup.map, test_map)
63
64     def test_wrong_policy_in_construct(self):
65
66         self.assertRaises(ValueError, model.PlacementGroup, 'foo',
67                           self.mock_context, 'baz')
68
69     def test_add_member(self):
70
71         test_pg = model.PlacementGroup('foo', self.mock_context, 'affinity')
72         test_pg.add_member('foo')
73
74         self.assertEqual(test_pg.members, set(['foo']))
75
76     def test_get_name_successful(self):
77
78         model.PlacementGroup.map = {'foo': True}
79         self.assertTrue(model.PlacementGroup.get('foo'))
80
81     def test_get_name_unsuccessful(self):
82
83         self.assertIsNone(model.PlacementGroup.get('foo'))
84
85
86 class RouterTestCase(unittest.TestCase):
87
88     def test_construct(self):
89
90         mock_context = mock.Mock()
91         mock_context.name = 'baz'
92         test_router = model.Router('foo', 'bar', mock_context, 'qux')
93
94         self.assertEqual(test_router.stack_name, 'baz-bar-foo')
95         self.assertEqual(test_router.stack_if_name, 'baz-bar-foo-if0')
96         self.assertEqual(test_router.external_gateway_info, 'qux')
97
98
99 class NetworkTestCase(unittest.TestCase):
100
101     def setUp(self):
102         self.mock_context = mock.Mock()
103         self.mock_context.name = 'bar'
104
105     def tearDown(self):
106         model.Network.list = []
107
108     def test_construct_no_external_network(self):
109
110         attrs = {'cidr': '10.0.0.0/24'}
111         test_network = model.Network('foo', self.mock_context, attrs)
112
113         self.assertEqual(test_network.stack_name, 'bar-foo')
114         self.assertEqual(test_network.subnet_stack_name, 'bar-foo-subnet')
115         self.assertEqual(test_network.subnet_cidr, attrs['cidr'])
116         self.assertIsNone(test_network.router)
117         self.assertIn(test_network, model.Network.list)
118
119     def test_construct_has_external_network(self):
120
121         attrs = {'external_network': 'ext_net'}
122         test_network = model.Network('foo', self.mock_context, attrs)
123         exp_router = model.Router('router', 'foo', self.mock_context,
124                                   'ext_net')
125
126         self.assertEqual(test_network.router.stack_name, exp_router.stack_name)
127         self.assertEqual(test_network.router.stack_if_name,
128                          exp_router.stack_if_name)
129         self.assertEqual(test_network.router.external_gateway_info,
130                          exp_router.external_gateway_info)
131
132     def test_has_route_to(self):
133
134         attrs = {'external_network': 'ext_net'}
135         test_network = model.Network('foo', self.mock_context, attrs)
136
137         self.assertTrue(test_network.has_route_to('ext_net'))
138
139     def test_has_no_route_to(self):
140
141         attrs = {}
142         test_network = model.Network('foo', self.mock_context, attrs)
143
144         self.assertFalse(test_network.has_route_to('ext_net'))
145
146     @mock.patch('yardstick.benchmark.contexts.model.Network.has_route_to')
147     def test_find_by_route_to(self, mock_has_route_to):
148
149         mock_network = mock.Mock()
150         model.Network.list = [mock_network]
151         mock_has_route_to.return_value = True
152
153         self.assertIs(mock_network, model.Network.find_by_route_to('foo'))
154
155     def test_find_external_network(self):
156
157         mock_network = mock.Mock()
158         mock_network.router = mock.Mock() #pylint ignore assignment-from-none
159         mock_network.router.external_gateway_info = 'ext_net'
160         model.Network.list = [mock_network]
161
162         self.assertEqual(model.Network.find_external_network(), 'ext_net')
163
164     def test_construct_gateway_ip_is_null(self):
165
166         attrs = {'gateway_ip': 'null'}
167         test_network = model.Network('foo', self.mock_context, attrs)
168         self.assertEqual(test_network.gateway_ip, 'null')
169
170     def test_construct_gateway_ip_is_none(self):
171
172         attrs = {'gateway_ip': None}
173         test_network = model.Network('foo', self.mock_context, attrs)
174         self.assertEqual(test_network.gateway_ip, 'null')
175
176     def test_construct_gateway_ip_is_absent(self):
177
178         attrs = {}
179         test_network = model.Network('foo', self.mock_context, attrs)
180         self.assertIsNone(test_network.gateway_ip)
181
182
183 class ServerTestCase(unittest.TestCase):
184
185     def setUp(self):
186         self.mock_context = mock.Mock()
187         self.mock_context.name = 'bar'
188         self.mock_context.keypair_name = 'some-keys'
189         self.mock_context.secgroup_name = 'some-secgroup'
190         self.mock_context.user = "some-user"
191         netattrs = {'cidr': '10.0.0.0/24', 'provider': None, 'external_network': 'ext_net'}
192         self.mock_context.networks = [model.Network("some-network", self.mock_context, netattrs)]
193
194     def test_construct_defaults(self):
195
196         attrs = None
197         test_server = model.Server('foo', self.mock_context, attrs)
198
199         self.assertEqual(test_server.stack_name, 'foo.bar')
200         self.assertEqual(test_server.keypair_name, 'some-keys')
201         self.assertEqual(test_server.secgroup_name, 'some-secgroup')
202         self.assertEqual(test_server.placement_groups, [])
203         self.assertIsNone(test_server.server_group)
204         self.assertEqual(test_server.instances, 1)
205         self.assertIsNone(test_server.floating_ip)
206         self.assertIsNone(test_server._image)
207         self.assertIsNone(test_server._flavor)
208         self.assertIn(test_server, model.Server.list)
209
210     @mock.patch('yardstick.benchmark.contexts.model.PlacementGroup')
211     def test_construct_get_wrong_placement_group(self, mock_pg):
212
213         attrs = {'placement': 'baz'}
214         mock_pg.get.return_value = None
215
216         self.assertRaises(ValueError, model.Server, 'foo',
217                           self.mock_context, attrs)
218
219     @mock.patch('yardstick.benchmark.contexts.model.PlacementGroup')
220     def test_construct_get_wrong_server_group(self, mock_sg):
221
222         attrs = {'server_group': 'baz'}
223         mock_sg.get.return_value = None
224
225         self.assertRaises(ValueError, model.Server, 'foo',
226                           self.mock_context, attrs)
227
228     @mock.patch('yardstick.benchmark.contexts.heat.HeatTemplate')
229     def test__add_instance(self, mock_template):
230         attrs = {'image': 'some-image', 'flavor': 'some-flavor', 'floating_ip': '192.168.1.10',
231                  'floating_ip_assoc': 'some-vm',
232                  'availability_zone': 'zone'}
233         test_server = model.Server('foo', self.mock_context, attrs)
234
235         self.mock_context.flavors = ['flavor1', 'flavor2', 'some-flavor']
236
237         mock_network = mock.Mock()
238         mock_network.name = 'some-network'
239         mock_network.stack_name = 'some-network-stack'
240         mock_network.allowed_address_pairs = ["1", "2"]
241         mock_network.vnic_type = 'normal'
242         mock_network.subnet_stack_name = 'some-network-stack-subnet'
243         mock_network.provider = 'sriov'
244         mock_network.net_flags = {}
245         mock_network.external_network = 'ext_net'
246         mock_network.router = model.Router('some-router', 'some-network', self.mock_context,
247                                            'ext_net')
248
249         test_server._add_instance(mock_template, 'some-server',
250                                   [mock_network], 'hints')
251
252         mock_template.add_port.assert_called_with(
253             'some-server-some-network-port',
254             mock_network,
255             sec_group_id=self.mock_context.secgroup_name,
256             provider=mock_network.provider,
257             allowed_address_pairs=mock_network.allowed_address_pairs)
258
259         mock_template.add_floating_ip.assert_called_with(
260             'some-server-fip',
261             mock_network.external_network,
262             'some-server-some-network-port',
263             'bar-some-network-some-router-if0',
264             'some-secgroup'
265         )
266
267         mock_template.add_floating_ip_association.assert_called_with(
268             'some-server-fip-assoc',
269             'some-server-fip',
270             'some-server-some-network-port'
271         )
272
273         mock_template.add_server.assert_called_with(
274             'some-server', 'some-image',
275             flavor='some-flavor',
276             flavors=['flavor1', 'flavor2', 'some-flavor'],
277             ports=['some-server-some-network-port'],
278             user=self.mock_context.user,
279             key_name=self.mock_context.keypair_name,
280             user_data='',
281             scheduler_hints='hints',
282             availability_zone='zone')
283
284     def test_override_ip(self):
285         network_ports = {
286             'mgmt': ['mgmt'],
287             'uplink_0': [
288                 {'xe0': {'local_ip': '10.44.0.20', 'netmask': '255.255.255.0'}},
289             ],
290             'downlink_0': [
291                 {'xe1': {'local_ip': '10.44.0.30', 'netmask': '255.255.255.0'}},
292             ],
293         }
294         attrs = {
295             'image': 'some-image', 'flavor': 'some-flavor',
296         }
297         test_server = model.Server('foo', self.mock_context, attrs)
298         test_server.interfaces = {
299             "xe0": {
300                 "local_ip": "1.2.3.4",
301                 "netmask": "255.255.255.0",
302             },
303             "xe1": {
304                 "local_ip": "1.2.3.5",
305                 "netmask": "255.255.255.0"
306             }
307         }
308         test_server.network_ports = network_ports
309
310         test_server.override_ip("uplink_0", {"port": "xe0"})
311         self.assertEqual(test_server.interfaces["xe0"], network_ports["uplink_0"][0]["xe0"])
312
313     def test_override_ip_multiple(self):
314         network_ports = {
315             'mgmt': ['mgmt'],
316             'uplink_0': [
317                 {'xe0': {'local_ip': '10.44.0.20', 'netmask': '255.255.255.0'}},
318                 {'xe0': {'local_ip': '10.44.0.21', 'netmask': '255.255.255.0'}},
319             ],
320             'downlink_0': [
321                 {'xe1': {'local_ip': '10.44.0.30', 'netmask': '255.255.255.0'}},
322             ],
323         }
324         attrs = {
325             'image': 'some-image', 'flavor': 'some-flavor',
326         }
327         test_server = model.Server('foo', self.mock_context, attrs)
328         test_server.interfaces = {
329             "xe0": {
330                 "local_ip": "1.2.3.4",
331                 "netmask": "255.255.255.0",
332             },
333             "xe1": {
334                 "local_ip": "1.2.3.5",
335                 "netmask": "255.255.255.0"
336             }
337         }
338         test_server.network_ports = network_ports
339         test_server.override_ip("uplink_0", {"port": "xe0"})
340         self.assertEqual(test_server.interfaces["xe0"], network_ports["uplink_0"][0]["xe0"])
341
342     def test_override_ip_mixed(self):
343         network_ports = {
344             'mgmt': ['mgmt'],
345             'uplink_0': [
346                 'xe0',
347                 {'xe0': {'local_ip': '10.44.0.21', 'netmask': '255.255.255.0'}},
348             ],
349             'downlink_0': [
350                 {'xe1': {'local_ip': '10.44.0.30', 'netmask': '255.255.255.0'}},
351             ],
352         }
353         attrs = {
354             'image': 'some-image', 'flavor': 'some-flavor',
355         }
356         test_server = model.Server('foo', self.mock_context, attrs)
357         test_server.interfaces = {
358             "xe0": {
359                 "local_ip": "1.2.3.4",
360                 "netmask": "255.255.255.0",
361             },
362             "xe1": {
363                 "local_ip": "1.2.3.5",
364                 "netmask": "255.255.255.0"
365             }
366         }
367         test_server.network_ports = network_ports
368         test_server.override_ip("uplink_0", {"port": "xe0"})
369         self.assertEqual(test_server.interfaces["xe0"], network_ports["uplink_0"][1]["xe0"])
370
371     @mock.patch('yardstick.benchmark.contexts.heat.HeatTemplate')
372     def test__add_instance_with_ip_override_invalid_syntax(self, mock_template):
373         network_ports = {
374             'mgmt': ['mgmt'],
375             'uplink_0': 'xe0',
376             'downlink_0': [
377                 {'xe1': {'local_ip': '10.44.0.30', 'netmask': '255.255.255.0'}},
378             ],
379         }
380         attrs = {
381             'image': 'some-image', 'flavor': 'some-flavor',
382         }
383         test_server = model.Server('foo', self.mock_context, attrs)
384         test_server.network_ports = network_ports
385         context = type("Context", (object,), {})
386         # can't use Mock because Mock.name is reserved
387         context.name = "context"
388         networks = [model.Network(n, context, {}) for n in network_ports]
389
390         with self.assertRaises(SyntaxError):
391             test_server._add_instance(mock_template, 'some-server',
392                                       networks, 'hints')
393
394     @mock.patch('yardstick.benchmark.contexts.heat.HeatTemplate')
395     def test__add_instance_with_ip_override(self, mock_template):
396         network_ports = {
397             'mgmt': ['mgmt'],
398             'uplink_0': [
399                 {'xe0': {'local_ip': '10.44.0.20', 'netmask': '255.255.255.0'}},
400             ],
401             'downlink_0': [
402                 {'xe1': {'local_ip': '10.44.0.30', 'netmask': '255.255.255.0'}},
403             ],
404         }
405         attrs = {
406             'image': 'some-image', 'flavor': 'some-flavor',
407         }
408         test_server = model.Server('foo', self.mock_context, attrs)
409         test_server.network_ports = network_ports
410         context = type("Context", (object,), {})
411         # can't use Mock because Mock.name is reserved
412         context.name = "context"
413         networks = [model.Network(n, context, {}) for n in network_ports]
414
415         test_server._add_instance(mock_template, 'some-server',
416                                   networks, 'hints')
417         self.assertEqual(test_server.ports, {
418             'downlink_0': [{'port': 'xe1', 'stack_name': 'some-server-xe1-port'}],
419             'mgmt': [{'port': 'mgmt', 'stack_name': 'some-server-mgmt-port'}],
420             'uplink_0': [{'port': 'xe0', 'stack_name': 'some-server-xe0-port'}]
421         })
422
423     @mock.patch('yardstick.benchmark.contexts.heat.HeatTemplate')
424     def test__add_instance_with_multiple_ip_override(self, mock_template):
425         network_ports = {
426             'mgmt': ['mgmt'],
427             'uplink_0': [
428                 {'xe0': {'local_ip': '10.44.0.20', 'netmask': '255.255.255.0'}},
429                 {'xe0': {'local_ip': '10.44.0.21', 'netmask': '255.255.255.0'}},
430             ],
431             'downlink_0': [
432                 {'xe1': {'local_ip': '10.44.0.30', 'netmask': '255.255.255.0'}},
433             ],
434         }
435         attrs = {
436             'image': 'some-image', 'flavor': 'some-flavor',
437         }
438         test_server = model.Server('foo', self.mock_context, attrs)
439         test_server.network_ports = network_ports
440         context = type("Context", (object,), {})
441         # can't use Mock because Mock.name is reserved
442         context.name = "context"
443         networks = [model.Network(n, context, {}) for n in network_ports]
444
445         test_server._add_instance(mock_template, 'some-server',
446                                   networks, 'hints')
447         self.assertEqual(test_server.ports, {
448             'downlink_0': [{'port': 'xe1', 'stack_name': 'some-server-xe1-port'}],
449             'mgmt': [{'port': 'mgmt', 'stack_name': 'some-server-mgmt-port'}],
450             'uplink_0': [{'port': 'xe0', 'stack_name': 'some-server-xe0-port'},
451                          # this is not an error, we can produce this, it is left to Heat
452                          # to detect duplicate ports and error
453                          {'port': 'xe0', 'stack_name': 'some-server-xe0-port'}]
454         })
455
456     @mock.patch('yardstick.benchmark.contexts.heat.HeatTemplate')
457     def test__add_instance_with_user_data(self, mock_template):
458         user_data = "USER_DATA"
459         attrs = {
460             'image': 'some-image', 'flavor': 'some-flavor',
461             'user_data': user_data,
462         }
463         test_server = model.Server('foo', self.mock_context, attrs)
464
465         test_server._add_instance(mock_template, 'some-server',
466                                   [], 'hints')
467
468         mock_template.add_server.assert_called_with(
469             'some-server', 'some-image',
470             flavor='some-flavor',
471             flavors=self.mock_context.flavors,
472             ports=[],
473             user=self.mock_context.user,
474             key_name=self.mock_context.keypair_name,
475             user_data=user_data,
476             scheduler_hints='hints',
477             availability_zone=None)
478
479     @mock.patch('yardstick.benchmark.contexts.heat.HeatTemplate')
480     def test__add_instance_with_availablity_zone(self, mock_template):
481         attrs = {
482             'image': 'some-image', 'flavor': 'some-flavor',
483             'availability_zone': 'zone',
484         }
485         test_server = model.Server('foo', self.mock_context, attrs)
486
487         test_server._add_instance(mock_template, 'some-server',
488                                   [], 'hints')
489
490         mock_template.add_server.assert_called_with(
491             'some-server', 'some-image',
492             flavor='some-flavor',
493             flavors=self.mock_context.flavors,
494             ports=[],
495             user=self.mock_context.user,
496             key_name=self.mock_context.keypair_name,
497             user_data='',
498             scheduler_hints='hints',
499             availability_zone='zone')
500
501     @mock.patch('yardstick.benchmark.contexts.heat.HeatTemplate')
502     def test__add_instance_plus_flavor(self, mock_template):
503
504         user_data = ''
505         attrs = {
506             'image': 'some-image', 'flavor': 'flavor1',
507             'flavors': ['flavor2'], 'user_data': user_data
508         }
509         test_server = model.Server('ServerFlavor-2', self.mock_context, attrs)
510
511         self.mock_context.flavors = ['flavor2']
512         mock_network = mock.Mock()
513         mock_network.allowed_address_pairs = ["1", "2"]
514         mock_network.vnic_type = 'normal'
515         mock_network.net_flags = {}
516         mock_network.configure_mock(name='some-network', stack_name='some-network-stack',
517                                     subnet_stack_name='some-network-stack-subnet',
518                                     provider='some-provider')
519
520         test_server._add_instance(mock_template, 'ServerFlavor-2',
521                                   [mock_network], 'hints')
522
523         mock_template.add_port.assert_called_with(
524             'ServerFlavor-2-some-network-port',
525             mock_network,
526             provider=mock_network.provider,
527             sec_group_id=self.mock_context.secgroup_name,
528             allowed_address_pairs=mock_network.allowed_address_pairs)
529
530         mock_template.add_server.assert_called_with(
531             'ServerFlavor-2', 'some-image',
532             flavor='flavor1',
533             flavors=['flavor2'],
534             ports=['ServerFlavor-2-some-network-port'],
535             user=self.mock_context.user,
536             key_name=self.mock_context.keypair_name,
537             user_data=user_data,
538             scheduler_hints='hints',
539             availability_zone=None)
540
541     @mock.patch('yardstick.benchmark.contexts.heat.HeatTemplate')
542     def test__add_instance_misc(self, mock_template):
543
544         user_data = ''
545         attrs = {
546             'image': 'some-image', 'flavor': 'flavor1',
547             'flavors': ['flavor2'], 'user_data': user_data
548         }
549         test_server = model.Server('ServerFlavor-3', self.mock_context, attrs)
550
551         self.mock_context.flavors = ['flavor2']
552         self.mock_context.flavor = {'vcpus': 4}
553         mock_network = mock.Mock()
554         mock_network.name = 'some-network'
555         mock_network.stack_name = 'some-network-stack'
556         mock_network.subnet_stack_name = 'some-network-stack-subnet'
557         mock_network.net_flags = {}
558
559         test_server._add_instance(mock_template, 'ServerFlavor-3',
560                                   [mock_network], 'hints')
561
562         mock_template.add_port(
563             'ServerFlavor-3-some-network-port',
564             mock_network.stack_name,
565             mock_network.subnet_stack_name,
566             sec_group_id=self.mock_context.secgroup_name)
567
568         mock_template.add_flavor(
569             vcpus=4,
570             ram=2048,
571             disk=1)
572
573         mock_template.add_flavor(
574             vcpus=4,
575             ram=2048,
576             disk=1,
577             extra_specs={'cat': 1, 'dog': 2, 'dragon': 1000})
578
579         mock_template.add_server.assert_called_with(
580             'ServerFlavor-3', 'some-image',
581             flavor='flavor1',
582             flavors=['flavor2'],
583             ports=['ServerFlavor-3-some-network-port'],
584             user=self.mock_context.user,
585             key_name=self.mock_context.keypair_name,
586             user_data=user_data,
587             scheduler_hints='hints',
588             availability_zone=None)