Class: Rack::Session::Redis
- Inherits:
-
Abstract::ID
- Object
- Abstract::ID
- Rack::Session::Redis
- Includes:
- Merb::RedisStore
- Defined in:
- lib/rack/session/merb.rb,
lib/rack/session/redis.rb
Constant Summary collapse
- DEFAULT_OPTIONS =
Abstract::ID::DEFAULT_OPTIONS.merge :redis_server => "redis://127.0.0.1:6379/0"
Instance Attribute Summary collapse
-
#mutex ⇒ Object
readonly
Returns the value of attribute mutex.
-
#pool ⇒ Object
readonly
Returns the value of attribute pool.
Instance Method Summary collapse
- #generate_sid ⇒ Object
- #get_session(env, sid) ⇒ Object
-
#initialize(app, options = {}) ⇒ Redis
constructor
A new instance of Redis.
- #set_session(env, session_id, new_session, options) ⇒ Object
Methods included from Merb::RedisStore
#delete_session, #retrieve_session, #store_session
Constructor Details
Instance Attribute Details
#mutex ⇒ Object (readonly)
Returns the value of attribute mutex.
4 5 6 |
# File 'lib/rack/session/redis.rb', line 4 def mutex @mutex end |
#pool ⇒ Object (readonly)
Returns the value of attribute pool.
4 5 6 |
# File 'lib/rack/session/redis.rb', line 4 def pool @pool end |
Instance Method Details
#generate_sid ⇒ Object
13 14 15 16 17 18 |
# File 'lib/rack/session/redis.rb', line 13 def generate_sid loop do sid = super break sid unless @pool.get(sid) end end |
#get_session(env, sid) ⇒ Object
20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/rack/session/redis.rb', line 20 def get_session(env, sid) session = @pool.get(sid) if sid @mutex.lock if env['rack.multithread'] unless sid and session env['rack.errors'].puts("Session '#{sid.inspect}' not found, initializing...") if $VERBOSE and not sid.nil? session = {} sid = generate_sid ret = @pool.set sid, session raise "Session collision on '#{sid.inspect}'" unless ret end session.instance_variable_set('@old', {}.merge(session)) return [sid, session] rescue Errno::ECONNREFUSED warn "#{self} is unable to find server." warn $!.inspect return [ nil, {} ] ensure @mutex.unlock if env['rack.multithread'] end |
#set_session(env, session_id, new_session, options) ⇒ Object
40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 |
# File 'lib/rack/session/redis.rb', line 40 def set_session(env, session_id, new_session, ) @mutex.lock if env['rack.multithread'] session = @pool.get(session_id) rescue {} if [:renew] or [:drop] @pool.del session_id return false if [:drop] session_id = generate_sid @pool.set session_id, 0 end old_session = new_session.instance_variable_get('@old') || {} session = merge_sessions session_id, old_session, new_session, session @pool.set session_id, session, return session_id rescue Errno::ECONNREFUSED warn "#{self} is unable to find server." warn $!.inspect return false ensure @mutex.unlock if env['rack.multithread'] end |