openstack/placement
Code Issues Proposed changes

Convert consoles to use instance uuid.

Browse Source 
Continued work on blueprint finish-uuid-conversion.

Change-Id: I4032419d66e9bbb17b770d8974a92a136bf9c5d2
This commit is contained in:
Michael Still
2012-06-07 11:16:23 +10:00
parent f6cdd60d3a
commit 983a376aa2
2 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
nova/db/api.py
View File

@@ -1505,19 +1505,19 @@ def console_delete(context, console_id):
return IMPL.console_delete(context, console_id)
def console_get_by_pool_instance(context, pool_id, instance_id):
def console_get_by_pool_instance(context, pool_id, instance_uuid):
"""Get console entry for a given instance and pool."""
return IMPL.console_get_by_pool_instance(context, pool_id, instance_id)
return IMPL.console_get_by_pool_instance(context, pool_id, instance_uuid)
def console_get_all_by_instance(context, instance_id):
def console_get_all_by_instance(context, instance_uuid):
"""Get consoles for a given instance."""
return IMPL.console_get_all_by_instance(context, instance_id)
return IMPL.console_get_all_by_instance(context, instance_uuid)
def console_get(context, console_id, instance_id=None):
def console_get(context, console_id, instance_uuid=None):
"""Get a specific console (possibly on a given instance)."""
return IMPL.console_get(context, console_id, instance_id)
return IMPL.console_get(context, console_id, instance_uuid)
##################

20
nova/db/sqlalchemy/api.py
View File

@@ -3894,40 +3894,40 @@ def console_delete(context, console_id):
delete()
def console_get_by_pool_instance(context, pool_id, instance_id):
def console_get_by_pool_instance(context, pool_id, instance_uuid):
result = model_query(context, models.Console, read_deleted="yes").\
filter_by(pool_id=pool_id).\
filter_by(instance_id=instance_id).\
filter_by(instance_uuid=instance_uuid).\
options(joinedload('pool')).\
first()
if not result:
raise exception.ConsoleNotFoundInPoolForInstance(
pool_id=pool_id, instance_id=instance_id)
pool_id=pool_id, instance_uuid=instance_uuid)
return result
def console_get_all_by_instance(context, instance_id):
def console_get_all_by_instance(context, instance_uuid):
return model_query(context, models.Console, read_deleted="yes").\
filter_by(instance_id=instance_id).\
filter_by(instance_uuid=instance_uuid).\
all()
def console_get(context, console_id, instance_id=None):
def console_get(context, console_id, instance_uuid=None):
query = model_query(context, models.Console, read_deleted="yes").\
filter_by(id=console_id).\
options(joinedload('pool'))
if instance_id is not None:
query = query.filter_by(instance_id=instance_id)
if instance_uuid is not None:
query = query.filter_by(instance_uuid=instance_uuid)
result = query.first()
if not result:
if instance_id:
if instance_uuid:
raise exception.ConsoleNotFoundForInstance(
console_id=console_id, instance_id=instance_id)
console_id=console_id, instance_uuid=instance_uuid)
else:
raise exception.ConsoleNotFound(console_id=console_id)