Abstract::ID
# File lib/rack/session/redis.rb, line 46 def destroy_session(env, session_id, options) with_lock(env) do @pool.del(session_id) generate_sid unless options[:drop] end end
# File lib/rack/session/redis.rb, line 20 def generate_sid loop do sid = super break sid unless @pool.get(sid) end end
# File lib/rack/session/redis.rb, line 27 def get_session(env, sid) with_lock(env, [nil, {}]) do unless sid and session = @pool.get(sid) sid, session = generate_sid, {} unless /^OK/ =~ @pool.set(sid, session, @default_options) raise "Session collision on '#{sid.inspect}'" end end [sid, session] end end
# File lib/rack/session/redis.rb, line 39 def set_session(env, session_id, new_session, options) with_lock(env, false) do @pool.set session_id, new_session, options session_id end end
# File lib/rack/session/redis.rb, line 53 def with_lock(env, default=nil) @mutex.lock if env['rack.multithread'] yield rescue Errno::ECONNREFUSED if $VERBOSE warn "#{self} is unable to find Redis server." warn $!.inspect end default ensure @mutex.unlock if @mutex.locked? end
Generated with the Darkfish Rdoc Generator 2.