| /external/chromium-trace/catapult/third_party/gsutil/gslib/tests/ |
| D | test_daisy_chain_wrapper.py | 88 with open(file_path, 'wb') as upload_stream:
93 upload_stream.write(data)
115 with open(upload_file, 'rb') as upload_stream:
117 self.assertEqual(upload_stream.read(), download_stream.read())
140 with open(upload_file, 'rb') as upload_stream:
142 self.assertEqual(upload_stream.read(), download_stream.read())
162 with open(upload_file, 'rb') as upload_stream:
164 self.assertEqual(upload_stream.read(), download_stream.read())
203 with open(upload_file, 'rb') as upload_stream:
204 self.assertEqual(upload_stream.read(), expected_contents,
[all …]
|
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| D | cloud_api_delegator.py | 227 def UploadObject(self, upload_stream, object_metadata, size=None, argument
231 upload_stream, object_metadata, size=size, canned_acl=canned_acl,
235 def UploadObjectStreaming(self, upload_stream, object_metadata, argument
239 upload_stream, object_metadata, canned_acl=canned_acl,
244 self, upload_stream, object_metadata, canned_acl=None, preconditions=None, argument
248 upload_stream, object_metadata, canned_acl=canned_acl,
|
| D | cloud_api.py | 299 def UploadObject(self, upload_stream, object_metadata, canned_acl=None, argument
328 def UploadObjectStreaming(self, upload_stream, object_metadata, argument
359 self, upload_stream, object_metadata, canned_acl=None, argument
|
| D | boto_translation.py | 699 def _PerformSimpleUpload(self, dst_uri, upload_stream, md5=None, argument
702 dst_uri.set_contents_from_file(upload_stream, md5=md5, policy=canned_acl,
705 def _PerformStreamingUpload(self, dst_uri, upload_stream, canned_acl=None, argument
708 dst_uri.set_contents_from_stream(upload_stream, policy=canned_acl,
716 stream_bytes = upload_stream.read(DEFAULT_FILE_BUFFER_SIZE)
719 stream_bytes = upload_stream.read(DEFAULT_FILE_BUFFER_SIZE)
727 def _PerformResumableUpload(self, key, upload_stream, upload_size, argument
733 resumable_upload.SendFile(key, upload_stream, upload_size,
816 self, upload_stream, object_metadata, canned_acl=None, preconditions=None, argument
823 upload_stream, object_metadata, canned_acl=canned_acl,
[all …]
|
| D | gcs_json_api.py | 821 def _UploadObject(self, upload_stream, object_metadata, canned_acl=None, argument
891 upload_stream, content_type, total_size=size, auto_transfer=True,
902 upload_stream, self.authorized_upload_http, content_type, size,
914 self, upload_stream, authorized_upload_http, content_type, size, argument
922 upload_stream, serialization_data, self.api_client.http,
929 upload_stream, content_type, total_size=size,
1028 def UploadObject(self, upload_stream, object_metadata, canned_acl=None, argument
1033 upload_stream, object_metadata, canned_acl=canned_acl,
1038 def UploadObjectStreaming(self, upload_stream, object_metadata, argument
1047 upload_stream, object_metadata, canned_acl=canned_acl,
[all …]
|
| D | copy_helper.py | 1564 upload_stream = src_obj_filestream
1570 upload_stream = open(upload_url.object_name, 'rb')
1585 orig_stream = upload_stream
1587 upload_stream = ResumableStreamingJsonUploadWrapper(
1594 wrapped_filestream = HashingFileUploadWrapper(upload_stream, digesters,
1597 wrapped_filestream = upload_stream
1602 upload_stream, upload_url, dst_url, dst_obj_metadata,
1626 upload_stream.close()
|