RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-25 04:43:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1166 from ajarr/wip-17216

Browse Source 
tasks/cephfs : test recovery of partial auth update

Reviewed-by: John Spray <john.spray@redhat.com>
This commit is contained in:
John Spray 2016-10-19 15:18:52 +02:00 committed by GitHub
commit 5f3435e17b
1 changed files with 57 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
tasks/cephfs/test_volume_client.py
View File

@ -833,3 +833,60 @@ vc.disconnect()
volume_id=volume_id,
)))
self.assertNotIn(vol_metadata_filename, self.mounts[0].ls("volumes"))
def test_recover_metadata(self):
"""
That volume client can recover from partial auth updates using
metadata files, which store auth info and its update status info.
"""
volumeclient_mount = self.mounts[1]
volumeclient_mount.umount_wait()
# Configure volumeclient_mount as the handle for driving volumeclient.
self._configure_vc_auth(volumeclient_mount, "manila")
group_id = "groupid"
volume_id = "volumeid"
guestclient = {
"auth_id": "guest",
"tenant_id": "tenant",
}
# Create a volume.
self._volume_client_python(volumeclient_mount, dedent("""
vp = VolumePath("{group_id}", "{volume_id}")
vc.create_volume(vp, 1024*1024*10)
""".format(
group_id=group_id,
volume_id=volume_id,
)))
# Authorize 'guestclient' access to the volume.
self._volume_client_python(volumeclient_mount, dedent("""
vp = VolumePath("{group_id}", "{volume_id}")
vc.authorize(vp, "{auth_id}", tenant_id="{tenant_id}")
""".format(
group_id=group_id,
volume_id=volume_id,
auth_id=guestclient["auth_id"],
tenant_id=guestclient["tenant_id"]
)))
# Check that auth metadata file for auth ID 'guest' is created.
auth_metadata_filename = "${0}.meta".format(guestclient["auth_id"])
self.assertIn(auth_metadata_filename, self.mounts[0].ls("volumes"))
# Induce partial auth update state by modifying the auth metadata file,
# and then run recovery procedure.
self._volume_client_python(volumeclient_mount, dedent("""
vp = VolumePath("{group_id}", "{volume_id}")
auth_metadata = vc._auth_metadata_get("{auth_id}")
auth_metadata['dirty'] = True
vc._auth_metadata_set("{auth_id}", auth_metadata)
vc.recover()
""".format(
group_id=group_id,
volume_id=volume_id,
auth_id=guestclient["auth_id"],
)))