blob: ba419a6c4c7dbd719117871e71c79c95b2a08f0f [file] [log] [blame]
fujioka yuuichi636f8db2013-08-09 12:05:24 +09001# Licensed under the Apache License, Version 2.0 (the "License"); you may
2# not use this file except in compliance with the License. You may obtain
3# a copy of the License at
4#
5# http://www.apache.org/licenses/LICENSE-2.0
6#
7# Unless required by applicable law or agreed to in writing, software
8# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
9# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
10# License for the specific language governing permissions and limitations
11# under the License.
12
Doug Hellmann583ce2c2015-03-11 14:55:46 +000013from oslo_log import log
Matt Riedemannebaf2452015-08-31 07:12:51 -070014from tempest_lib import decorators
Matthew Treinishc49fcbe2015-02-05 23:37:34 -050015
Fei Long Wangd39431f2015-05-14 11:30:48 +120016from tempest.common.utils import data_utils
Ken'ichi Ohmichi0eb153c2015-07-13 02:18:25 +000017from tempest.common import waiters
Matthew Treinish6c072292014-01-29 19:15:52 +000018from tempest import config
fujioka yuuichi636f8db2013-08-09 12:05:24 +090019from tempest.scenario import manager
Masayuki Igawa4ded9f02014-02-17 15:05:59 +090020from tempest import test
fujioka yuuichi636f8db2013-08-09 12:05:24 +090021
Matthew Treinish6c072292014-01-29 19:15:52 +000022CONF = config.CONF
fujioka yuuichi636f8db2013-08-09 12:05:24 +090023
Nachi Ueno95b41282014-01-15 06:54:21 -080024LOG = log.getLogger(__name__)
25
26
Joseph Lanouxeef192f2014-08-01 14:32:53 +000027class TestVolumeBootPattern(manager.ScenarioTest):
fujioka yuuichi636f8db2013-08-09 12:05:24 +090028
29 """
30 This test case attempts to reproduce the following steps:
31
32 * Create in Cinder some bootable volume importing a Glance image
33 * Boot an instance from the bootable volume
34 * Write content to the volume
35 * Delete an instance and Boot a new instance from the volume
36 * Check written content in the instance
37 * Create a volume snapshot while the instance is running
38 * Boot an additional instance from the new snapshot based volume
39 * Check written content in the instance booted from snapshot
40 """
JordanPbce55532014-03-19 12:10:32 +010041 @classmethod
Emily Hugenbruch5e2d2a22015-02-25 21:35:45 +000042 def skip_checks(cls):
43 super(TestVolumeBootPattern, cls).skip_checks()
JordanPbce55532014-03-19 12:10:32 +010044 if not CONF.volume_feature_enabled.snapshot:
45 raise cls.skipException("Cinder volume snapshots are disabled")
fujioka yuuichi636f8db2013-08-09 12:05:24 +090046
47 def _create_volume_from_image(self):
Matthew Treinish6c072292014-01-29 19:15:52 +000048 img_uuid = CONF.compute.image_ref
Masayuki Igawa259c1132013-10-31 17:48:44 +090049 vol_name = data_utils.rand_name('volume-origin')
fujioka yuuichi636f8db2013-08-09 12:05:24 +090050 return self.create_volume(name=vol_name, imageRef=img_uuid)
51
Andrey Pavlovc8bd4b12015-08-17 10:20:17 +030052 def _get_bdm(self, vol_id, delete_on_termination=False):
fujioka yuuichi636f8db2013-08-09 12:05:24 +090053 # NOTE(gfidente): the syntax for block_device_mapping is
54 # dev_name=id:type:size:delete_on_terminate
55 # where type needs to be "snap" if the server is booted
56 # from a snapshot, size instead can be safely left empty
Joseph Lanouxeef192f2014-08-01 14:32:53 +000057 bd_map = [{
58 'device_name': 'vda',
59 'volume_id': vol_id,
Andrey Pavlovc8bd4b12015-08-17 10:20:17 +030060 'delete_on_termination': str(int(delete_on_termination))}]
61 return {'block_device_mapping': bd_map}
62
63 def _boot_instance_from_volume(self, vol_id, keypair=None,
64 security_group=None,
65 delete_on_termination=False):
66 create_kwargs = dict()
67 if keypair:
68 create_kwargs['key_name'] = keypair['name']
69 if security_group:
70 create_kwargs['security_groups'] = [
71 {'name': security_group['name']}]
72 create_kwargs.update(self._get_bdm(
73 vol_id, delete_on_termination=delete_on_termination))
Xavier Queralt249cac32014-03-05 13:51:39 +010074 return self.create_server(image='', create_kwargs=create_kwargs)
fujioka yuuichi636f8db2013-08-09 12:05:24 +090075
76 def _create_snapshot_from_volume(self, vol_id):
Masayuki Igawa259c1132013-10-31 17:48:44 +090077 snap_name = data_utils.rand_name('snapshot')
melanie witt87412222015-01-21 04:32:17 +000078 snap = self.snapshots_client.create_snapshot(
Joseph Lanouxeef192f2014-08-01 14:32:53 +000079 volume_id=vol_id,
80 force=True,
John Warrenff7faf62015-08-17 16:59:06 +000081 display_name=snap_name)['snapshot']
Yaroslav Lobankov46a78c32015-04-08 13:45:27 +030082 self.addCleanup(
83 self.snapshots_client.wait_for_resource_deletion, snap['id'])
84 self.addCleanup(self.snapshots_client.delete_snapshot, snap['id'])
Joseph Lanouxeef192f2014-08-01 14:32:53 +000085 self.snapshots_client.wait_for_snapshot_status(snap['id'], 'available')
Ivan Kolodyazhnybcfc32e2015-08-06 13:31:36 +030086
87 # NOTE(e0ne): Cinder API v2 uses name instead of display_name
88 if 'display_name' in snap:
89 self.assertEqual(snap_name, snap['display_name'])
90 else:
91 self.assertEqual(snap_name, snap['name'])
92
fujioka yuuichi636f8db2013-08-09 12:05:24 +090093 return snap
94
95 def _create_volume_from_snapshot(self, snap_id):
Masayuki Igawa259c1132013-10-31 17:48:44 +090096 vol_name = data_utils.rand_name('volume')
fujioka yuuichi636f8db2013-08-09 12:05:24 +090097 return self.create_volume(name=vol_name, snapshot_id=snap_id)
98
99 def _stop_instances(self, instances):
100 # NOTE(gfidente): two loops so we do not wait for the status twice
101 for i in instances:
Ken'ichi Ohmichib2631082015-08-27 01:31:00 +0000102 self.servers_client.stop_server(i['id'])
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900103 for i in instances:
Ken'ichi Ohmichi0eb153c2015-07-13 02:18:25 +0000104 waiters.wait_for_server_status(self.servers_client,
105 i['id'], 'SHUTOFF')
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900106
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900107 def _ssh_to_server(self, server, keypair):
Matthew Treinish6c072292014-01-29 19:15:52 +0000108 if CONF.compute.use_floatingip_for_ssh:
Matt Riedemann3ed09042015-09-01 10:48:24 -0700109 ip = self.create_floating_ip(server)['ip']
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900110 else:
Yaroslav Lobankovfc997072015-07-27 11:57:49 +0300111 ip = server
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900112
JordanP3fe2dc32014-11-17 13:06:01 +0100113 return self.get_remote_client(ip, private_key=keypair['private_key'],
114 log_console_of_servers=[server])
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900115
116 def _get_content(self, ssh_client):
117 return ssh_client.exec_command('cat /tmp/text')
118
119 def _write_text(self, ssh_client):
Ken'ichi Ohmichi07308f12015-03-23 00:24:28 +0000120 text = data_utils.rand_name('text')
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900121 ssh_client.exec_command('echo "%s" > /tmp/text; sync' % (text))
122
123 return self._get_content(ssh_client)
124
125 def _delete_server(self, server):
Joseph Lanouxeef192f2014-08-01 14:32:53 +0000126 self.servers_client.delete_server(server['id'])
Ken'ichi Ohmichie91a0c62015-08-13 02:09:16 +0000127 waiters.wait_for_server_termination(self.servers_client, server['id'])
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900128
129 def _check_content_of_written_file(self, ssh_client, expected):
130 actual = self._get_content(ssh_client)
131 self.assertEqual(expected, actual)
132
Chris Hoge7579c1a2015-02-26 14:12:15 -0800133 @test.idempotent_id('557cd2c2-4eb8-4dce-98be-f86765ff311b')
Sean Dague3c634d12015-04-27 12:09:19 -0400134 @test.attr(type='smoke')
Masayuki Igawa4ded9f02014-02-17 15:05:59 +0900135 @test.services('compute', 'volume', 'image')
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900136 def test_volume_boot_pattern(self):
137 keypair = self.create_keypair()
Yaroslav Lobankov0089af52015-07-02 19:14:40 +0300138 security_group = self._create_security_group()
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900139
140 # create an instance from volume
141 volume_origin = self._create_volume_from_image()
Joseph Lanouxeef192f2014-08-01 14:32:53 +0000142 instance_1st = self._boot_instance_from_volume(volume_origin['id'],
Yaroslav Lobankov0089af52015-07-02 19:14:40 +0300143 keypair, security_group)
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900144
145 # write content to volume on instance
146 ssh_client_for_instance_1st = self._ssh_to_server(instance_1st,
147 keypair)
148 text = self._write_text(ssh_client_for_instance_1st)
149
150 # delete instance
151 self._delete_server(instance_1st)
152
153 # create a 2nd instance from volume
Joseph Lanouxeef192f2014-08-01 14:32:53 +0000154 instance_2nd = self._boot_instance_from_volume(volume_origin['id'],
Yaroslav Lobankov0089af52015-07-02 19:14:40 +0300155 keypair, security_group)
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900156
157 # check the content of written file
158 ssh_client_for_instance_2nd = self._ssh_to_server(instance_2nd,
159 keypair)
160 self._check_content_of_written_file(ssh_client_for_instance_2nd, text)
161
162 # snapshot a volume
Joseph Lanouxeef192f2014-08-01 14:32:53 +0000163 snapshot = self._create_snapshot_from_volume(volume_origin['id'])
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900164
165 # create a 3rd instance from snapshot
Joseph Lanouxeef192f2014-08-01 14:32:53 +0000166 volume = self._create_volume_from_snapshot(snapshot['id'])
Yaroslav Lobankov0089af52015-07-02 19:14:40 +0300167 instance_from_snapshot = (
168 self._boot_instance_from_volume(volume['id'],
169 keypair, security_group))
fujioka yuuichi636f8db2013-08-09 12:05:24 +0900170
171 # check the content of written file
172 ssh_client = self._ssh_to_server(instance_from_snapshot, keypair)
173 self._check_content_of_written_file(ssh_client, text)
174
175 # NOTE(gfidente): ensure resources are in clean state for
176 # deletion operations to succeed
177 self._stop_instances([instance_2nd, instance_from_snapshot])
Nikola Dipanov7cff03f2014-03-12 14:06:25 +0100178
Matt Riedemannebaf2452015-08-31 07:12:51 -0700179 @decorators.skip_because(bug='1489581')
Andrey Pavlovc8bd4b12015-08-17 10:20:17 +0300180 @test.idempotent_id('36c34c67-7b54-4b59-b188-02a2f458a63b')
181 @test.services('compute', 'volume', 'image')
182 def test_create_ebs_image_and_check_boot(self):
183 # create an instance from volume
184 volume_origin = self._create_volume_from_image()
185 instance = self._boot_instance_from_volume(volume_origin['id'],
186 delete_on_termination=True)
187 # create EBS image
188 name = data_utils.rand_name('image')
189 image = self.create_server_snapshot(instance, name=name)
190
191 # delete instance
192 self._delete_server(instance)
193
194 # boot instance from EBS image
195 instance = self.create_server(image=image['id'])
196 # just ensure that instance booted
197
198 # delete instance
199 self._delete_server(instance)
200
Nikola Dipanov7cff03f2014-03-12 14:06:25 +0100201
202class TestVolumeBootPatternV2(TestVolumeBootPattern):
Andrey Pavlovc8bd4b12015-08-17 10:20:17 +0300203 def _get_bdm(self, vol_id, delete_on_termination=False):
Yaroslav Lobankov0089af52015-07-02 19:14:40 +0300204 bd_map_v2 = [{
205 'uuid': vol_id,
206 'source_type': 'volume',
207 'destination_type': 'volume',
208 'boot_index': 0,
Andrey Pavlovc8bd4b12015-08-17 10:20:17 +0300209 'delete_on_termination': delete_on_termination}]
210 return {'block_device_mapping_v2': bd_map_v2}