summaryrefslogtreecommitdiffstats
path: root/nova/tests
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2012-08-15 07:55:57 +0000
committerGerrit Code Review <review@openstack.org>2012-08-15 07:55:57 +0000
commitefdc248d15cf2a0308b215dccb90d0b7da6926b7 (patch)
tree0faad2bacdfd36ecfd3577f51597e3155c0c4131 /nova/tests
parent9f9f1a7aa46fad83fdda36be15d648dfa21cba2f (diff)
parent6972cd1e7eb1ec51f9ab4d94a842ebc45b655cc5 (diff)
Merge "Add support for NFS-based virtual block devices"
Diffstat (limited to 'nova/tests')
-rw-r--r--nova/tests/test_libvirt.py26
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):