if mdss.remotes:
log.info('Setting up CephFS filesystem...')
- fs = Filesystem(ctx, name='cephfs', create=True,
- ec_profile=config.get('cephfs_ec_profile', None))
-
- cephfs_conf = config['cephfs']
- max_mds = config_conf.get('max_mds', 1)
- if max_mds > 1:
- fs.set_max_mds(max_mds)
+ Filesystem(ctx, fs_config=config.get('cephfs', None), name='cephfs',
+ create=True, ec_profile=config.get('cephfs_ec_profile', None))
yield
This object is for driving a CephFS filesystem. The MDS daemons driven by
MDSCluster may be shared with other Filesystems.
"""
- def __init__(self, ctx, fscid=None, name=None, create=False,
+ def __init__(self, ctx, fs_config=None, fscid=None, name=None, create=False,
ec_profile=None):
super(Filesystem, self).__init__(ctx)
self.metadata_overlay = False
self.data_pool_name = None
self.data_pools = None
+ self.fs_config = fs_config
client_list = list(misc.all_roles_of_type(self._ctx.cluster, 'client'))
self.client_id = client_list[0]
else:
raise
+ if self.fs_config is not None:
+ max_mds = self.fs_config.get('max_mds', 1)
+ if max_mds > 1:
+ self.set_max_mds(max_mds)
+
self.getinfo(refresh = True)
def destroy(self, reset_obj_attrs=True):