self.pseudo_path = "/cephfs"
self.path = "/"
self.fs_name = "nfs-cephfs"
- self.expected_name = "nfs.ganesha-test"
+ self.expected_name = "nfs.test"
self.sample_export = {
"export_id": 1,
"path": self.path,
# Disable any running nfs ganesha daemon
self._check_nfs_server_status()
self._nfs_cmd('cluster', 'create', self.export_type, self.cluster_id)
- # Check for expected status and daemon name (nfs.ganesha-<cluster_id>)
+ # Check for expected status and daemon name (nfs.<cluster_id>)
self._check_nfs_cluster_status('running', 'NFS Ganesha cluster deployment failed')
def _test_delete_cluster(self):
'set', self.cluster_id, '-i', '-'], stdin=config)
time.sleep(30)
res = self._sys_cmd(['rados', '-p', pool, '-N', self.cluster_id, 'get',
- f'userconf-nfs.ganesha-{user_id}', '-'])
+ f'userconf-nfs.{user_id}', '-'])
self.assertEqual(config, res.decode('utf-8'))
self._test_mnt(pseudo_path, port, ip)
self._nfs_cmd('cluster', 'config', 'reset', self.cluster_id)
def available_clusters(mgr):
'''
This method returns list of available cluster ids.
- It removes 'ganesha-' prefixes from cluster service id returned by cephadm.
+ Service name is service_type.service_id
Example:
completion.result value:
- <ServiceDescription of <NFSServiceSpec for service_name=nfs.ganesha-vstart>>
- return value: ['ganesha-vstart'] -> ['vstart']
+ <ServiceDescription of <NFSServiceSpec for service_name=nfs.vstart>>
+ return value: ['vstart']
'''
# TODO check cephadm cluster list with rados pool conf objects
completion = mgr.describe_service(service_type='nfs')
mgr._orchestrator_wait([completion])
orchestrator.raise_if_exception(completion)
- return [cluster.spec.service_id.replace('ganesha-', '', 1) for cluster in completion.result
+ return [cluster.spec.service_id for cluster in completion.result
if cluster.spec.service_id]
def _save_export(self, export):
self.exports[self.rados_namespace].append(export)
NFSRados(self.mgr, self.rados_namespace).write_obj(export.to_export_block(),
- f'export-{export.export_id}', f'conf-nfs.ganesha-{export.cluster_id}')
+ f'export-{export.export_id}', f'conf-nfs.{export.cluster_id}')
def _delete_export(self, cluster_id, pseudo_path, export_obj=None):
try:
if export:
if pseudo_path:
NFSRados(self.mgr, self.rados_namespace).remove_obj(
- f'export-{export.export_id}', f'conf-nfs.ganesha-{cluster_id}')
+ f'export-{export.export_id}', f'conf-nfs.{cluster_id}')
self.exports[cluster_id].remove(export)
self._delete_user(export.fsal.user_id)
if not self.exports[cluster_id]:
self.mgr = mgr
def _set_cluster_id(self, cluster_id):
- self.cluster_id = f"ganesha-{cluster_id}"
+ self.cluster_id = cluster_id
def _set_pool_namespace(self, cluster_id):
self.pool_ns = cluster_id