lib/rsched/engine.rb in rsched-0.3.2 vs lib/rsched/engine.rb in rsched-0.3.3
- old
+ new
@@ -178,11 +178,11 @@
false
end
end
def cleanup_old_entries(ident)
- @lock.delete_before(ident, Time.now.to_i-@delete)
+ @lock.delete_before(ident, Time.now.to_i-@delete-@delay)
end
class TimerThread
include MonitorMixin
@@ -245,10 +245,10 @@
end
def try_extend(now, token)
if now > @extend_time
puts "extending token=#{token.inspect}"
- @lock.extend_timeout(token, now)
+ @lock.extend_timeout(token)
@extend_time = now + @extend_timeout
end
end
def try_kill(now, token)