| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/glacier/ |
| D | writer.py | 89 def __init__(self, vault, upload_id, part_size, chunk_size=_ONE_MEGABYTE): argument
91 self.upload_id = upload_id
126 self.upload_id,
158 self.vault.name, self.upload_id, hex_tree_hash,
171 def resume_file_upload(vault, upload_id, part_size, fobj, part_hash_map, argument
192 uploader = _Uploader(vault, upload_id, part_size, chunk_size)
210 def __init__(self, vault, upload_id, part_size, chunk_size=_ONE_MEGABYTE): argument
211 self.uploader = _Uploader(vault, upload_id, part_size, chunk_size)
257 def upload_id(self): member in Writer
258 return self.uploader.upload_id
|
| D | layer1.py | 952 def complete_multipart_upload(self, vault_name, upload_id, argument
1036 uri = 'vaults/%s/multipart-uploads/%s' % (vault_name, upload_id)
1042 def abort_multipart_upload(self, vault_name, upload_id): argument
1074 uri = 'vaults/%s/multipart-uploads/%s' % (vault_name, upload_id)
1137 def list_parts(self, vault_name, upload_id, limit=None, marker=None): argument
1190 uri = 'vaults/%s/multipart-uploads/%s' % (vault_name, upload_id)
1193 def upload_part(self, vault_name, upload_id, linear_hash, argument
1276 uri = 'vaults/%s/multipart-uploads/%s' % (vault_name, upload_id)
|
| D | vault.py | 172 upload_id_callback(writer.upload_id)
198 def resume_archive_from_file(self, upload_id, filename=None, argument
222 part_list_response = self.list_all_parts(upload_id)
236 self, upload_id, part_size, file_obj, part_hash_map)
432 def list_all_parts(self, upload_id): argument
439 result = self.layer1.list_parts(self.name, upload_id)
443 self.name, upload_id, marker=marker)
|
| D | concurrent.py | 137 upload_id = response['UploadId']
143 self._start_upload_threads(result_queue, upload_id,
151 self._api.abort_multipart_upload(self._vault_name, upload_id)
155 self._vault_name, upload_id, bytes_to_hex(tree_hash(hash_chunks)),
176 def _start_upload_threads(self, result_queue, upload_id, worker_queue, argument
181 upload_id, worker_queue, result_queue)
217 def __init__(self, api, vault_name, filename, upload_id, argument
226 self._upload_id = upload_id
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/glacier/ |
| D | test_writer.py | 71 sentinel.vault_name, sentinel.upload_id,
88 sentinel.vault_name, sentinel.upload_id, data_tree_hash, data_len)
97 upload_id = sentinel.upload_id
99 self.vault, upload_id, self.part_size, self.chunk_size)
181 self.assertEquals(sentinel.upload_id, self.writer.upload_id)
202 self.vault, sentinel.upload_id, self.part_size, fobj,
227 self.vault, sentinel.upload_id, self.part_size, StringIO('1'), {},
|
| D | test_layer2.py | 202 self.assertEqual(writer.upload_id, "UPLOADID")
258 parts_result = self.vault.list_all_parts(sentinel.upload_id)
259 expected = [call('examplevault', sentinel.upload_id)]
269 parts_result = self.vault.list_all_parts(sentinel.upload_id)
270 expected = [call('examplevault', sentinel.upload_id),
271 call('examplevault', sentinel.upload_id,
293 sentinel.upload_id, file_obj=sentinel.file_obj)
295 self.vault, sentinel.upload_id, part_size, sentinel.file_obj,
|
| D | test_concurrent.py | 35 def _start_upload_threads(self, results_queue, upload_id, argument
39 self.upload_id = upload_id
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/glacier/ |
| D | test_layer1.py | 39 upload_id = glacier.initiate_multipart_upload('l1testvault', 4 * 1024 * 1024,
41 self.addCleanup(glacier.abort_multipart_upload, 'l1testvault', upload_id)
44 self.assertEqual(response[0]['MultipartUploadId'], upload_id)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/s3/ |
| D | bucket.py | 1767 def complete_multipart_upload(self, key_name, upload_id, argument
1772 query_args = 'uploadId=%s' % upload_id
1806 def cancel_multipart_upload(self, key_name, upload_id, headers=None): argument
1812 query_args = 'uploadId=%s' % upload_id
|