lib/logstash/outputs/s3/uploader.rb in logstash-output-s3-4.3.7 vs lib/logstash/outputs/s3/uploader.rb in logstash-output-s3-4.4.0
- old
+ new
@@ -29,10 +29,11 @@
LogStash::Util.set_thread_name("S3 output uploader, file: #{file.path}")
upload(file, options)
end
end
+ # uploads a TemporaryFile to S3
def upload(file, options = {})
upload_options = options.fetch(:upload_options, {})
tries = 0
begin
@@ -66,9 +67,10 @@
def stop
@workers_pool.shutdown
@workers_pool.wait_for_termination(nil) # block until its done
end
+
end
end
end
end