diff options
| author | Jenkins <jenkins@review.openstack.org> | 2012-08-15 07:55:57 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2012-08-15 07:55:57 +0000 |
| commit | efdc248d15cf2a0308b215dccb90d0b7da6926b7 (patch) | |
| tree | 0faad2bacdfd36ecfd3577f51597e3155c0c4131 /nova/tests | |
| parent | 9f9f1a7aa46fad83fdda36be15d648dfa21cba2f (diff) | |
| parent | 6972cd1e7eb1ec51f9ab4d94a842ebc45b655cc5 (diff) | |
Merge "Add support for NFS-based virtual block devices"
Diffstat (limited to 'nova/tests')
| -rw-r--r-- | nova/tests/test_libvirt.py | 26 |
1 files changed, 26 insertions, 0 deletions
diff --git a/nova/tests/test_libvirt.py b/nova/tests/test_libvirt.py index 781a68033..b1359323b 100644 --- a/nova/tests/test_libvirt.py +++ b/nova/tests/test_libvirt.py @@ -56,6 +56,7 @@ from nova.virt.libvirt import firewall from nova.virt.libvirt import imagebackend from nova.virt.libvirt import utils as libvirt_utils from nova.virt.libvirt import volume +from nova.virt.libvirt import volume_nfs from nova.volume import driver as volume_driver @@ -326,6 +327,31 @@ class LibvirtVolumeTestCase(test.TestCase): libvirt_driver.disconnect_volume(connection_info, mount_device) connection_info = vol_driver.terminate_connection(vol, self.connr) + def test_libvirt_nfs_driver(self): + # NOTE(vish) exists is to make driver assume connecting worked + mnt_base = '/mnt' + self.flags(nfs_mount_point_base=mnt_base) + + libvirt_driver = volume_nfs.NfsVolumeDriver(self.fake_conn) + export_string = '192.168.1.1:/nfs/share1' + name = 'volume-00001' + export_mnt_base = os.path.join(mnt_base, + libvirt_driver.get_hash_str(export_string)) + file_path = os.path.join(export_mnt_base, name) + + connection_info = {'data': {'export': export_string, 'name': name}} + mount_device = "vde" + conf = libvirt_driver.connect_volume(connection_info, mount_device) + tree = conf.format_dom() + self.assertEqual(tree.get('type'), 'file') + self.assertEqual(tree.find('./source').get('file'), file_path) + libvirt_driver.disconnect_volume(connection_info, mount_device) + + expected_commands = [ + ('stat', export_mnt_base), + ('mount', '-t', 'nfs', export_string, export_mnt_base)] + self.assertEqual(self.executes, expected_commands) + class CacheConcurrencyTestCase(test.TestCase): def setUp(self): |
