lib/aws-sdk-s3/object_multipart_copier.rb
UNKNOWN
Verdict: BENIGN
Local reference
Suspicious dependency
Inferred
object_multipart_copier.rb
ruby
| 1 |
require 'thread' |
|
| 2 |
require 'cgi' |
|
| 3 |
|
|
| 4 |
module Aws |
AWS SDK Ruby namespace marker |
| 5 |
module S3 |
|
| 6 |
# @api private |
|
| 7 |
class ObjectMultipartCopier |
|
| 8 |
|
|
| 9 |
FIVE_MB = 5 * 1024 * 1024 # 5MB |
|
| 10 |
|
|
| 11 |
FILE_TOO_SMALL = "… |
|
| 17:16 |
…lts to 50MB. |
|
| 18 |
# will be constructed from the given `options' hash. |
|
| 19 |
# @option [Integer] :thread_count (10) Number of concurrent threads to |
|
| 20 |
# use for copying parts. |
|
| 21 |
def initialize(options = {}) |
|
| 22 |
@thread_count = options.delete(:threa… |
|
| 45:3 |
… def initiate_upload(options) |
|
| 46 |
options = options_for(:create_multipart_upload, options) |
Create multipart upload operation |
| 47 |
@client.create_multipart_upload(options).upload_id |
|
| 48 |
end |
|
| 49 |
|
|
| 50 |
def copy_parts(size, default_part_size, o… |
|
| 56:64 |
…_number] } |
|
| 57 |
end |
|
| 58 |
|
|
| 59 |
def copy_part_thread(queue) |
|
| 60 |
Thread.new do |
Creates a Ruby background thread |
| 61 |
begin |
|
| 62 |
completed = [] |
|
| 63 |
while part = queue.shift |
|
| 64 |
completed << copy_part(part) |
|
| 65 |
… |
|
| 81:10 |
… complete_upload(parts, options) |
|
| 82 |
options = options_for(:complete_multipart_upload, options) |
Complete multipart upload operation |
| 83 |
options[:multipart_upload] = { parts: parts } |
Multipart upload operation |
| 84 |
@client.complete_multipart_upload(options) |
|
| 85 |
end |
|
| 86 |
|
|
| 87 |
def abort_upload(options) |
|
| 88 |
@clie… |
|
Well-known
| 1 |
require 'thread' |
|
| 2 |
require 'cgi' |
|
| 3 |
|
|
| 4 |
module Aws |
|
| 5 |
module S3 |
|
| 6 |
# @api private |
|
| 7 |
class ObjectMultipartCopier |
|
| 8 |
|
|
| 9 |
FIVE_MB = 5 * 1024 * 1024 # 5MB |
|
| 10 |
|
|
| 11 |
FILE_TOO_SMALL = "… |
|
Micro-behaviors
| 81:10 |
… complete_upload(parts, options) |
|
| 82 |
options = options_for(:complete_multipart_upload, options) |
|
| 83 |
options[:multipart_upload] = { parts: parts } |
|
| 84 |
@client.complete_multipart_upload(options) |
|
| 85 |
end |
|
| 86 |
|
|
| 87 |
def abort_upload(options) |
|
| 88 |
@clie… |
|
| 45:3 |
… def initiate_upload(options) |
|
| 46 |
options = options_for(:create_multipart_upload, options) |
|
| 47 |
@client.create_multipart_upload(options).upload_id |
|
| 48 |
end |
|
| 49 |
|
|
| 50 |
def copy_parts(size, default_part_size, o… |
|
| 56:64 |
…_number] } |
|
| 57 |
end |
|
| 58 |
|
|
| 59 |
def copy_part_thread(queue) |
|
| 60 |
Thread.new do |
|
| 61 |
begin |
|
| 62 |
completed = [] |
|
| 63 |
while part = queue.shift |
|
| 64 |
completed << copy_part(part) |
|
| 65 |
… |
|
Metadata
| 17:16 |
…lts to 50MB. |
|
| 18 |
# will be constructed from the given `options' hash. |
|
| 19 |
# @option [Integer] :thread_count (10) Number of concurrent threads to |
|
| 20 |
# use for copying parts. |
|
| 21 |
def initialize(options = {}) |
|
| 22 |
@thread_count = options.delete(:threa… |
|
-
0
require 'thread'
require 'cgi'
module Aws
module S3
# @api private
class ObjectMultipartCopier
FIVE_MB = 5 * 1024 * 1024 # 5MB
FILE_TOO_SMALL = "
Identity
| SHA-256 |
f6f8ef6bbf6eb8e861dbe88b22f64b1ec016cb14ae6ff18f1df6a8e6b7871af2 |
| Filename |
lib/aws-sdk-s3/object_multipart_copier.rb |
Origin
| Source |
x |
| Feed |
pkg.go.dev |
| Ecosystem |
go |
Timeline
| First seen |
16 Aug 2026 05:39 UTC |
| First analyzed |
16 Aug 2026 05:41 UTC |
| Last analyzed |
16 Aug 2026 05:41 UTC |
| Last updated |
16 Aug 2026 05:39 UTC |