shaba/lvm2
1
0
Fork 0
mirror of git://sourceware.org/git/lvm2.git synced 2025-01-03 05:18:29 +03:00
Code Releases Activity

lvmdbustest.py: Verify lookups work immediately after vg create

Browse Source
This commit is contained in:
Tony Asleson 2017-03-01 11:09:51 -06:00
parent 157948b5a5
commit 10c3d94159
1 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
test/dbus/lvmdbustest.py
View File

@ -229,6 +229,7 @@ class TestDbusService(unittest.TestCase):
dbus.Int32(g_tmo), dbus.Int32(g_tmo),
EOD)) EOD))
self._validate_vg_lookup(vg_name, vg_path)
self.assertTrue(vg_path is not None and len(vg_path) > 0) self.assertTrue(vg_path is not None and len(vg_path) > 0)
return ClientProxy(self.bus, vg_path, interfaces=(VG_INT, )) return ClientProxy(self.bus, vg_path, interfaces=(VG_INT, ))
@ -342,6 +343,10 @@ class TestDbusService(unittest.TestCase):
return self.objs[MANAGER_INT][0].\ return self.objs[MANAGER_INT][0].\
Manager.LookUpByLvmId(dbus.String(lvm_id)) Manager.LookUpByLvmId(dbus.String(lvm_id))
def _validate_vg_lookup(self, vg_name, object_path):
t = self._lookup(vg_name)
self.assertTrue(object_path == t, "%s != %s" % (object_path, t))
def test_lookup_by_lvm_id(self): def test_lookup_by_lvm_id(self):
# For the moment lets just lookup what we know about which is PVs # For the moment lets just lookup what we know about which is PVs
# When we start testing VGs and LVs we will test lookups for those # When we start testing VGs and LVs we will test lookups for those
@ -926,7 +931,8 @@ class TestDbusService(unittest.TestCase):
self.assertTrue(vg_path == '/') self.assertTrue(vg_path == '/')
self.assertTrue(vg_job and len(vg_job) > 0) self.assertTrue(vg_job and len(vg_job) > 0)
self._wait_for_job(vg_job) vg_path = self._wait_for_job(vg_job)
self._validate_vg_lookup(vg_name, vg_path)
def _test_expired_timer(self, num_lvs): def _test_expired_timer(self, num_lvs):
rc = False rc = False
@ -1508,12 +1514,14 @@ class TestDbusService(unittest.TestCase):
EOD)) EOD))
# Create a VG and try to create LVs with different bad names # Create a VG and try to create LVs with different bad names
vg_name = vg_n()
vg_path = self.handle_return( vg_path = self.handle_return(
mgr.VgCreate( mgr.VgCreate(
dbus.String(vg_n()), dbus.String(vg_name),
dbus.Array(pv_paths, 'o'), dbus.Array(pv_paths, 'o'),
dbus.Int32(g_tmo), dbus.Int32(g_tmo),
EOD)) EOD))
self._validate_vg_lookup(vg_name, vg_path)
vg_proxy = ClientProxy(self.bus, vg_path, interfaces=(VG_INT, )) vg_proxy = ClientProxy(self.bus, vg_path, interfaces=(VG_INT, ))
@ -1559,13 +1567,16 @@ class TestDbusService(unittest.TestCase):
def test_invalid_tags(self): def test_invalid_tags(self):
mgr = self.objs[MANAGER_INT][0].Manager mgr = self.objs[MANAGER_INT][0].Manager
pv_paths = [self.objs[PV_INT][0].object_path] pv_paths = [self.objs[PV_INT][0].object_path]
vg_name = vg_n()
vg_path = self.handle_return( vg_path = self.handle_return(
mgr.VgCreate( mgr.VgCreate(
dbus.String(vg_n()), dbus.String(vg_name),
dbus.Array(pv_paths, 'o'), dbus.Array(pv_paths, 'o'),
dbus.Int32(g_tmo), dbus.Int32(g_tmo),
EOD)) EOD))
self._validate_vg_lookup(vg_name, vg_path)
vg_proxy = ClientProxy(self.bus, vg_path, interfaces=(VG_INT, )) vg_proxy = ClientProxy(self.bus, vg_path, interfaces=(VG_INT, ))
for c in self._invalid_tag_characters(): for c in self._invalid_tag_characters():
@ -1587,13 +1598,15 @@ class TestDbusService(unittest.TestCase):
def test_tag_names(self): def test_tag_names(self):
mgr = self.objs[MANAGER_INT][0].Manager mgr = self.objs[MANAGER_INT][0].Manager
pv_paths = [self.objs[PV_INT][0].object_path] pv_paths = [self.objs[PV_INT][0].object_path]
vg_name = vg_n()
vg_path = self.handle_return( vg_path = self.handle_return(
mgr.VgCreate( mgr.VgCreate(
dbus.String(vg_n()), dbus.String(vg_name),
dbus.Array(pv_paths, 'o'), dbus.Array(pv_paths, 'o'),
dbus.Int32(g_tmo), dbus.Int32(g_tmo),
EOD)) EOD))
self._validate_vg_lookup(vg_name, vg_path)
vg_proxy = ClientProxy(self.bus, vg_path, interfaces=(VG_INT, )) vg_proxy = ClientProxy(self.bus, vg_path, interfaces=(VG_INT, ))
for i in range(1, 64): for i in range(1, 64):
@ -1618,13 +1631,15 @@ class TestDbusService(unittest.TestCase):
def test_tag_regression(self): def test_tag_regression(self):
mgr = self.objs[MANAGER_INT][0].Manager mgr = self.objs[MANAGER_INT][0].Manager
pv_paths = [self.objs[PV_INT][0].object_path] pv_paths = [self.objs[PV_INT][0].object_path]
vg_name = vg_n()
vg_path = self.handle_return( vg_path = self.handle_return(
mgr.VgCreate( mgr.VgCreate(
dbus.String(vg_n()), dbus.String(vg_name),
dbus.Array(pv_paths, 'o'), dbus.Array(pv_paths, 'o'),
dbus.Int32(g_tmo), dbus.Int32(g_tmo),
EOD)) EOD))
self._validate_vg_lookup(vg_name, vg_path)
vg_proxy = ClientProxy(self.bus, vg_path, interfaces=(VG_INT, )) vg_proxy = ClientProxy(self.bus, vg_path, interfaces=(VG_INT, ))
tag = '--h/K.6g0A4FOEatf3+k_nI/Yp&L_u2oy-=j649x:+dUcYWPEo6.IWT0c' tag = '--h/K.6g0A4FOEatf3+k_nI/Yp&L_u2oy-=j649x:+dUcYWPEo6.IWT0c'