class Bizside::Cache::FileStore
Constants
- DIR_FORMATTER
- EXCLUDED_DIRS
- FILENAME_MAX_SIZE
- FILEPATH_MAX_SIZE
Attributes
cache_path[R]
Public Class Methods
new(cache_path, options = nil)
click to toggle source
Calls superclass method
# File lib/bizside/cache/file_store.rb, line 14 def initialize(cache_path, options = nil) super(options) @cache_path = cache_path.to_s end
Public Instance Methods
cleanup(options = nil)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 24 def cleanup(options = nil) options = merged_options(options) search_dir(cache_path) do |fname| key = file_path_key(fname) entry = read_entry(key, options) delete_entry(key, options) if entry && entry.expired? end end
clear(options = nil)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 19 def clear(options = nil) root_dirs = Dir.entries(cache_path).reject {|f| (EXCLUDED_DIRS + [".gitkeep"]).include?(f)} FileUtils.rm_r(root_dirs.collect{|f| File.join(cache_path, f)}) end
decrement(name, amount = 1, options = nil)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 37 def decrement(name, amount = 1, options = nil) modify_value(name, -amount, options) end
delete_matched(matcher, options = nil)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 41 def delete_matched(matcher, options = nil) options = merged_options(options) instrument(:delete_matched, matcher.inspect) do matcher = key_matcher(matcher, options) search_dir(cache_path) do |path| key = file_path_key(path) delete_entry(key, options) if key.match(matcher) end end end
increment(name, amount = 1, options = nil)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 33 def increment(name, amount = 1, options = nil) modify_value(name, amount, options) end
Protected Instance Methods
delete_entry(key, options)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 71 def delete_entry(key, options) file_name = key_file_path(key) if File.exist?(file_name) begin File.delete(file_name) delete_empty_directories(File.dirname(file_name)) true rescue => e raise e if File.exist?(file_name) false end end end
read_entry(key, options)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 54 def read_entry(key, options) file_name = key_file_path(key) if File.exist?(file_name) File.open(file_name) { |f| Marshal.load(f) } end rescue => e nil end
write_entry(key, entry, options)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 63 def write_entry(key, entry, options) file_name = key_file_path(key) return false if options[:unless_exist] && File.exist?(file_name) ensure_cache_path(File.dirname(file_name)) File.atomic_write(file_name, cache_path) {|f| Marshal.dump(entry, f)} true end
Private Instance Methods
delete_empty_directories(dir)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 126 def delete_empty_directories(dir) return if File.realpath(dir) == File.realpath(cache_path) if Dir.entries(dir).reject {|f| EXCLUDED_DIRS.include?(f)}.empty? Dir.delete(dir) rescue nil delete_empty_directories(File.dirname(dir)) end end
ensure_cache_path(path)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 134 def ensure_cache_path(path) FileUtils.makedirs(path) unless File.exist?(path) end
file_path_key(path)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 121 def file_path_key(path) fname = path[cache_path.to_s.size..-1].split(File::SEPARATOR, 4).last URI.decode_www_form_component(fname, Encoding::UTF_8) end
key_file_path(key)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 102 def key_file_path(key) if key.size > FILEPATH_MAX_SIZE key = Digest::MD5.hexdigest(key) end fname = URI.encode_www_form_component(key) hash = Zlib.adler32(fname) hash, dir_1 = hash.divmod(0x1000) dir_2 = hash.modulo(0x1000) fname_paths = [] begin fname_paths << fname[0, FILENAME_MAX_SIZE] fname = fname[FILENAME_MAX_SIZE..-1] end until fname.blank? File.join(cache_path, DIR_FORMATTER % dir_1, DIR_FORMATTER % dir_2, *fname_paths) end
lock_file(file_name) { || ... }
click to toggle source
# File lib/bizside/cache/file_store.rb, line 87 def lock_file(file_name, &block) if File.exist?(file_name) File.open(file_name, 'r+') do |f| begin f.flock File::LOCK_EX yield ensure f.flock File::LOCK_UN end end else yield end end
modify_value(name, amount, options)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 151 def modify_value(name, amount, options) file_name = key_file_path(namespaced_key(name, options)) lock_file(file_name) do options = merged_options(options) if num = read(name, options) num = num.to_i + amount write(name, num, options) num end end end
search_dir(dir, &callback)
click to toggle source
# File lib/bizside/cache/file_store.rb, line 138 def search_dir(dir, &callback) return if !File.exist?(dir) Dir.foreach(dir) do |d| next if EXCLUDED_DIRS.include?(d) name = File.join(dir, d) if File.directory?(name) search_dir(name, &callback) else callback.call name end end end