return r.json
def _caclulate_uploaded_blocks(
- self, blocksize, blockhash, size, nblocks, hashes, hmap, fileobj,
- hash_cb=None):
+ self, blocksize, blockhash, size, nblocks, hashes, hmap, fileobj,
+ hash_cb=None):
offset = 0
if hash_cb:
hash_gen = hash_cb(nblocks)
if thread.exception:
failures.append(thread)
if isinstance(
- thread.exception,
- ClientError) and thread.exception.status == 502:
- self.POOLSIZE = self._thread_limit
+ thread.exception,
+ ClientError) and thread.exception.status == 502:
+ self.POOLSIZE = self._thread_limit
elif thread.isAlive():
flying.append(thread)
elif upload_gen:
:raises ClientError: 409 Container is not empty
"""
self._assert_container()
- r = self.container_delete(until=until,
+ r = self.container_delete(
+ until=until,
delimiter=delimiter,
success=(204, 404, 409))
r.release()
return reply
def set_object_sharing(
- self, obj,
- read_permition=False, write_permition=False):
+ self, obj,
+ read_permition=False, write_permition=False):
"""Give read/write permisions to an object.
:param obj: (str) remote object path
source_object=path4url(self.container, obj))
r.release()
- def overwrite_object(
- self, obj, start, end, source_file,
- upload_cb=None):
+ def overwrite_object(self, obj, start, end, source_file, upload_cb=None):
"""Overwrite a part of an object from local source file
:param obj: (str) remote object path
upload_gen.next()
def copy_object(
- self, src_container, src_object, dst_container,
- dst_object=False,
- source_version=None,
- public=False,
- content_type=None,
- delimiter=None):
+ self, src_container, src_object, dst_container,
+ dst_object=False,
+ source_version=None,
+ public=False,
+ content_type=None,
+ delimiter=None):
"""
:param src_container: (str) source container