summaryrefslogtreecommitdiff
path: root/swiftclient/service.py
diff options
context:
space:
mode:
authorDaniel Wakefield <daniel.wakefield@hp.com>2014-11-07 12:46:23 +0000
committerDaniel Wakefield <daniel.wakefield@hp.com>2014-11-07 12:55:51 +0000
commit93cc42b21d213079285fcd09f1cf07168b803018 (patch)
tree812def351c0d92f2efcc31c7fef3cad274829f4f /swiftclient/service.py
parent19b427eacbbbb94199551766149472f26fa08698 (diff)
downloadpython-swiftclient-93cc42b21d213079285fcd09f1cf07168b803018.tar.gz
Fix misnamed variable in SwiftReader.
actual_md5 was being used instead of _actual_md5 only when assigning the md5 object. This resulted in all checks and updates of the md5 to be skipped. When fixed it revealed another bug that the md5 of the read content is always checked even if there is no _expected_etag. Added tests Change-Id: Iaf1e21324ce592049d02cd5be123604b99833e86
Diffstat (limited to 'swiftclient/service.py')
-rw-r--r--swiftclient/service.py35
1 files changed, 18 insertions, 17 deletions
diff --git a/swiftclient/service.py b/swiftclient/service.py
index 281947e..a964d4d 100644
--- a/swiftclient/service.py
+++ b/swiftclient/service.py
@@ -313,36 +313,37 @@ class _SwiftReader(object):
self._actual_md5 = None
self._expected_etag = headers.get('etag')
- if 'x-object-manifest' not in headers and \
- 'x-static-large-object' not in headers:
- self.actual_md5 = md5()
+ if ('x-object-manifest' not in headers
+ and 'x-static-large-object' not in headers):
+ self._actual_md5 = md5()
if 'content-length' in headers:
- self._content_length = int(headers.get('content-length'))
+ try:
+ self._content_length = int(headers.get('content-length'))
+ except ValueError:
+ raise SwiftError('content-length header must be an integer')
def __enter__(self):
return self
def __exit__(self, exc_type, exc_val, exc_tb):
- if self._actual_md5 is not None:
+ if self._actual_md5 and self._expected_etag:
etag = self._actual_md5.hexdigest()
if etag != self._expected_etag:
- raise SwiftError(
- 'Error downloading %s: md5sum != etag, %s != %s' %
- (self._path, etag, self._expected_etag)
- )
+ raise SwiftError('Error downloading {0}: md5sum != etag, '
+ '{1} != {2}'.format(
+ self._path, etag, self._expected_etag))
- if self._content_length is not None and \
- self._actual_read != self._content_length:
- raise SwiftError(
- 'Error downloading %s: read_length != content_length, '
- '%d != %d' % (self._path, self._actual_read,
- self._content_length)
- )
+ if (self._content_length is not None
+ and self._actual_read != self._content_length):
+ raise SwiftError('Error downloading {0}: read_length != '
+ 'content_length, {1:d} != {2:d}'.format(
+ self._path, self._actual_read,
+ self._content_length))
def buffer(self):
for chunk in self._body:
- if self._actual_md5 is not None:
+ if self._actual_md5:
self._actual_md5.update(chunk)
self._actual_read += len(chunk)
yield chunk