openstack/placement
Code Issues Proposed changes

Merge "Fix db calls for snaphsot and volume mapping"

Browse Source
This commit is contained in:
Jenkins
2012-06-27 20:27:26 +00:00
committed by Gerrit Code Review
parent 7baf7295f2 bd9fb0aed8
commit 213add4a91
2 changed files with 13 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
nova/db/api.py
View File

@@ -1154,6 +1154,11 @@ def get_snapshot_uuid_by_ec2_id(context, ec2_id):
def get_ec2_snapshot_id_by_uuid(context, snapshot_id):
return IMPL.get_ec2_snapshot_id_by_uuid(context, snapshot_id)
def ec2_snapshot_create(context, snapshot_id, forced_id=None):
return IMPL.ec2_snapshot_create(context, snapshot_id, forced_id)
####################

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

@@ -2949,15 +2949,13 @@ def _volume_get_query(context, session=None, project_only=False):
@require_context
def _ec2_volume_get_query(context, session=None, project_only=False):
return model_query(context, models.VolumeIdMapping, session=session,
project_only=project_only)
def _ec2_volume_get_query(context, session=None):
return model_query(context, models.VolumeIdMapping, session=session)
@require_context
def _ec2_snapshot_get_query(context, session=None, project_only=False):
return model_query(context, models.SnapshotIdMapping, session=session,
project_only=project_only)
def _ec2_snapshot_get_query(context, session=None):
return model_query(context, models.SnapshotIdMapping, session=session)
@require_context
@@ -3046,9 +3044,7 @@ def ec2_volume_create(context, volume_uuid, id=None):
@require_context
def get_ec2_volume_id_by_uuid(context, volume_id, session=None):
result = _ec2_volume_get_query(context,
session=session,
project_only=True).\
result = _ec2_volume_get_query(context, session=session).\
filter_by(uuid=volume_id).\
first()
@@ -3060,9 +3056,7 @@ def get_ec2_volume_id_by_uuid(context, volume_id, session=None):
@require_context
def get_volume_uuid_by_ec2_id(context, ec2_id, session=None):
result = _ec2_volume_get_query(context,
session=session,
project_only=True).\
result = _ec2_volume_get_query(context, session=session).\
filter_by(id=ec2_id).\
first()
@@ -3087,9 +3081,7 @@ def ec2_snapshot_create(context, snapshot_uuid, id=None):
@require_context
def get_ec2_snapshot_id_by_uuid(context, snapshot_id, session=None):
result = _ec2_snapshot_get_query(context,
session=session,
project_only=True).\
result = _ec2_snapshot_get_query(context, session=session).\
filter_by(uuid=snapshot_id).\
first()
@@ -3101,9 +3093,7 @@ def get_ec2_snapshot_id_by_uuid(context, snapshot_id, session=None):
@require_context
def get_snapshot_uuid_by_ec2_id(context, ec2_id, session=None):
result = _ec2_snapshot_get_query(context,
session=session,
project_only=True).\
result = _ec2_snapshot_get_query(context, session=session).\
filter_by(id=ec2_id).\
first()