log.debug(f'command returned={res}')
return json.loads(res)
- def get_mirror_daemon_status(self, fs_name, fs_id):
- daemon_status = json.loads(self.mgr_cluster.mon_manager.raw_cluster_cmd("fs", "snapshot", "mirror", "daemon", "status", fs_name))
+ def get_mirror_daemon_status(self):
+ daemon_status = json.loads(self.mgr_cluster.mon_manager.raw_cluster_cmd("fs", "snapshot", "mirror", "daemon", "status"))
log.debug(f'daemon_status: {daemon_status}')
# running a single mirror daemon is supported
status = daemon_status[0]
self.peer_add(self.primary_fs_name, self.primary_fs_id, "client.mirror_remote@ceph", self.secondary_fs_name)
time.sleep(30)
- status = self.get_mirror_daemon_status(self.primary_fs_name, self.primary_fs_id)
+ status = self.get_mirror_daemon_status()
# assumption for this test: mirroring enabled for a single filesystem w/ single
# peer
self.add_directory(self.primary_fs_name, self.primary_fs_id, '/d0')
time.sleep(120)
- status = self.get_mirror_daemon_status(self.primary_fs_name, self.primary_fs_id)
+ status = self.get_mirror_daemon_status()
# we added one
peer = status['filesystems'][0]['peers'][0]
self.assertEquals(status['filesystems'][0]['directory_count'], 1)
self.mount_a.run_shell(["mkdir", "d0"])
time.sleep(120)
- status = self.get_mirror_daemon_status(self.primary_fs_name, self.primary_fs_id)
+ status = self.get_mirror_daemon_status()
peer = status['filesystems'][0]['peers'][0]
self.assertEquals(status['filesystems'][0]['directory_count'], 1)
# failure and recovery count should be reflected