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