self.getinfo(refresh = True)
+ def run_client_payload(self, cmd):
+ # avoid circular dep by importing here:
+ from tasks.cephfs.fuse_mount import FuseMount
+ d = misc.get_testdir(self._ctx)
+ m = FuseMount(self._ctx, {}, d, "admin", self.client_remote, cephfs_name=self.name)
+ m.mount()
+ m.run_shell_payload(cmd)
+ m.umount_wait(require_clean=True)
+
def destroy(self, reset_obj_attrs=True):
- log.info('Destroying file system ' + self.name + ' and related '
- 'pools')
+ log.info(f'Destroying file system {self.name} and related pools')
+
+ if self.dead():
+ log.debug('already dead...')
+ return
+ data_pools = self.get_data_pool_names(refresh=True)
+
# make sure no MDSs are attached to given FS.
self.mon_manager.raw_cluster_cmd('fs', 'fail', self.name)
self.mon_manager.raw_cluster_cmd(