class Rufus::Scheduler::EveryJob
def check_frequency
def check_frequency fail ArgumentError.new( "job frequency (#{@frequency}s) is higher than " + "scheduler frequency (#{@scheduler.frequency}s)" ) if @frequency < @scheduler.frequency end
def initialize(scheduler, duration, opts, block)
def initialize(scheduler, duration, opts, block) super(scheduler, duration, opts, block) @frequency = Rufus::Scheduler.parse_in(@original) fail ArgumentError.new( "cannot schedule #{self.class} with a frequency " + "of #{@frequency.inspect} (#{@original.inspect})" ) if @frequency <= 0 set_next_time(nil) end
def next_time_from(time)
def next_time_from(time) time + @frequency end
def set_next_time(trigger_time, is_post=false, now=nil)
def set_next_time(trigger_time, is_post=false, now=nil) return if is_post n = now || EoTime.now return @next_time = @first_at \ if @first_at && (trigger_time == nil || @first_at > n) dp = discard_past? loop do @next_time = (@next_time || n) + @frequency break if dp == false break if @next_time > n end end