except MirrorException as me:
return me.args[0], '', me.args[1]
- def daemon_status(self, filesystem):
+ def daemon_status(self):
try:
with self.lock:
- if not self.filesystem_exist(filesystem):
- raise MirrorException(-errno.ENOENT, f'filesystem {filesystem} does not exist')
- fspolicy = self.pool_policy.get(filesystem, None)
- if not fspolicy:
- raise MirrorException(-errno.EINVAL, f'filesystem {filesystem} is not mirrored')
daemons = []
sm = self.mgr.get('service_map')
daemon_entry = sm['services'].get('cephfs-mirror', None)
return self.fs_snapshot_mirror.show_distribution(fs_name)
@CLIReadCommand('fs snapshot mirror daemon status')
- def snapshot_mirror_daemon_status(self,
- fs_name: str):
+ def snapshot_mirror_daemon_status(self):
"""Get mirror daemon status"""
- return self.fs_snapshot_mirror.daemon_status(fs_name)
+ return self.fs_snapshot_mirror.daemon_status()