Sha256: bd38bd301245946bb343ede44c1bdc5f5801bf4ef56beca51fe5ee4ee169ec9d
Contents?: true
Size: 1.78 KB
Versions: 17
Compression:
Stored size: 1.78 KB
Contents
# Logic for the serialized file access
class ScoutRails::LayawayFile
def path
"#{ScoutRails::Agent.instance.log_path}/scout_rails.db"
end
def dump(object)
Marshal.dump(object)
end
def load(dump)
if dump.size == 0
ScoutRails::Agent.instance.logger.debug("No data in layaway file.")
return nil
end
Marshal.load(dump)
rescue ArgumentError, TypeError => e
ScoutRails::Agent.instance.logger.debug("Error loading data from layaway file: #{e.inspect}")
ScoutRails::Agent.instance.logger.debug(e.backtrace.inspect)
nil
end
def read_and_write
File.open(path, File::RDWR | File::CREAT) do |f|
f.flock(File::LOCK_EX)
begin
result = (yield get_data(f))
f.rewind
f.truncate(0)
if result
write(f, dump(result))
end
ensure
f.flock(File::LOCK_UN)
end
end
rescue Errno::ENOENT, Exception => e
ScoutRails::Agent.instance.logger.error("Unable to access the layaway file [#{e.message}]. The user running the app must have read+write access.")
ScoutRails::Agent.instance.logger.debug(e.backtrace.split("\n"))
# ensure the in-memory metric hash is cleared so data doesn't continue to accumulate.
ScoutRails::Agent.instance.store.metric_hash = {}
end
def get_data(f)
data = read_until_end(f)
result = load(data)
f.truncate(0)
result
end
def write(f, string)
result = 0
while (result < string.length)
result += f.write_nonblock(string)
end
rescue Errno::EAGAIN, Errno::EINTR
IO.select(nil, [f])
retry
end
def read_until_end(f)
contents = ""
while true
contents << f.read_nonblock(10_000)
end
rescue Errno::EAGAIN, Errno::EINTR
IO.select([f])
retry
rescue EOFError
contents
end
end
Version data entries
17 entries across 17 versions & 1 rubygems