|
59 | 59 |
|
60 | 60 | it "calls keepalive on the sessions that need it" do |
61 | 61 | # update the session so it was last updated an hour ago |
62 | | - session.instance_variable_set :@last_updated_at, Time.now - 60*60 |
| 62 | + session.instance_variable_set :@last_updated_at, Process::clock_gettime(Process::CLOCK_MONOTONIC) - 60*60 |
63 | 63 | # set the session in the pool |
64 | 64 | pool.sessions_available = [session] |
65 | 65 | pool.sessions_in_use = {} |
|
78 | 78 |
|
79 | 79 | it "doesn't call keepalive on sessions that don't need it" do |
80 | 80 | # update the session so it was last updated now |
81 | | - session.instance_variable_set :@last_updated_at, Time.now |
| 81 | + session.instance_variable_set :@last_updated_at, Process::clock_gettime(Process::CLOCK_MONOTONIC) |
82 | 82 | # set the session in the pool |
83 | 83 | pool.sessions_available = [session] |
84 | 84 | pool.sessions_in_use = {} |
|
102 | 102 | pool.sessions_available = [session, session2, session3] |
103 | 103 | pool.instance_variable_set :@thread_pool, Concurrent::ImmediateExecutor.new |
104 | 104 | pool.instance_variable_set :@min, 2 |
105 | | - session.instance_variable_set :@last_updated_at, Time.now |
106 | | - session2.instance_variable_set :@last_updated_at, Time.now - 2000 |
107 | | - session3.instance_variable_set :@last_updated_at, Time.now - 2000 |
| 105 | + session.instance_variable_set :@last_updated_at, Process::clock_gettime(Process::CLOCK_MONOTONIC) |
| 106 | + session2.instance_variable_set :@last_updated_at, Process::clock_gettime(Process::CLOCK_MONOTONIC) - 2000 |
| 107 | + session3.instance_variable_set :@last_updated_at, Process::clock_gettime(Process::CLOCK_MONOTONIC) - 2000 |
108 | 108 |
|
109 | 109 | keepalive_log = [] |
110 | 110 | release_log = [] |
|
138 | 138 | pool.sessions_available = [session, session2] |
139 | 139 | pool.instance_variable_set :@thread_pool, Concurrent::ImmediateExecutor.new |
140 | 140 | pool.instance_variable_set :@min, 3 |
141 | | - session.instance_variable_set :@last_updated_at, Time.now |
142 | | - session2.instance_variable_set :@last_updated_at, Time.now - 2000 |
| 141 | + session.instance_variable_set :@last_updated_at, Process::clock_gettime(Process::CLOCK_MONOTONIC) |
| 142 | + session2.instance_variable_set :@last_updated_at, Process::clock_gettime(Process::CLOCK_MONOTONIC) - 2000 |
143 | 143 |
|
144 | 144 | keepalive_log = [] |
145 | 145 | session2.stub(:keepalive!, proc { keepalive_log << session2 }) do |
|
0 commit comments