class MemoryLeak::Resources
Public Class Methods
define(resource, refresh_fn, ttl, opts = {})
click to toggle source
# File lib/aspace_client/memoryleak.rb, line 15 def self.define(resource, refresh_fn, ttl, opts = {}) @@resources[resource] = Atomic.new(nil) @@refresh_fns[resource] = refresh_fn @@expiration_seconds[resource] = ttl if ttl self.set(resource, opts[:init], 0) end
get(resource)
click to toggle source
# File lib/aspace_client/memoryleak.rb, line 24 def self.get(resource) stale = (@@resources[resource].value.nil? || (@@expiration_seconds[resource] && (Time.now.to_i - @@resources[resource].value[:system_mtime]) > @@expiration_seconds[resource])) self.refresh(resource) if stale @@resources[resource].value[:value] end
invalidate_all!()
click to toggle source
# File lib/aspace_client/memoryleak.rb, line 51 def self.invalidate_all! @@resources.values.each do |atom| atom.update {|val| val.merge(:system_mtime => 0) if val} end end
refresh(resource)
click to toggle source
# File lib/aspace_client/memoryleak.rb, line 35 def self.refresh(resource) # Two concurrent users might trigger some resource to be refreshed at # around the same time (e.g. when two people create a new repository at # once). We want both refreshes to run in sequence, so use a mutex to # serialize them. @@refresh_mutex.synchronize do self.set(resource, @@refresh_fns[resource].call) end end
set(resource, value, time = nil)
click to toggle source
# File lib/aspace_client/memoryleak.rb, line 46 def self.set(resource, value, time = nil) @@resources[resource].swap({:value => value, :system_mtime => (time || Time.now.to_i)}) end