class Rack::Session::AbstractDBM
Attributes
mutex[R]
pool[R]
Public Class Methods
new(app, path=nil, options={})
click to toggle source
Calls superclass method
# File lib/rack/session/abstract_dbm.rb, line 8 def initialize(app, path=nil, options={}) super(app, options) @mutex = Mutex.new db_path = path || (defined?(RACK_ROOT) ? ::File.join(RACK_ROOT, 'tmp', default_session_file) : @default_options[:dbm_path]) opts = @default_options @pool = dbklass.new(db_path) end
Public Instance Methods
destroy_session(env, session_id, options)
click to toggle source
# File lib/rack/session/abstract_dbm.rb, line 46 def destroy_session(env, session_id, options) with_lock(env) do @pool.delete(session_id) generate_sid unless options[:drop] end end
generate_sid()
click to toggle source
Calls superclass method
# File lib/rack/session/abstract_dbm.rb, line 18 def generate_sid loop do sid = super break sid unless @pool[sid] end end
get_session(env, sid)
click to toggle source
# File lib/rack/session/abstract_dbm.rb, line 25 def get_session(env, sid) with_lock(env, [nil, {}]) do unless sid and session = Marshal.load(@pool[sid] || "\x04\b0") sid, session = generate_sid, {} begin @pool[sid] = Marshal.dump(session) rescue raise "Session collision on '#{sid.inspect}'" end end [sid, session] end end
set_session(env, session_id, new_session, options)
click to toggle source
# File lib/rack/session/abstract_dbm.rb, line 39 def set_session(env, session_id, new_session, options) with_lock(env, false) do @pool[session_id] = Marshal.dump(new_session) session_id end end
with_lock(env, default=nil) { || ... }
click to toggle source
# File lib/rack/session/abstract_dbm.rb, line 53 def with_lock(env, default=nil) @mutex.lock if env['rack.multithread'] yield rescue StandardError if $VERBOSE warn "#{self} is unable to write to dbm." warn $!.inspect end default ensure @mutex.unlock if @mutex.locked? end