Cache snapshots in request for extension
The extended snapshots extension makes a separate db request for snapshots which is horribly inefficent. In addition it causes an issue when using all_tenants=1, because the second request doesn't pass in the filter. Fix this by caching the snapshot in the request object like we do for volumes and retrieve the cached object in the extension. Change-Id: Ia943438c8d48accb7f62c43f07642c3da2fe34ab Resolves-bug: #1358960
This commit is contained in:
@@ -15,13 +15,9 @@
|
||||
"""The Extended Snapshot Attributes API extension."""
|
||||
|
||||
|
||||
from webob import exc
|
||||
|
||||
from cinder.api import extensions
|
||||
from cinder.api.openstack import wsgi
|
||||
from cinder.api import xmlutil
|
||||
from cinder import exception
|
||||
from cinder.i18n import _
|
||||
from cinder.openstack.common import log as logging
|
||||
from cinder import volume
|
||||
|
||||
@@ -43,10 +39,11 @@ class ExtendedSnapshotAttributesController(wsgi.Controller):
|
||||
rval = dict((snapshot['id'], snapshot) for snapshot in snapshots)
|
||||
return rval
|
||||
|
||||
def _extend_snapshot(self, snapshot, data):
|
||||
def _extend_snapshot(self, req, resp_snap):
|
||||
db_snap = req.cached_resource_by_id(resp_snap['id'])
|
||||
for attr in ['project_id', 'progress']:
|
||||
key = "%s:%s" % (Extended_snapshot_attributes.alias, attr)
|
||||
snapshot[key] = data[attr]
|
||||
resp_snap[key] = db_snap[attr]
|
||||
|
||||
@wsgi.extends
|
||||
def show(self, req, resp_obj, id):
|
||||
@@ -54,15 +51,8 @@ class ExtendedSnapshotAttributesController(wsgi.Controller):
|
||||
if authorize(context):
|
||||
# Attach our slave template to the response object
|
||||
resp_obj.attach(xml=ExtendedSnapshotAttributeTemplate())
|
||||
|
||||
try:
|
||||
snapshot = self.volume_api.get_snapshot(context, id)
|
||||
except exception.NotFound:
|
||||
explanation = _("Snapshot not found.")
|
||||
raise exc.HTTPNotFound(explanation=explanation)
|
||||
|
||||
self._extend_snapshot(snapshot=resp_obj.obj['snapshot'],
|
||||
data=snapshot)
|
||||
snapshot = resp_obj.obj['snapshot']
|
||||
self._extend_snapshot(req, snapshot)
|
||||
|
||||
@wsgi.extends
|
||||
def detail(self, req, resp_obj):
|
||||
@@ -70,18 +60,8 @@ class ExtendedSnapshotAttributesController(wsgi.Controller):
|
||||
if authorize(context):
|
||||
# Attach our slave template to the response object
|
||||
resp_obj.attach(xml=ExtendedSnapshotAttributesTemplate())
|
||||
|
||||
snapshots = list(resp_obj.obj.get('snapshots', []))
|
||||
db_snapshots = self._get_snapshots(context)
|
||||
|
||||
for snapshot_object in snapshots:
|
||||
try:
|
||||
snapshot_data = db_snapshots[snapshot_object['id']]
|
||||
except KeyError:
|
||||
continue
|
||||
|
||||
self._extend_snapshot(snapshot=snapshot_object,
|
||||
data=snapshot_data)
|
||||
for snapshot in list(resp_obj.obj['snapshots']):
|
||||
self._extend_snapshot(req, snapshot)
|
||||
|
||||
|
||||
class Extended_snapshot_attributes(extensions.ExtensionDescriptor):
|
||||
|
||||
Reference in New Issue
Block a user