From 254e37ab3c995f6514084d38f2f797da9cf5e5a9 Mon Sep 17 00:00:00 2001 From: Zhiteng Huang Date: Wed, 11 Dec 2013 21:46:38 +0800 Subject: [PATCH] Add AllocatedCapacityWeigher AllocatedCapacityWeigher is a weigher that weigh hosts by their allocated capacity. The main purpose of this weigher is to simulate the SimpleScheduler's behavior, which sorts hosts by the size of all volumes on them. So by allocated capacity, it equals to the sum of size of all volumes on target host. In order to keep track of 'allocated' capacity, host state is updated to add a 'allocated_capacity_gb' attribute to record the value, which means each back-end must report one extra stats to scheduler. Fortunately, the 'allocated' capacity we are interested in here is pure Cinder level capacity, the volume manager can take all the burden to calculate this value without having to query back-ends. The volume manager does the initial calculation in init_host() by the time when it has to query all existing volumes from DB for ensure_export(). After initial calculation, volume manager/scheduler will keep track of every new request that changes 'allocated_capacity' and make sure this value is up to date. !DriverImpact! Cinder driver developers, please read on: This patch contains a change that might IMPACT volume drivers: volume manager now uses 'stats' attribute to save 'allocated_capacity_gb'. And this information will be merged with those stats drivers provide as a whole for scheduler to consume. If you plan to report any form of allocated space other than the apparent Cinder level value, (e.g. actual capacity allocated), Please choose a key name other than 'allocated_capacity_gb', otherwise it will *OVERWRITE* the value volume manager has calculated and confuse scheduler. Partially implements bp: deprecate-chance-and-simple-schedulers Change-Id: I306230b8973c2d1ad77bcab14ccde68e997ea816 --- cinder/scheduler/host_manager.py | 6 ++ cinder/scheduler/weights/capacity.py | 30 +++++- .../tests/api/contrib/test_admin_actions.py | 36 ++++---- cinder/tests/scheduler/fakes.py | 6 +- .../test_allocated_capacity_weigher.py | 92 +++++++++++++++++++ .../tests/scheduler/test_capacity_weigher.py | 6 +- cinder/tests/test_gpfs.py | 1 + cinder/tests/test_rbd.py | 1 + cinder/tests/test_volume.py | 1 + cinder/volume/manager.py | 15 ++- etc/cinder/cinder.conf.sample | 4 + setup.cfg | 1 + 12 files changed, 176 insertions(+), 23 deletions(-) create mode 100644 cinder/tests/scheduler/test_allocated_capacity_weigher.py diff --git a/cinder/scheduler/host_manager.py b/cinder/scheduler/host_manager.py index 7cb8adfad..cfcbfcfa0 100644 --- a/cinder/scheduler/host_manager.py +++ b/cinder/scheduler/host_manager.py @@ -99,6 +99,9 @@ class HostState(object): # Mutable available resources. # These will change as resources are virtually "consumed". self.total_capacity_gb = 0 + # capacity has been allocated in cinder POV, which should be + # sum(vol['size'] for vol in vols_on_hosts) + self.allocated_capacity_gb = 0 self.free_capacity_gb = None self.reserved_percentage = 0 @@ -128,6 +131,8 @@ class HostState(object): self.total_capacity_gb = capability['total_capacity_gb'] self.free_capacity_gb = capability['free_capacity_gb'] + self.allocated_capacity_gb = capability.get( + 'allocated_capacity_gb', 0) self.reserved_percentage = capability['reserved_percentage'] self.updated = capability['timestamp'] @@ -135,6 +140,7 @@ class HostState(object): def consume_from_volume(self, volume): """Incrementally update host state from an volume.""" volume_gb = volume['size'] + self.allocated_capacity_gb += volume_gb if self.free_capacity_gb == 'infinite': # There's virtually infinite space on back-end pass diff --git a/cinder/scheduler/weights/capacity.py b/cinder/scheduler/weights/capacity.py index 98d3d5c82..d4f20b5e3 100644 --- a/cinder/scheduler/weights/capacity.py +++ b/cinder/scheduler/weights/capacity.py @@ -1,3 +1,4 @@ +# Copyright (c) 2013 eBay Inc. # Copyright (c) 2012 OpenStack Foundation # All Rights Reserved. # @@ -13,11 +14,22 @@ # License for the specific language governing permissions and limitations # under the License. """ -Capacity Weigher. Weigh hosts by their available capacity. +Weighers that weigh hosts by their capacity, including following two +weighers: + +1. Capacity Weigher. Weigh hosts by their available capacity. The default is to spread volumes across all hosts evenly. If you prefer stacking, you can set the 'capacity_weight_multiplier' option to a negative number and the weighing has the opposite effect of the default. + +2. Allocated Capacity Weigher. Weigh hosts by their allocated capacity. + +The default behavior is to place new volume to the host allocated the least +space. This weigher is intended to simulate the behavior of SimpleScheduler. +If you prefer to place volumes to host allocated the most space, you can +set the 'allocated_capacity_weight_multiplier' option to a postive number +and the weighing has the opposite effect of the default. """ @@ -33,6 +45,10 @@ capacity_weight_opts = [ default=1.0, help='Multiplier used for weighing volume capacity. ' 'Negative numbers mean to stack vs spread.'), + cfg.FloatOpt('allocated_capacity_weight_multiplier', + default=-1.0, + help='Multiplier used for weighing volume capacity. ' + 'Negative numbers mean to stack vs spread.'), ] CONF = cfg.CONF @@ -55,3 +71,15 @@ class CapacityWeigher(weights.BaseHostWeigher): else: free = math.floor(host_state.free_capacity_gb * (1 - reserved)) return free + + +class AllocatedCapacityWeigher(weights.BaseHostWeigher): + def _weight_multiplier(self): + """Override the weight multiplier.""" + return CONF.allocated_capacity_weight_multiplier + + def _weigh_object(self, host_state, weight_properties): + # Higher weights win. We want spreading (choose host with lowest + # allocated_capacity first) to be the default. + allocated_space = host_state.allocated_capacity_gb + return allocated_space diff --git a/cinder/tests/api/contrib/test_admin_actions.py b/cinder/tests/api/contrib/test_admin_actions.py index b5b46b68f..addf22b24 100644 --- a/cinder/tests/api/contrib/test_admin_actions.py +++ b/cinder/tests/api/contrib/test_admin_actions.py @@ -76,7 +76,7 @@ class AdminActionsTest(test.TestCase): def test_reset_status_as_non_admin(self): # current status is 'error' volume = db.volume_create(context.get_admin_context(), - {'status': 'error'}) + {'status': 'error', 'size': 1}) req = webob.Request.blank('/v2/fake/volumes/%s/action' % volume['id']) req.method = 'POST' req.headers['content-type'] = 'application/json' @@ -96,7 +96,7 @@ class AdminActionsTest(test.TestCase): # admin context ctx = context.RequestContext('admin', 'fake', True) # current status is available - volume = db.volume_create(ctx, {'status': 'available'}) + volume = db.volume_create(ctx, {'status': 'available', 'size': 1}) req = webob.Request.blank('/v2/fake/volumes/%s/action' % volume['id']) req.method = 'POST' req.headers['content-type'] = 'application/json' @@ -115,7 +115,7 @@ class AdminActionsTest(test.TestCase): # admin context ctx = context.RequestContext('admin', 'fake', True) # current status is available - volume = db.volume_create(ctx, {'status': 'available'}) + volume = db.volume_create(ctx, {'status': 'available', 'size': 1}) req = webob.Request.blank('/v2/fake/volumes/%s/action' % volume['id']) req.method = 'POST' req.headers['content-type'] = 'application/json' @@ -153,7 +153,8 @@ class AdminActionsTest(test.TestCase): # admin context ctx = context.RequestContext('admin', 'fake', True) # current status is available - volume = db.volume_create(ctx, {'status': 'available', + volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', + 'provider_location': '', 'size': 1, 'attach_status': 'attached'}) req = webob.Request.blank('/v2/fake/volumes/%s/action' % volume['id']) req.method = 'POST' @@ -177,7 +178,8 @@ class AdminActionsTest(test.TestCase): # admin context ctx = context.RequestContext('admin', 'fake', True) # current status is available - volume = db.volume_create(ctx, {'status': 'available', + volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', + 'provider_location': '', 'size': 1, 'attach_status': 'detached'}) req = webob.Request.blank('/v2/fake/volumes/%s/action' % volume['id']) req.method = 'POST' @@ -200,7 +202,8 @@ class AdminActionsTest(test.TestCase): # admin context ctx = context.RequestContext('admin', 'fake', True) # snapshot in 'error_deleting' - volume = db.volume_create(ctx, {}) + volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', + 'provider_location': '', 'size': 1}) snapshot = db.snapshot_create(ctx, {'status': 'error_deleting', 'volume_id': volume['id']}) req = webob.Request.blank('/v2/fake/snapshots/%s/action' % @@ -222,7 +225,8 @@ class AdminActionsTest(test.TestCase): # admin context ctx = context.RequestContext('admin', 'fake', True) # snapshot in 'available' - volume = db.volume_create(ctx, {}) + volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', + 'provider_location': '', 'size': 1}) snapshot = db.snapshot_create(ctx, {'status': 'available', 'volume_id': volume['id']}) req = webob.Request.blank('/v2/fake/snapshots/%s/action' % @@ -245,7 +249,7 @@ class AdminActionsTest(test.TestCase): # admin context ctx = context.RequestContext('admin', 'fake', True) # current status is creating - volume = db.volume_create(ctx, {'status': 'creating'}) + volume = db.volume_create(ctx, {'size': 1}) req = webob.Request.blank('/v2/fake/volumes/%s/action' % volume['id']) req.method = 'POST' req.headers['content-type'] = 'application/json' @@ -263,7 +267,7 @@ class AdminActionsTest(test.TestCase): # admin context ctx = context.RequestContext('admin', 'fake', True) # current status is creating - volume = db.volume_create(ctx, {'host': 'test'}) + volume = db.volume_create(ctx, {'host': 'test', 'size': 1}) snapshot = db.snapshot_create(ctx, {'status': 'creating', 'volume_size': 1, 'volume_id': volume['id']}) @@ -291,7 +295,7 @@ class AdminActionsTest(test.TestCase): ctx = context.RequestContext('admin', 'fake', True) # current status is available volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', - 'provider_location': ''}) + 'provider_location': '', 'size': 1}) connector = {'initiator': 'iqn.2012-07.org.fake:01'} # start service to handle rpc messages for attach requests svc = self.start_service('volume', host='test') @@ -346,7 +350,7 @@ class AdminActionsTest(test.TestCase): ctx = context.RequestContext('admin', 'fake', True) # current status is available volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', - 'provider_location': ''}) + 'provider_location': '', 'size': 1}) connector = {'initiator': 'iqn.2012-07.org.fake:01'} # start service to handle rpc messages for attach requests svc = self.start_service('volume', host='test') @@ -402,7 +406,7 @@ class AdminActionsTest(test.TestCase): ctx = context.RequestContext('admin', 'fake', True) # current status is available volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', - 'provider_location': ''}) + 'provider_location': '', 'size': 1}) connector = {'initiator': 'iqn.2012-07.org.fake:01'} # start service to handle rpc messages for attach requests svc = self.start_service('volume', host='test') @@ -438,7 +442,7 @@ class AdminActionsTest(test.TestCase): ctx = context.RequestContext('admin', 'fake', True) # current status is available volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', - 'provider_location': ''}) + 'provider_location': '', 'size': 1}) connector = {'initiator': 'iqn.2012-07.org.fake:01'} # start service to handle rpc messages for attach requests svc = self.start_service('volume', host='test') @@ -474,7 +478,7 @@ class AdminActionsTest(test.TestCase): ctx = context.RequestContext('admin', 'fake', True) # current status is available volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', - 'provider_location': ''}) + 'provider_location': '', 'size': 1}) connector = {} # start service to handle rpc messages for attach requests svc = self.start_service('volume', host='test') @@ -489,7 +493,7 @@ class AdminActionsTest(test.TestCase): ctx = context.RequestContext('admin', 'fake', True) # current status is available volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', - 'provider_location': ''}) + 'provider_location': '', 'size': 1}) # start service to handle rpc messages for attach requests svc = self.start_service('volume', host='test') values = {'status': 'attaching', @@ -513,7 +517,7 @@ class AdminActionsTest(test.TestCase): ctx = context.RequestContext('admin', 'fake', True) # current status is available volume = db.volume_create(ctx, {'status': 'available', 'host': 'test', - 'provider_location': ''}) + 'provider_location': '', 'size': 1}) # start service to handle rpc messages for attach requests svc = self.start_service('volume', host='test') values = {'status': 'attaching', diff --git a/cinder/tests/scheduler/fakes.py b/cinder/tests/scheduler/fakes.py index 4abc6f269..178b22fdc 100644 --- a/cinder/tests/scheduler/fakes.py +++ b/cinder/tests/scheduler/fakes.py @@ -34,18 +34,22 @@ class FakeHostManager(host_manager.HostManager): self.service_states = { 'host1': {'total_capacity_gb': 1024, 'free_capacity_gb': 1024, + 'allocated_capacity_gb': 0, 'reserved_percentage': 10, 'timestamp': None}, 'host2': {'total_capacity_gb': 2048, 'free_capacity_gb': 300, + 'allocated_capacity_gb': 1748, 'reserved_percentage': 10, 'timestamp': None}, 'host3': {'total_capacity_gb': 512, - 'free_capacity_gb': 512, + 'free_capacity_gb': 256, + 'allocated_capacity_gb': 256, 'reserved_percentage': 0, 'timestamp': None}, 'host4': {'total_capacity_gb': 2048, 'free_capacity_gb': 200, + 'allocated_capacity_gb': 1848, 'reserved_percentage': 5, 'timestamp': None}, } diff --git a/cinder/tests/scheduler/test_allocated_capacity_weigher.py b/cinder/tests/scheduler/test_allocated_capacity_weigher.py new file mode 100644 index 000000000..8a02ac92f --- /dev/null +++ b/cinder/tests/scheduler/test_allocated_capacity_weigher.py @@ -0,0 +1,92 @@ +# Copyright 2013 eBay Inc. +# +# All Rights Reserved. +# +# Licensed under the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. You may obtain +# a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT +# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the +# License for the specific language governing permissions and limitations +# under the License. +""" +Tests For Allocated Capacity Weigher. +""" + +import mock +from oslo.config import cfg + +from cinder import context +from cinder.openstack.common.scheduler.weights import HostWeightHandler +from cinder.scheduler.weights.capacity import AllocatedCapacityWeigher as ACW +from cinder import test +from cinder.tests.scheduler import fakes + +CONF = cfg.CONF + + +class AllocatedCapacityWeigherTestCase(test.TestCase): + def setUp(self): + super(AllocatedCapacityWeigherTestCase, self).setUp() + self.host_manager = fakes.FakeHostManager() + self.weight_handler = HostWeightHandler('cinder.scheduler.weights') + + def _get_weighed_host(self, hosts, weight_properties=None): + if weight_properties is None: + weight_properties = {} + return self.weight_handler.get_weighed_objects([ACW], hosts, + weight_properties)[0] + + @mock.patch('cinder.db.sqlalchemy.api.service_get_all_by_topic') + def _get_all_hosts(self, _mock_service_get_all_by_topic): + ctxt = context.get_admin_context() + fakes.mock_host_manager_db_calls(_mock_service_get_all_by_topic) + host_states = self.host_manager.get_all_host_states(ctxt) + _mock_service_get_all_by_topic.assert_called_once_with( + ctxt, CONF.volume_topic) + return host_states + + def test_default_of_spreading_first(self): + hostinfo_list = self._get_all_hosts() + + # host1: allocated_capacity_gb=0, weight=0 + # host2: allocated_capacity_gb=1748, weight=-1748 + # host3: allocated_capacity_gb=256, weight=-256 + # host4: allocated_capacity_gb=1848, weight=-1848 + + # so, host1 should win: + weighed_host = self._get_weighed_host(hostinfo_list) + self.assertEqual(weighed_host.weight, 0) + self.assertEqual(weighed_host.obj.host, 'host1') + + def test_capacity_weight_multiplier1(self): + self.flags(allocated_capacity_weight_multiplier=1.0) + hostinfo_list = self._get_all_hosts() + + # host1: allocated_capacity_gb=0, weight=0 + # host2: allocated_capacity_gb=1748, weight=1748 + # host3: allocated_capacity_gb=256, weight=256 + # host4: allocated_capacity_gb=1848, weight=1848 + + # so, host4 should win: + weighed_host = self._get_weighed_host(hostinfo_list) + self.assertEqual(weighed_host.weight, 1848.0) + self.assertEqual(weighed_host.obj.host, 'host4') + + def test_capacity_weight_multiplier2(self): + self.flags(allocated_capacity_weight_multiplier=-2.0) + hostinfo_list = self._get_all_hosts() + + # host1: allocated_capacity_gb=0, weight=0 + # host2: allocated_capacity_gb=1748, weight=-3496 + # host3: allocated_capacity_gb=256, weight=-512 + # host4: allocated_capacity_gb=1848, weight=-3696 + + # so, host1 should win: + weighed_host = self._get_weighed_host(hostinfo_list) + self.assertEqual(weighed_host.weight, 0) + self.assertEqual(weighed_host.obj.host, 'host1') diff --git a/cinder/tests/scheduler/test_capacity_weigher.py b/cinder/tests/scheduler/test_capacity_weigher.py index cb220f19e..680dac117 100644 --- a/cinder/tests/scheduler/test_capacity_weigher.py +++ b/cinder/tests/scheduler/test_capacity_weigher.py @@ -56,7 +56,7 @@ class CapacityWeigherTestCase(test.TestCase): # host1: free_capacity_gb=1024, free=1024*(1-0.1) # host2: free_capacity_gb=300, free=300*(1-0.1) - # host3: free_capacity_gb=512, free=512 + # host3: free_capacity_gb=512, free=256 # host4: free_capacity_gb=200, free=200*(1-0.05) # so, host1 should win: @@ -70,7 +70,7 @@ class CapacityWeigherTestCase(test.TestCase): # host1: free_capacity_gb=1024, free=-1024*(1-0.1) # host2: free_capacity_gb=300, free=-300*(1-0.1) - # host3: free_capacity_gb=512, free=-512 + # host3: free_capacity_gb=512, free=-256 # host4: free_capacity_gb=200, free=-200*(1-0.05) # so, host4 should win: @@ -84,7 +84,7 @@ class CapacityWeigherTestCase(test.TestCase): # host1: free_capacity_gb=1024, free=1024*(1-0.1)*2 # host2: free_capacity_gb=300, free=300*(1-0.1)*2 - # host3: free_capacity_gb=512, free=512*2 + # host3: free_capacity_gb=512, free=256*2 # host4: free_capacity_gb=200, free=200*(1-0.05)*2 # so, host1 should win: diff --git a/cinder/tests/test_gpfs.py b/cinder/tests/test_gpfs.py index 97c9b3dd9..1efbd49e4 100644 --- a/cinder/tests/test_gpfs.py +++ b/cinder/tests/test_gpfs.py @@ -90,6 +90,7 @@ class GPFSDriverTestCase(test.TestCase): self.volume = importutils.import_object(CONF.volume_manager) self.volume.driver.set_execute(self._execute_wrapper) self.volume.driver.set_initialized() + self.volume.stats = dict(allocated_capacity_gb=0) self.stubs.Set(GPFSDriver, '_create_gpfs_snap', self._fake_gpfs_snap) diff --git a/cinder/tests/test_rbd.py b/cinder/tests/test_rbd.py index e27e686d3..cc751ca51 100644 --- a/cinder/tests/test_rbd.py +++ b/cinder/tests/test_rbd.py @@ -702,6 +702,7 @@ class ManagedRBDTestCase(DriverTestCase): super(ManagedRBDTestCase, self).setUp() fake_image.stub_out_image_service(self.stubs) self.volume.driver.set_initialized() + self.volume.stats = {'allocated_capacity_gb': 0} self.called = [] def _create_volume_from_image(self, expected_status, raw=False, diff --git a/cinder/tests/test_volume.py b/cinder/tests/test_volume.py index 9cb552246..6abf3878d 100644 --- a/cinder/tests/test_volume.py +++ b/cinder/tests/test_volume.py @@ -113,6 +113,7 @@ class BaseVolumeTestCase(test.TestCase): self.stubs.Set(brick_lvm.LVM, '_vg_exists', lambda x: True) self.stubs.Set(os.path, 'exists', lambda x: True) self.volume.driver.set_initialized() + self.volume.stats = {'allocated_capacity_gb': 0} # keep ordered record of what we execute self.called = [] diff --git a/cinder/volume/manager.py b/cinder/volume/manager.py index 4ee29e498..c1d9e6a96 100644 --- a/cinder/volume/manager.py +++ b/cinder/volume/manager.py @@ -193,6 +193,7 @@ class VolumeManager(manager.SchedulerDependentManager): self.configuration = Configuration(volume_manager_opts, config_group=service_name) self._tp = GreenPool() + self.stats = {} if not volume_driver: # Get from configuration, which will get the default @@ -243,8 +244,13 @@ class VolumeManager(manager.SchedulerDependentManager): LOG.debug(_("Re-exporting %s volumes"), len(volumes)) try: + sum = 0 + self.stats.update({'allocated_capacity_gb': sum}) for volume in volumes: if volume['status'] in ['available', 'in-use']: + # calculate allocated capacity for driver + sum += volume['size'] + self.stats['allocated_capacity_gb'] = sum self.driver.ensure_export(ctxt, volume) elif volume['status'] == 'downloading': LOG.info(_("volume %s stuck in a downloading state"), @@ -341,6 +347,8 @@ class VolumeManager(manager.SchedulerDependentManager): # Fetch created volume from storage volume_ref = flow_engine.storage.fetch('volume') + # Update volume stats + self.stats['allocated_capacity_gb'] += volume_ref['size'] return volume_ref['id'] @utils.require_driver_initialized @@ -417,6 +425,7 @@ class VolumeManager(manager.SchedulerDependentManager): if reservations: QUOTAS.commit(context, reservations, project_id=project_id) + self.stats['allocated_capacity_gb'] -= volume_ref['size'] self.publish_service_capabilities(context) return True @@ -925,8 +934,9 @@ class VolumeManager(manager.SchedulerDependentManager): else: volume_stats = self.driver.get_volume_stats(refresh=True) if volume_stats: - # This will grab info about the host and queue it - # to be sent to the Schedulers. + # Append volume stats with 'allocated_capacity_gb' + volume_stats.update(self.stats) + # queue it to be sent to the Schedulers. self.update_service_capabilities(volume_stats) def publish_service_capabilities(self, context): @@ -1001,6 +1011,7 @@ class VolumeManager(manager.SchedulerDependentManager): QUOTAS.commit(context, reservations) self.db.volume_update(context, volume['id'], {'size': int(new_size), 'status': 'available'}) + self.stats['allocated_capacity_gb'] += size_increase self._notify_about_volume_usage( context, volume, "resize.end", extra_usage_info={'size': int(new_size)}) diff --git a/etc/cinder/cinder.conf.sample b/etc/cinder/cinder.conf.sample index 4f4147994..25c966c14 100644 --- a/etc/cinder/cinder.conf.sample +++ b/etc/cinder/cinder.conf.sample @@ -996,6 +996,10 @@ # numbers mean to stack vs spread. (floating point value) #capacity_weight_multiplier=1.0 +# Multiplier used for weighing volume capacity. Negative +# numbers mean to stack vs spread. (floating point value) +#allocated_capacity_weight_multiplier=-1.0 + # # Options defined in cinder.transfer.api diff --git a/setup.cfg b/setup.cfg index 883c56c3c..8b6deed4e 100644 --- a/setup.cfg +++ b/setup.cfg @@ -46,6 +46,7 @@ cinder.scheduler.filters = JsonFilter = cinder.openstack.common.scheduler.filters.json_filter:JsonFilter RetryFilter = cinder.scheduler.filters.retry_filter:RetryFilter cinder.scheduler.weights = + AllocatedCapacityWeigher = cinder.scheduler.weights.capacity:AllocatedCapacityWeigher CapacityWeigher = cinder.scheduler.weights.capacity:CapacityWeigher ChanceWeigher = cinder.scheduler.weights.chance:ChanceWeigher -- 2.45.2