]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
test: pass peer uuid when adding cephfs mirror peers 40206/head
authorVenky Shankar <vshankar@redhat.com>
Tue, 16 Mar 2021 05:27:58 +0000 (01:27 -0400)
committerVenky Shankar <vshankar@redhat.com>
Tue, 23 Mar 2021 04:16:25 +0000 (09:46 +0530)
Fixes: http://tracker.ceph.com/issues/49822
Signed-off-by: Venky Shankar <vshankar@redhat.com>
(cherry picked from commit f27678280387bbde86db4a96e176d033965790ea)

qa/tasks/cephfs/test_admin.py

index 744f0fdcfc242f0331a0910923e938e406134dee..91c939490d46aac5f24f44e26a5c15c012b1822e 100644 (file)
@@ -1,4 +1,5 @@
 import json
+import uuid
 from io import StringIO
 from os.path import join as os_path_join
 
@@ -346,7 +347,8 @@ class TestMirroringCommands(CephFSTestCase):
         self.fs.mon_manager.raw_cluster_cmd("fs", "mirror", "disable", fs_name)
 
     def _add_peer(self, fs_name, peer_spec, remote_fs_name):
-        self.fs.mon_manager.raw_cluster_cmd("fs", "mirror", "peer_add", fs_name, peer_spec, remote_fs_name)
+        peer_uuid = str(uuid.uuid4())
+        self.fs.mon_manager.raw_cluster_cmd("fs", "mirror", "peer_add", fs_name, peer_uuid, peer_spec, remote_fs_name)
 
     def _remove_peer(self, fs_name, peer_uuid):
         self.fs.mon_manager.raw_cluster_cmd("fs", "mirror", "peer_remove", fs_name, peer_uuid)
@@ -366,12 +368,12 @@ class TestMirroringCommands(CephFSTestCase):
         fs_map = status.get_fsmap_byname(fs_name)
         mirror_info = fs_map.get('mirror_info', None)
         self.assertTrue(mirror_info is not None)
-        for uuid, remote in mirror_info['peers'].items():
+        for peer_uuid, remote in mirror_info['peers'].items():
             client_name = remote['remote']['client_name']
             cluster_name = remote['remote']['cluster_name']
             spec = f'{client_name}@{cluster_name}'
             if spec == peer_spec:
-                return uuid
+                return peer_uuid
         return None
 
     def test_mirroring_command(self):