Sha256: 4f19a4492cadfe6f0403cb89a47e7d532fadd83b8622c35aa352561be3bbc81d
Contents?: true
Size: 1.95 KB
Versions: 200
Compression:
Stored size: 1.95 KB
Contents
require 'rbbt/tsv'
module Persist
module TSVAdapter
attr_accessor :persistence_path, :closed, :writable, :mutex
MAX_CHAR = 255.chr
def mutex
@mutex ||= Mutex.new
end
def prefix(key)
range(key, 1, key + MAX_CHAR, 1)
end
def get_prefix(key)
keys = prefix(key)
select(:key => keys)
end
def closed?
@closed
end
def close
@closed = true
super
self
end
def write?
@writable
end
def read?
! write?
end
def collect
res = []
each do |key, value|
res << if block_given?
yield key, value
else
[key, value]
end
end
res
end
def delete(key)
out(key)
end
def write_and_read
lock_filename = Persist.persistence_path(persistence_path + '.write', {:dir => TSV.lock_dir})
#mutex.synchronize do
Misc.lock(lock_filename) do
write if closed? or not write?
res = begin
yield
ensure
read
end
res
end
#end
end
def write_and_close
lock_filename = Persist.persistence_path(persistence_path + '.write', {:dir => TSV.lock_dir})
#mutex.synchronize do
Misc.lock(lock_filename, true) do
write if closed? or not write?
res = begin
yield
rescue Exception
Log.exception $!
raise $!
ensure
close
end
res
#end
end
end
def read_and_close
#mutex.synchronize do
read if closed? or not read?
res = begin
yield
ensure
close
end
res
#end
end
def merge!(hash)
hash.each do |key,values|
self[key] = values
end
end
def range(*args)
super(*args) #- TSV::ENTRY_KEYS.to_a
end
end
end
Version data entries
200 entries across 200 versions & 1 rubygems