Revision f5f2dc53 kamaki/clients/pithos.py
| b/kamaki/clients/pithos.py | ||
|---|---|---|
| 446 | 446 |
|
| 447 | 447 |
def _thread2file(self, flying, local_file, offset=0, **restargs): |
| 448 | 448 |
"""write the results of a greenleted rest call to a file |
| 449 |
@offset: the offset of the file up to blocksize |
|
| 450 |
- e.g. if the range is 10-100, all |
|
| 451 |
blocks will be written to normal_position - 10""" |
|
| 449 |
|
|
| 450 |
:param offset: the offset of the file up to blocksize |
|
| 451 |
- e.g. if the range is 10-100, all blocks will be written to |
|
| 452 |
normal_position - 10 |
|
| 453 |
""" |
|
| 452 | 454 |
finished = [] |
| 453 | 455 |
for i, (start, g) in enumerate(flying.items()): |
| 454 | 456 |
if not g.isAlive(): |
| ... | ... | |
| 509 | 511 |
if_none_match=None, |
| 510 | 512 |
if_modified_since=None, |
| 511 | 513 |
if_unmodified_since=None): |
| 512 |
"""Download an object using multiple connections (threads) and |
|
| 513 |
writing to random parts of the file |
|
| 514 |
"""Download an object (multiple connections, random blocks) |
|
| 514 | 515 |
|
| 515 | 516 |
:param obj: (str) remote object path |
| 516 | 517 |
|
| ... | ... | |
| 522 | 523 |
|
| 523 | 524 |
:param resume: (bool) if set, preserve already downloaded file parts |
| 524 | 525 |
|
| 525 |
:param range_str: (str) from-to where from and to are integers |
|
| 526 |
denoting file positions in bytes |
|
| 526 |
:param range_str: (str) from, to are file positions (int) in bytes |
|
| 527 | 527 |
|
| 528 | 528 |
:param if_match: (str) |
| 529 | 529 |
|
| ... | ... | |
| 531 | 531 |
|
| 532 | 532 |
:param if_modified_since: (str) formated date |
| 533 | 533 |
|
| 534 |
:param if_unmodified_since: (str) formated date |
|
| 535 |
""" |
|
| 536 |
|
|
| 534 |
:param if_unmodified_since: (str) formated date""" |
|
| 537 | 535 |
restargs = dict( |
| 538 | 536 |
version=version, |
| 539 | 537 |
data_range=None if range_str is None else 'bytes=%s' % range_str, |
Also available in: Unified diff