openstack/cyborg
Code Issues Proposed changes

Fix remote call conductor error

Browse Source 
Change-Id: I130bad097ffa2ef6594c5979f536b76a9350939f
Story: 2001928
Task: 14457
This commit is contained in:
wangzh21 2018-04-28 10:26:34 +08:00
parent ce0b6e5a95
commit 801aad10a4
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
cyborg/conductor/rpcapi.py
View File

@ -54,7 +54,7 @@ class ConductorAPI(object):
:param obj_acc: a created (but not saved) accelerator object. :param obj_acc: a created (but not saved) accelerator object.
:returns: created accelerator object. :returns: created accelerator object.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'accelerator_create', obj_acc=obj_acc) return cctxt.call(context, 'accelerator_create', obj_acc=obj_acc)
def accelerator_update(self, context, obj_acc): def accelerator_update(self, context, obj_acc):
@ -64,7 +64,7 @@ class ConductorAPI(object):
:param obj_acc: an accelerator object to update. :param obj_acc: an accelerator object to update.
:returns: updated accelerator object. :returns: updated accelerator object.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'accelerator_update', obj_acc=obj_acc) return cctxt.call(context, 'accelerator_update', obj_acc=obj_acc)
def accelerator_delete(self, context, obj_acc): def accelerator_delete(self, context, obj_acc):
@ -73,7 +73,7 @@ class ConductorAPI(object):
:param context: request context. :param context: request context.
:param obj_acc: an accelerator object to delete. :param obj_acc: an accelerator object to delete.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'accelerator_delete', obj_acc=obj_acc) return cctxt.call(context, 'accelerator_delete', obj_acc=obj_acc)
def accelerator_list_one(self, context, obj_acc): def accelerator_list_one(self, context, obj_acc):
@ -83,7 +83,7 @@ class ConductorAPI(object):
:param obj_acc: an accelerator object to list. :param obj_acc: an accelerator object to list.
:returns: accelerator object. :returns: accelerator object.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
cctxt.call(context, 'get_one', obj_acc=obj_acc) cctxt.call(context, 'get_one', obj_acc=obj_acc)
def accelerator_list_all(self, context, obj_acc): def accelerator_list_all(self, context, obj_acc):
@ -94,7 +94,7 @@ class ConductorAPI(object):
:returns: accelerator objects. :returns: accelerator objects.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'get_all', obj_acc=obj_acc) return cctxt.call(context, 'get_all', obj_acc=obj_acc)
def deployable_create(self, context, obj_dep): def deployable_create(self, context, obj_dep):
@ -104,7 +104,7 @@ class ConductorAPI(object):
:param obj_dep: a created (but not saved) deployable object. :param obj_dep: a created (but not saved) deployable object.
:returns: created deployable object. :returns: created deployable object.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'deployable_create', obj_dep=obj_dep) return cctxt.call(context, 'deployable_create', obj_dep=obj_dep)
def deployable_update(self, context, obj_dep): def deployable_update(self, context, obj_dep):
@ -114,7 +114,7 @@ class ConductorAPI(object):
:param obj_dep: a deployable object to update. :param obj_dep: a deployable object to update.
:returns: updated deployable object. :returns: updated deployable object.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'deployable_update', obj_dep=obj_dep) return cctxt.call(context, 'deployable_update', obj_dep=obj_dep)
def deployable_delete(self, context, obj_dep): def deployable_delete(self, context, obj_dep):
@ -123,7 +123,7 @@ class ConductorAPI(object):
:param context: request context. :param context: request context.
:param obj_dep: a deployable object to delete. :param obj_dep: a deployable object to delete.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
cctxt.call(context, 'deployable_delete', obj_dep=obj_dep) cctxt.call(context, 'deployable_delete', obj_dep=obj_dep)
def deployable_get(self, context, uuid): def deployable_get(self, context, uuid):
@ -133,7 +133,7 @@ class ConductorAPI(object):
:param uuid: UUID of a deployable. :param uuid: UUID of a deployable.
:returns: requested deployable object. :returns: requested deployable object.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'deployable_get', uuid=uuid) return cctxt.call(context, 'deployable_get', uuid=uuid)
def deployable_get_by_host(self, context, host): def deployable_get_by_host(self, context, host):
@ -143,7 +143,7 @@ class ConductorAPI(object):
:param host: host on which the deployable is located. :param host: host on which the deployable is located.
:returns: requested deployable object. :returns: requested deployable object.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'deployable_get_by_host', host=host) return cctxt.call(context, 'deployable_get_by_host', host=host)
def deployable_list(self, context): def deployable_list(self, context):
@ -152,5 +152,5 @@ class ConductorAPI(object):
:param context: request context. :param context: request context.
:returns: a list of deployable objects. :returns: a list of deployable objects.
""" """
cctxt = self.client.prepare(topic=self.topic, server=CONF.host) cctxt = self.client.prepare(topic=self.topic)
return cctxt.call(context, 'deployable_list') return cctxt.call(context, 'deployable_list')