Merge pull request #3335 from fujimotos/sf/atomic-storage

storage_local: change LocalStorage.save() to be atomic
fluent · Apr 19, 2021 · 31efe9c · 31efe9c
2 parents 72267d8 + 9a7cda6
commit 31efe9c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/fluent/plugin/storage_local.rb b/lib/fluent/plugin/storage_local.rb
@@ -130,7 +130,7 @@ def load
 
       def save
         return if @on_memory
-        tmp_path = @path + '.tmp'
+        tmp_path = @path + '.tmp.' + Fluent::UniqueId.hex(Fluent::UniqueId.generate)
         begin
           json_string = Yajl::Encoder.encode(@store, pretty: @pretty_print)
           File.open(tmp_path, 'w:utf-8', @mode) { |io| io.write json_string; io.fsync }