class Rack::Session::Dalli
Constants
- DEFAULT_OPTIONS
Attributes
mutex[R]
pool[R]
Public Class Methods
new(app, options={})
click to toggle source
Calls superclass method
# File lib/rack/session/dalli.rb, line 13 def initialize(app, options={}) super @mutex = Mutex.new mserv = @default_options[:memcache_server] mopts = @default_options.reject{|k,v| !DEFAULT_OPTIONS.include? k } @pool = options[:cache] || ::Dalli::Client.new(mserv, mopts) @pool.alive! end
Public Instance Methods
destroy_session(env, session_id, options)
click to toggle source
# File lib/rack/session/dalli.rb, line 52 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/dalli.rb, line 22 def generate_sid loop do sid = super break sid unless @pool.get(sid) end end
get_session(env, sid)
click to toggle source
# File lib/rack/session/dalli.rb, line 29 def get_session(env, sid) with_lock(env, [nil, {}]) do unless sid and !sid.empty? and session = @pool.get(sid) sid, session = generate_sid, {} unless @pool.add(sid, session) 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/dalli.rb, line 41 def set_session(env, session_id, new_session, options) return false unless session_id expiry = options[:expire_after] expiry = expiry.nil? ? 0 : expiry + 1 with_lock(env, false) do @pool.set session_id, new_session, expiry session_id end end
with_lock(env, default=nil) { || ... }
click to toggle source
# File lib/rack/session/dalli.rb, line 59 def with_lock(env, default=nil) @mutex.lock if env['rack.multithread'] yield rescue ::Dalli::DalliError, Errno::ECONNREFUSED raise if $!.message =~ /undefined class/ if $VERBOSE warn "#{self} is unable to find memcached server." warn $!.inspect end default ensure @mutex.unlock if @mutex.locked? end