Class: Merb::MemorySessionStore

Inherits:

Object

• Object
• Merb::MemorySessionStore

show all

Defined in:

merb-core/lib/merb-core/dispatch/session/memory.rb

Overview

Instance Method Summary (collapse)

• - (Object) delete_session(session_id) private
• - (MemorySessionStore) initialize(ttl = nil) constructor private

  A new instance of MemorySessionStore.

• - (Object) reap_expired_sessions private

  Deletes any sessions that have reached their maximum validity.

• - (Object) retrieve_session(session_id) private
• - (Object) start_timer private

  Starts the timer that will eventually reap outdated sessions.

• - (Object) store_session(session_id, data) private

45
46
47
48
49
50
51

# File 'merb-core/lib/merb-core/dispatch/session/memory.rb', line 45

def initialize(ttl=nil)
  @sessions = Hash.new
  @timestamps = Hash.new
  @mutex = Mutex.new
  @session_ttl = ttl || Merb::Const::HOUR # defaults 1 hour
  start_timer
end

70
71
72
73
74
75

# File 'merb-core/lib/merb-core/dispatch/session/memory.rb', line 70

def delete_session(session_id)
  @mutex.synchronize {
    @timestamps.delete(session_id)
    @sessions.delete(session_id)
  }
end

80
81
82
83
84
85

# File 'merb-core/lib/merb-core/dispatch/session/memory.rb', line 80

def reap_expired_sessions
  @timestamps.each do |session_id,stamp|
    delete_session(session_id) if (stamp + @session_ttl) < Time.now 
  end
  GC.start
end

54
55
56
57
58
59

# File 'merb-core/lib/merb-core/dispatch/session/memory.rb', line 54

def retrieve_session(session_id)
  @mutex.synchronize {
    @timestamps[session_id] = Time.now
    @sessions[session_id]
  }
end

90
91
92
93
94
95
96
97

# File 'merb-core/lib/merb-core/dispatch/session/memory.rb', line 90

def start_timer
  Thread.new do
    loop {
      sleep @session_ttl
      reap_expired_sessions
    } 
  end  
end

62
63
64
65
66
67

# File 'merb-core/lib/merb-core/dispatch/session/memory.rb', line 62

def store_session(session_id, data)
  @mutex.synchronize {
    @timestamps[session_id] = Time.now
    @sessions[session_id] = data
  }
end