From: ManasviGoyal Date: Mon, 27 Sep 2021 17:44:26 +0000 (+0530) Subject: mgr/volumes/fs: add extra blank line X-Git-Tag: v17.1.0~773^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F43322%2Fhead;p=ceph.git mgr/volumes/fs: add extra blank line Fixes: https://tracker.ceph.com/issues/51387 Signed-off-by: Manasvi Goyal --- diff --git a/src/pybind/mgr/volumes/fs/purge_queue.py b/src/pybind/mgr/volumes/fs/purge_queue.py index d67ef9af373..d444daa91c3 100644 --- a/src/pybind/mgr/volumes/fs/purge_queue.py +++ b/src/pybind/mgr/volumes/fs/purge_queue.py @@ -16,6 +16,7 @@ from .operations.trash import open_trashcan log = logging.getLogger(__name__) + # helper for fetching a trash entry for a given volume def get_trash_entry_for_volume(fs_client, volspec, volname, running_jobs): log.debug("fetching trash entry for volume '{0}'".format(volname)) @@ -34,6 +35,7 @@ def get_trash_entry_for_volume(fs_client, volspec, volname, running_jobs): log.error("error fetching trash entry for volume '{0}' ({1})".format(volname, ve)) return ve.errno, None + def subvolume_purge(fs_client, volspec, volname, trashcan, subvolume_trash_entry, should_cancel): groupname, subvolname = resolve_trash(volspec, subvolume_trash_entry.decode('utf-8')) log.debug("subvolume resolved to {0}/{1}".format(groupname, subvolname)) @@ -53,6 +55,7 @@ def subvolume_purge(fs_client, volspec, volname, trashcan, subvolume_trash_entry if not ve.errno == -errno.ENOENT: raise + # helper for starting a purge operation on a trash entry def purge_trash_entry_for_volume(fs_client, volspec, volname, purge_entry, should_cancel): log.debug("purging trash entry '{0}' for volume '{1}'".format(purge_entry, volname)) @@ -90,6 +93,7 @@ def purge_trash_entry_for_volume(fs_client, volspec, volname, purge_entry, shoul ret = ve.errno return ret + class ThreadPoolPurgeQueueMixin(AsyncJobs): """ Purge queue mixin class maintaining a pool of threads for purging trash entries.