X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/365370295e04bdd056f6dd1c5e1523ec3f66e5b3..fcf3e4bc055cd91a47a5aedc91abad9161e180fc:/RecordTimer.py diff --git a/RecordTimer.py b/RecordTimer.py index 215f9c3a..de4f6cc1 100644 --- a/RecordTimer.py +++ b/RecordTimer.py @@ -482,27 +482,19 @@ class RecordTimer(timer.Timer): file.close() def getNextZapTime(self): - llen = len(self.timer_list) - idx = 0 now = time.time() - while idx < llen: - timer = self.timer_list[idx] + for timer in self.timer_list: if not timer.justplay or timer.begin < now: - idx += 1 - else: - return timer.begin + continue + return timer.begin return -1 def getNextRecordingTime(self): - llen = len(self.timer_list) - idx = 0 now = time.time() - while idx < llen: - timer = self.timer_list[idx] + for timer in self.timer_list: if timer.justplay or timer.begin < now: - idx += 1 - else: - return timer.begin + continue + return timer.begin return -1 def record(self, entry): @@ -510,6 +502,7 @@ class RecordTimer(timer.Timer): print "[Timer] Record " + str(entry) entry.Timer = self self.addTimerEntry(entry) + self.saveTimer() def isInTimer(self, eventid, begin, duration, service): time_match = 0 @@ -531,10 +524,20 @@ class RecordTimer(timer.Timer): sref.setUnsignedData(5, 0) sref.setUnsignedData(6, 0) check = x.service_ref.ref.toCompareString() == str(service) + num = 0 + if check: + check = False + event = eEPGCache.getInstance().lookupEventId(sref, eventid) + num = event and event.getNumOfLinkageServices() or 0 sref.setUnsignedData(1, sid) sref.setUnsignedData(2, tsid) sref.setUnsignedData(5, parent_sid) sref.setUnsignedData(6, parent_tsid) + for cnt in range(num): + subservice = event.getLinkageService(sref, cnt) + if sref.toCompareString() == subservice.toCompareString(): + check = True + break if check: #if x.eit is not None and x.repeated == 0: # if x.eit == eventid: @@ -581,6 +584,7 @@ class RecordTimer(timer.Timer): print "in running: ", entry in self.timer_list # now the timer should be in the processed_timers list. remove it from there. self.processed_timers.remove(entry) + self.saveTimer() def shutdown(self): self.saveTimer()