Class: Rack::Session::Redis

Inherits:
Abstract::ID
  • Object
show all
Defined in:
lib/rack/session/redis.rb

Constant Summary collapse

DEFAULT_OPTIONS = 
Abstract::ID::DEFAULT_OPTIONS.merge \
:redis_server => 'redis://127.0.0.1:6379/0/rack:session'

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(app, options = {}) ⇒ Redis

Returns a new instance of Redis.



13
14
15
16
17
18
 
# File 'lib/rack/session/redis.rb', line 13

def initialize(app, options = {})
  super

  @mutex = Mutex.new
  @pool = ::Redis::Store::Factory.create @default_options[:redis_server]
end

Instance Attribute Details

#mutex ⇒ Object (readonly)

Returns the value of attribute mutex.



8
9
10
 
# File 'lib/rack/session/redis.rb', line 8

def mutex
  @mutex
end

#pool ⇒ Object (readonly)

Returns the value of attribute pool.



8
9
10
 
# File 'lib/rack/session/redis.rb', line 8

def pool
  @pool
end

Instance Method Details

#destroy_session(env, session_id, options) ⇒ Object 



46
47
48
49
50
51
 
# 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

#generate_sid ⇒ Object 



20
21
22
23
24
25
 
# File 'lib/rack/session/redis.rb', line 20

def generate_sid
  loop do
    sid = super
    break sid unless @pool.get(sid)
  end
end

#get_session(env, sid) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
 
# 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

#set_session(env, session_id, new_session, options) ⇒ Object 



39
40
41
42
43
44
 
# 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

#with_lock(env, default = nil) ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
 
# 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