revert

Author: ph

lib/logstash/outputs/s3/file_repository.rb

@@ -47,8 +47,6 @@ def initialize(tags, encoding, temporary_directory,
           start_stale_sweeper
         end
 
-        # This method is not atomic, but in the code we are using
-        # to check if file need rotation.
         def keys
           @prefixed_factories.keys
         end

spec/outputs/s3/file_repository_spec.rb

@@ -66,15 +66,13 @@
 
   it "returns the number of prefix keys" do
     expect(subject.size).to eq(0)
-    subject.get_file(prefix_key)  { |file| file.write("something") }
+    subject.get_file(prefix_key) { |file| file.write("something") }
     expect(subject.size).to eq(1)
   end
 
   it "returns all available keys" do
-    # this method is not atomic.
-    try {
-      expect(subject.keys).to eq([prefix_key])
-    }
+    subject.get_file(prefix_key) { |file| file.write("something") }
+    expect(subject.keys).to eq([prefix_key])
   end
 
   it "clean stale factories" do