Class: Rack::Session::Pool
- Inherits:
-
Abstract::Persisted
- Object
- Abstract::Persisted
- Rack::Session::Pool
- Defined in:
- lib/rack/session/pool.rb
Overview
Rack::Session::Pool provides simple cookie based session management. Session data is stored in a hash held by @pool. In the context of a multithreaded environment, sessions being committed to the pool is done in a merging manner.
The :drop option is available in rack.session.options if you wish to explicitly remove the session from the session cache.
Example:
myapp = MyRackApp.new
sessioned = Rack::Session::Pool.new(myapp,
:domain => 'foo.com',
:expire_after => 2592000
)
Rack::Handler::WEBrick.run sessioned
Constant Summary collapse
- DEFAULT_OPTIONS =
Abstract::ID::DEFAULT_OPTIONS.merge :drop => false
Instance Attribute Summary collapse
-
#mutex ⇒ Object
readonly
Returns the value of attribute mutex.
-
#pool ⇒ Object
readonly
Returns the value of attribute pool.
Attributes inherited from Abstract::Persisted
#default_options, #key, #sid_secure
Instance Method Summary collapse
- #delete_session(req, session_id, options) ⇒ Object
- #find_session(req, sid) ⇒ Object
- #generate_sid ⇒ Object
-
#initialize(app, options = {}) ⇒ Pool
constructor
A new instance of Pool.
- #with_lock(req) ⇒ Object
- #write_session(req, session_id, new_session, options) ⇒ Object
Methods inherited from Abstract::Persisted
#call, #commit_session, #context
Constructor Details
#initialize(app, options = {}) ⇒ Pool
Returns a new instance of Pool.
31 32 33 34 35 |
# File 'lib/rack/session/pool.rb', line 31 def initialize(app, ={}) super @pool = Hash.new @mutex = Mutex.new end |
Instance Attribute Details
#mutex ⇒ Object (readonly)
Returns the value of attribute mutex.
28 29 30 |
# File 'lib/rack/session/pool.rb', line 28 def mutex @mutex end |
#pool ⇒ Object (readonly)
Returns the value of attribute pool.
28 29 30 |
# File 'lib/rack/session/pool.rb', line 28 def pool @pool end |
Instance Method Details
#delete_session(req, session_id, options) ⇒ Object
61 62 63 64 65 66 |
# File 'lib/rack/session/pool.rb', line 61 def delete_session(req, session_id, ) with_lock(req) do @pool.delete(session_id) generate_sid unless [:drop] end end |
#find_session(req, sid) ⇒ Object
44 45 46 47 48 49 50 51 52 |
# File 'lib/rack/session/pool.rb', line 44 def find_session(req, sid) with_lock(req) do unless sid and session = @pool[sid] sid, session = generate_sid, {} @pool.store sid, session end [sid, session] end end |
#generate_sid ⇒ Object
37 38 39 40 41 42 |
# File 'lib/rack/session/pool.rb', line 37 def generate_sid loop do sid = super break sid unless @pool.key? sid end end |
#with_lock(req) ⇒ Object
68 69 70 71 72 73 |
# File 'lib/rack/session/pool.rb', line 68 def with_lock(req) @mutex.lock if req.multithread? yield ensure @mutex.unlock if @mutex.locked? end |
#write_session(req, session_id, new_session, options) ⇒ Object
54 55 56 57 58 59 |
# File 'lib/rack/session/pool.rb', line 54 def write_session(req, session_id, new_session, ) with_lock(req) do @pool.store session_id, new_session session_id end end |