# 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) end
# File lib/rack/session/dalli.rb, line 50 def destroy_session(env, session_id, options) with_lock(env) do @pool.delete(session_id) generate_sid unless options[:drop] end end
# File lib/rack/session/dalli.rb, line 21 def generate_sid loop do sid = super break sid unless @pool.get(sid) end end
# File lib/rack/session/dalli.rb, line 28 def get_session(env, sid) with_lock(env, [nil, {}]) do unless sid 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
# File lib/rack/session/dalli.rb, line 40 def set_session(env, session_id, new_session, options) 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
# File lib/rack/session/dalli.rb, line 57 def with_lock(env, default=nil) @mutex.lock if env['rack.multithread'] yield rescue ::Dalli::DalliError, Errno::ECONNREFUSED raise if $!.message =~ %rundefined class/ if $VERBOSE warn "#{self} is unable to find memcached server." warn $!.inspect end default ensure @mutex.unlock if @mutex.locked? end