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