Baguette
/
dodb.cr
3
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

corruption prevention

remotes/1708105384931250775/master
Philippe PITTOLI 2019-07-24 02:19:57 +02:00
parent ac3f94c017
commit 594906bcc7
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/fs.cr
View File

@ -1,4 +1,5 @@
require "file_utils"
require "json" require "json"
class FS::Hash(K, V) class FS::Hash(K, V)
@ -51,9 +52,13 @@ class FS::Hash(K, V)
end end
def []=(key : K, value : V) def []=(key : K, value : V)
# FIXME: Update partitions pointing to previous value (in any) # FIXME: Update partitions pointing to previous value (if any)
::File.write file_path(key), value.to_json # avoid corruption in case of crash during file writing
file_path(key).tap do |path|
::File.write "#{path}.new", value.to_json
::FileUtils.mv "#{path}.new", path
end
@partitions.each do |index| @partitions.each do |index|
index_key = index.key_proc.call value index_key = index.key_proc.call value
@ -62,6 +67,8 @@ class FS::Hash(K, V)
Dir.mkdir_p ::File.dirname symlink Dir.mkdir_p ::File.dirname symlink
# FIXME: why?
# Hint: to update old symlinks (new data directory)
::File.delete symlink if ::File.exists? symlink ::File.delete symlink if ::File.exists? symlink
::File.symlink symlink_path(key), symlink ::File.symlink symlink_path(key), symlink