¡@
OpenStack Study: aggregate_image_properties_isolation.py**** CubicPower OpenStack Study ****
# Copyright (c) 2013 Cloudwatt # 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. from oslo.config import cfg from nova import db from nova.openstack.common.gettextutils import _ from nova.openstack.common import log as logging from nova.scheduler import filters opts = [ cfg.StrOpt('aggregate_image_properties_isolation_namespace', help='Force the filter to consider only keys matching ' 'the given namespace.'), cfg.StrOpt('aggregate_image_properties_isolation_separator', default=".", help='The separator used between the namespace and keys'), ] CONF = cfg.CONF CONF.register_opts(opts) LOG = logging.getLogger(__name__)
**** CubicPower OpenStack Study **** class AggregateImagePropertiesIsolation(filters.BaseHostFilter): """AggregateImagePropertiesIsolation works with image properties.""" # Aggregate data and instance type does not change within a request run_filter_once_per_request = True
**** CubicPower OpenStack Study **** def host_passes(self, host_state, filter_properties): """Checks a host in an aggregate that metadata key/value match with image properties. """ cfg_namespace = CONF.aggregate_image_properties_isolation_namespace cfg_separator = CONF.aggregate_image_properties_isolation_separator spec = filter_properties.get('request_spec', {}) image_props = spec.get('image', {}).get('properties', {}) context = filter_properties['context'].elevated() metadata = db.aggregate_metadata_get_by_host(context, host_state.host) for key, options in metadata.iteritems(): if (cfg_namespace and not key.startswith(cfg_namespace + cfg_separator)): continue prop = image_props.get(key) if prop and prop not in options: LOG.debug(_("%(host_state)s fails image aggregate properties " "requirements. Property %(prop)s does not " "match %(options)s."), {'host_state': host_state, 'prop': prop, 'options': options}) return False return True
|