X-Git-Url: http://code.vuplus.com/gitweb/?p=vuplus_dvbapp;a=blobdiff_plain;f=timer.py;h=42bafe350e4ac73f2a6fde81a703777f8549202e;hp=6c174c867e5f49226119d844fd06826aecb59971;hb=dc093daa0b0c4b12e33c30fb1b0b48c18ab8f8b5;hpb=7abf1d06a7a051f55708af14aef49ad7fea093ac diff --git a/timer.py b/timer.py index 6c174c8..42bafe3 100644 --- a/timer.py +++ b/timer.py @@ -27,6 +27,37 @@ 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" + print time.strftime("%c", time.localtime(self.begin)) + print time.strftime("%c", time.localtime(self.end)) + if (self.repeated != 0): + now = int(time.time()) + 1 + + day = [] + flags = self.repeated + for x in range(0, 7): + if (flags & 1 == 1): + day.append(0) + print "Day: " + str(x) + else: + day.append(1) + flags = flags >> 1 + + print time.strftime("%c", time.localtime(now)) + print time.strftime("%c", time.localtime(self.begin)) + print time.strftime("%c", time.localtime(self.end)) + print str(time.localtime(self.begin).tm_wday) + while ((day[time.localtime(self.begin).tm_wday] != 0) or ((day[time.localtime(self.begin).tm_wday] == 0) and self.end < now)): + print time.strftime("%c", time.localtime(self.begin)) + print time.strftime("%c", time.localtime(self.end)) + self.begin += 86400 + self.end += 86400 + def getTime(self): if self.state == self.StateWait: return self.begin - self.prepare_time @@ -65,8 +96,11 @@ class Timer: self.calcNextActivation() 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(): bisect.insort(self.timer_list, entry) if not noRecalc: @@ -104,16 +138,24 @@ class Timer: def timeChanged(self, timer): self.timer_list.remove(timer) + self.addTimerEntry(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