Increase the size of the pool
"""
pool = self.ceph_manager.get_pool()
+ if pool is None:
+ return
self.log("Growing pool %s" % (pool,))
if self.ceph_manager.expand_pool(pool,
self.config.get('pool_grow_by', 10),
Decrease the size of the pool
"""
pool = self.ceph_manager.get_pool()
+ if pool is None:
+ return
_ = self.ceph_manager.get_pool_pg_num(pool)
self.log("Shrinking pool %s" % (pool,))
if self.ceph_manager.contract_pool(
Pick a random pool
"""
with self.lock:
- return random.choice(self.pools.keys())
+ if self.pools:
+ return random.choice(self.pools.keys())
def get_pool_pg_num(self, pool_name):
"""