Class: ScoutApm::LayawayFile

Inherits:
Object
  • Object
show all
Defined in:
lib/scout_apm/layaway_file.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(context, path) ⇒ LayawayFile

Returns a new instance of LayawayFile.



7
8
9
10
 
# File 'lib/scout_apm/layaway_file.rb', line 7

def initialize(context, path)
  @path = path
  @context = context
end

Instance Attribute Details

#context ⇒ Object (readonly)

Returns the value of attribute context.



5
6
7
 
# File 'lib/scout_apm/layaway_file.rb', line 5

def context
  @context
end

#path ⇒ Object (readonly)

Returns the value of attribute path.



4
5
6
 
# File 'lib/scout_apm/layaway_file.rb', line 4

def path
  @path
end

Instance Method Details

#deserialize(data) ⇒ Object 



39
40
41
 
# File 'lib/scout_apm/layaway_file.rb', line 39

def deserialize(data)
  Marshal.load(data)
end

#load ⇒ Object 



16
17
18
19
20
21
22
23
24
 
# File 'lib/scout_apm/layaway_file.rb', line 16

def load
  data = File.open(path, "r") { |f| read_raw(f) }
  deserialize(data)
rescue NameError, ArgumentError, TypeError => e
  # Marshal error
  logger.info("LayawayFile: Unable to load data")
  logger.debug("#{e.message}, #{e.backtrace.join("\n\t")}")
  nil
end

#logger ⇒ Object 



12
13
14
 
# File 'lib/scout_apm/layaway_file.rb', line 12

def logger
  context.logger
end

#read_raw(f) ⇒ Object 



43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/scout_apm/layaway_file.rb', line 43

def read_raw(f)
  contents = ""
  while true
    contents << f.read_nonblock(10_000)
  end
rescue Errno::EAGAIN, Errno::EINTR
  IO.select([f])
  retry
rescue EOFError
  contents
end

#serialize(data) ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/scout_apm/layaway_file.rb', line 31

def serialize(data)
  Marshal.dump(data)
rescue
  ScoutApm::Agent.instance.logger.info("Failed Marshalling LayawayFile")
  ScoutApm::Agent.instance.logger.info(ScoutApm::Utils::MarshalLogging.new(data).dive) rescue nil
  raise
end

#write(data) ⇒ Object 



26
27
28
29
 
# File 'lib/scout_apm/layaway_file.rb', line 26

def write(data)
  serialized_data = serialize(data)
  File.open(path, "w") { |f| write_raw(f, serialized_data) }
end

#write_raw(f, data) ⇒ Object 



55
56
57
58
59
60
61
62
63
 
# File 'lib/scout_apm/layaway_file.rb', line 55

def write_raw(f, data)
  result = 0
  while (result < data.length)
    result += f.write_nonblock(data)
  end
rescue Errno::EAGAIN, Errno::EINTR
  IO.select(nil, [f])
  retry
end