capabilities fix, run_as_root fix
This commit is contained in:
@@ -71,8 +71,8 @@ class SchedulerManager(manager.Manager):
|
|||||||
def update_service_capabilities(self, context=None, service_name=None,
|
def update_service_capabilities(self, context=None, service_name=None,
|
||||||
host=None, capabilities=None):
|
host=None, capabilities=None):
|
||||||
"""Process a capability update from a service node."""
|
"""Process a capability update from a service node."""
|
||||||
if not capability:
|
if not capabilities:
|
||||||
capability = {}
|
capabilities = {}
|
||||||
self.zone_manager.update_service_capabilities(service_name,
|
self.zone_manager.update_service_capabilities(service_name,
|
||||||
host, capabilities)
|
host, capabilities)
|
||||||
|
|
||||||
|
|||||||
@@ -197,8 +197,6 @@ class ZoneManager(object):
|
|||||||
|
|
||||||
def update_service_capabilities(self, service_name, host, capabilities):
|
def update_service_capabilities(self, service_name, host, capabilities):
|
||||||
"""Update the per-service capabilities based on this notification."""
|
"""Update the per-service capabilities based on this notification."""
|
||||||
# logging.debug(_("Received %(service_name)s service update from "
|
|
||||||
# "%(host)s: %(capabilities)s") % locals())
|
|
||||||
logging.debug(_("Received %(service_name)s service update from "
|
logging.debug(_("Received %(service_name)s service update from "
|
||||||
"%(host)s.") % locals())
|
"%(host)s.") % locals())
|
||||||
service_caps = self.service_states.get(host, {})
|
service_caps = self.service_states.get(host, {})
|
||||||
|
|||||||
Reference in New Issue
Block a user