X-Git-Url: http://code.vuplus.com/gitweb/?a=blobdiff_plain;f=timer.py;h=bbad0be1ec004dc5238784f2d6076214967b5aa2;hb=8bd62c4086556c08908ba18292b47509e56d4d61;hp=7855c0989b4cbd5b3160719c73ef2ccf80b86ab3;hpb=d49e2877599ede3ac725f96f2d241b1d7369ca43;p=vuplus_dvbapp diff --git a/timer.py b/timer.py index 7855c09..bbad0be 100644 --- a/timer.py +++ b/timer.py @@ -27,6 +27,9 @@ class TimerEntry: self.repeated |= (2 ** day) print "Repeated: " + str(self.repeated) + def isRunning(self): + return self.state == self.StateRunning + # update self.begin and self.end according to the self.repeated-flags def processRepeated(self): print "ProcessRepeated" @@ -95,15 +98,15 @@ class Timer: def addTimerEntry(self, entry, noRecalc=0): entry.processRepeated() - # we either go trough Prepare/Start/End-state if the timer is still running, - # or skip it when it's alrady past the end. - - if entry.end > time.time(): + # when the timer has not yet started, and is already passed, + # don't go trough waiting/running/end-states, but sort it + # right into the processedTimers. + if entry.end <= time.time() and entry.state == TimerEntry.StateWait: + bisect.insort(self.processed_timers, entry) + else: bisect.insort(self.timer_list, entry) if not noRecalc: self.calcNextActivation() - else: - bisect.insort(self.processed_timers, entry) def setNextActivation(self, when): delay = int((when - time.time()) * 1000) @@ -141,17 +144,18 @@ class Timer: def doActivate(self, w): w.activate(w.state) self.timer_list.remove(w) - + w.state += 1 if w.state < TimerEntry.StateEnded: bisect.insort(self.timer_list, w) else: - bisect.insort(self.processed_timers, w) if (w.repeated != 0): w.processRepeated() w.state = TimerEntry.StateWait self.addTimerEntry(w) - + else: + bisect.insort(self.processed_timers, w) + def processActivation(self): t = int(time.time()) + 1