4 from mgr_module import CommandResult
5 from remote_view_cache import RemoteViewCache
8 class CephFSClients(RemoteViewCache):
9 def __init__(self, module_inst, fscid):
10 super(CephFSClients, self).__init__(module_inst)
15 mds_spec = "{0}:0".format(self.fscid)
16 result = CommandResult("")
17 self._module.send_command(result, "mds", mds_spec,
19 "prefix": "session ls",
22 r, outb, outs = result.wait()
23 # TODO handle nonzero returns, e.g. when rank isn't active
25 return json.loads(outb)