Signed-off-by: Jan Fajerski <jfajerski@suse.com>
self.stopping = Event()
self.connection_pool = CephfsConnectionPool(self.mgr)
+ def is_stopping(self):
+ return self.stopping.is_set()
+
def shutdown(self):
logger.info("shutting down")
# first, note that we're shutting down
self.cloner.queue_job(fs['mdsmap']['fs_name'])
self.purge_queue.queue_job(fs['mdsmap']['fs_name'])
- def is_stopping(self):
- return self.stopping.is_set()
-
def shutdown(self):
# Overrides CephfsClient.shutdown()
log.info("shutting down")