"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "cyborg/objects/extarq/ext_arq_job.py" between
openstack-cyborg-6.0.0.tar.gz and openstack-cyborg-7.0.0.tar.gz

About: OpenStack Cyborg provides a general purpose management framework for acceleration resources.
The "Xena" series (latest release).

ext_arq_job.py  (openstack-cyborg-6.0.0):ext_arq_job.py  (openstack-cyborg-7.0.0)
skipping to change at line 58 skipping to change at line 58
"""From the inherit subclass find the suitable ExtARQ.""" """From the inherit subclass find the suitable ExtARQ."""
extarq = cls.get(context, uuid) extarq = cls.get(context, uuid)
typ = extarq.get_resources_from_device_profile_group() typ = extarq.get_resources_from_device_profile_group()
factory = cls.factory(typ) factory = cls.factory(typ)
if factory != cls: if factory != cls:
return factory.get(context, uuid) return factory.get(context, uuid)
return extarq return extarq
def start_bind_job(self, context, valid_fields): def start_bind_job(self, context, valid_fields):
"""Check and start bind jobs for ARQ.""" """Check and start bind jobs for ARQ."""
# Check can ARC be bound.
expected = ARQ_STATES_TRANSFORM_MATRIX[constants.ARQ_BIND_STARTED] expected = ARQ_STATES_TRANSFORM_MATRIX[constants.ARQ_BIND_STARTED]
# Check whether ARQ can be bound.
if self.arq.state not in expected: if self.arq.state not in expected:
raise exception.ARQBadState( raise exception.ARQBadState(
state=self.arq.state, uuid=self.arq.uuid, expected=expected) state=self.arq.state, uuid=self.arq.uuid, expected=expected)
hostname = valid_fields[self.arq.uuid]['hostname'] hostname = valid_fields[self.arq.uuid]['hostname']
devrp_uuid = valid_fields[self.arq.uuid]['device_rp_uuid'] devrp_uuid = valid_fields[self.arq.uuid]['device_rp_uuid']
instance_uuid = valid_fields[self.arq.uuid]['instance_uuid'] instance_uuid = valid_fields[self.arq.uuid]['instance_uuid']
project_id = valid_fields[self.arq.uuid].get('project_id') project_id = valid_fields[self.arq.uuid].get('project_id')
LOG.info('[arqs:objs] bind. hostname: %(hostname)s, ' LOG.info('[arqs:objs] bind. hostname: %(hostname)s, '
'devrp_uuid: %(devrp_uuid)s, ' 'devrp_uuid: %(devrp_uuid)s, '
skipping to change at line 239 skipping to change at line 239
def apply_patch(cls, context, patch_list, valid_fields): def apply_patch(cls, context, patch_list, valid_fields):
"""Apply JSON patch. See api/controllers/v2/arqs.py.""" """Apply JSON patch. See api/controllers/v2/arqs.py."""
arq_binds = {} arq_binds = {}
for arq_uuid, patch in patch_list.items(): for arq_uuid, patch in patch_list.items():
extarq = cls.get_suitable_ext_arq(context, arq_uuid) extarq = cls.get_suitable_ext_arq(context, arq_uuid)
if patch[0]['op'] == 'add': # All ops are 'add' if patch[0]['op'] == 'add': # All ops are 'add'
# arq_notify_list.append(arq_uuid) # arq_notify_list.append(arq_uuid)
job = extarq.start_bind_job(context, valid_fields) job = extarq.start_bind_job(context, valid_fields)
arq_binds[extarq] = job arq_binds[extarq] = job
else: else:
extarq.unbind(context, extarq) extarq.unbind(context)
if arq_binds: if arq_binds:
cls.master(context, arq_binds) cls.master(context, arq_binds)
 End of changes. 3 change blocks. 
2 lines changed or deleted 2 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)