2 import NavigationInstance
3 from time import localtime
4 from Components.NimManager import nimmanager
5 from ServiceReference import ServiceReference
6 from enigma import iServiceInformation, eServiceCenter
8 class TimerSanityCheck:
9 def __init__(self, timerlist, newtimer=None):
11 self.timerlist = timerlist
12 self.newtimer = newtimer
14 self.rep_eventlist = []
15 self.nrep_eventlist = []
19 def check(self, ext_timer=1):
22 self.newtimer = ext_timer
23 if self.newtimer is None:
26 self.simultimer = [ self.newtimer ]
27 return self.checkTimerlist()
30 def getSimulTimerList(self):
31 return self.simultimer
33 def doubleCheck(self):
34 if self.newtimer is not None and self.newtimer.service_ref.ref.valid():
35 self.simultimer = [ self.newtimer ]
36 for timer in self.timerlist:
37 if (timer == self.newtimer):
40 if timer.begin == self.newtimer.begin:
41 getUnsignedDataRef1 = timer.service_ref.ref.getUnsignedData
42 getUnsignedDataRef2 = self.newtimer.service_ref.ref.getUnsignedData
44 if getUnsignedDataRef1(x) != getUnsignedDataRef2(x):
50 def checkTimerlist(self, ext_timer=1):
51 #with special service for external plugins
52 # Entries in eventlist
54 # index -1 for the new Timer, 0..n index of the existing timers
55 # BeginEndFlag -1 for begin, +1 for end
56 # count of running timers
58 print "checkTimerlist"
59 # create a list with all start and end times
60 # split it into recurring and singleshot timers
62 ##################################################################################
63 # process the new timer
64 self.rep_eventlist = []
65 self.nrep_eventlist = []
67 self.newtimer = ext_timer
68 if (self.newtimer is not None) and (not self.newtimer.disabled):
69 if not self.newtimer.service_ref.ref.valid():
71 rflags = self.newtimer.repeated
72 rflags = ((rflags & 0x7F)>> 3)|((rflags & 0x07)<<4)
74 begin = self.newtimer.begin % 86400 # map to first day
75 while rflags: # then arrange on the week
77 self.rep_eventlist.append((begin, -1))
81 self.nrep_eventlist.extend([(self.newtimer.begin,-1,self.bflag),(self.newtimer.end,-1,self.eflag)])
83 ##################################################################################
84 # now process existing timers
86 for timer in self.timerlist:
87 if (timer != self.newtimer) and (not timer.disabled):
89 rflags = timer.repeated
90 rflags = ((rflags & 0x7F)>> 3)|((rflags & 0x07)<<4)
91 begin = timer.begin % 86400 # map all to first day
94 self.rep_eventlist.append((begin, idx))
98 self.nrep_eventlist.extend([(timer.begin,idx,self.bflag),(timer.end,idx,self.eflag)])
101 ################################################################################
102 # journalize timer repeations
103 if len(self.nrep_eventlist):
104 interval_begin = min(self.nrep_eventlist)[0]
105 interval_end = max(self.nrep_eventlist)[0]
106 offset_0 = interval_begin - (interval_begin % 604800)
107 weeks = (interval_end - offset_0) / 604800
108 if ((interval_end - offset_0) % 604800):
110 for cnt in range(weeks):
111 for event in self.rep_eventlist:
112 if event[1] == -1: # -1 is the identifier of the changed timer
113 event_begin = self.newtimer.begin
114 event_end = self.newtimer.end
116 event_begin = self.timerlist[event[1]].begin
117 event_end = self.timerlist[event[1]].end
118 new_event_begin = event[0] + offset_0 + (cnt * 604800)
119 # summertime correction
120 new_lth = localtime(new_event_begin).tm_hour
121 new_event_begin += 3600 * (localtime(event_begin).tm_hour - new_lth)
122 new_event_end = new_event_begin + (event_end - event_begin)
124 if new_event_begin >= self.newtimer.begin: # is the soap already running?
125 self.nrep_eventlist.extend([(new_event_begin, event[1], self.bflag),(new_event_end, event[1], self.eflag)])
127 if new_event_begin >= self.timerlist[event[1]].begin: # is the soap already running?
128 self.nrep_eventlist.extend([(new_event_begin, event[1], self.bflag),(new_event_end, event[1], self.eflag)])
130 offset_0 = 345600 # the Epoch begins on Thursday
131 weeks = 2 # test two weeks to take care of Sunday-Monday transitions
132 for cnt in range(weeks):
133 for event in self.rep_eventlist:
134 if event[1] == -1: # -1 is the identifier of the changed timer
135 event_begin = self.newtimer.begin
136 event_end = self.newtimer.end
138 event_begin = self.timerlist[event[1]].begin
139 event_end = self.timerlist[event[1]].end
140 new_event_begin = event[0] + offset_0 + (cnt * 604800)
141 new_event_end = new_event_begin + (event_end - event_begin)
142 self.nrep_eventlist.extend([(new_event_begin, event[1], self.bflag),(new_event_end, event[1], self.eflag)])
144 ################################################################################
145 # order list chronological
146 self.nrep_eventlist.sort()
148 ##################################################################################
149 # detect overlapping timers and overlapping times
152 ConflictTunerType = None
154 newTimerTunerType = None
155 newTimerTunerSlot = None
159 for event in self.nrep_eventlist:
161 if event[1] == -1: # new timer
162 timer = self.newtimer
164 timer = self.timerlist[event[1]]
165 if event[2] == self.bflag:
166 fakeRecService = NavigationInstance.instance.recordService(timer.service_ref)
167 feinfo = fakeRecService.frontendInfo().getFrontendData()
168 tunerType = feinfo.get("tuner_type")
169 tunerSlot = feinfo.get("tuner_number")
170 if event[1] == -1: # new timer
171 newTimerTunerType = tunerType
172 newTimerTunerSlot = tunerSlot
173 fakeRecResult = fakeRecService.start(True)
174 overlaplist.append((fakeRecResult, timer, tunerType, tunerSlot))
175 fakeRecList.append((timer, fakeRecService))
177 if ConflictTimer is None: # just take care of the first conflict
178 ConflictTimer = timer
179 ConflictTunerType = tunerType
180 ConflictSlot = tunerSlot
181 elif event[2] == self.eflag:
182 for fakeRec in fakeRecList:
183 if timer == fakeRec[0]:
184 NavigationInstance.instance.stopRecordService(fakeRec[1])
185 fakeRecList.remove(fakeRec)
186 if overlaplist.count(timer):
187 overlaplist.remove(timer)
189 print "Bug: unknown flag!"
190 self.nrep_eventlist[idx] = (event[0],event[1],event[2],cnt,overlaplist[:]) # insert a duplicate into current overlaplist
193 for fakeRec in fakeRecList:
194 NavigationInstance.instance.stopRecordService(fakeRec[1])
196 if ConflictTimer is None: # no conflict found :)
199 ##################################################################################
200 # we have detected a conflict, now we must figure out the involved timers
202 if self.newtimer is not None: # new timer?
203 if self.newtimer is not ConflictTimer: # the new timer is not the conflicting timer?
204 for event in self.nrep_eventlist:
205 if len(event[4]) > 1: # entry in overlaplist of this event??
208 for entry in event[4]:
209 if entry[1] is ConflictTimer:
211 if entry[1] is self.newtimer:
214 ConflictTimer = self.newtimer
215 ConflictTunerType = newTimerTunerType
216 ConflictSlot = newTimerTunerSlot
219 self.simultimer = [ ConflictTimer ]
220 for event in self.nrep_eventlist:
221 if len(event[4]) > 1: # entry in overlaplist of this event??
222 for entry in event[4]:
223 if entry[1] is ConflictTimer:
227 for entry in event[4]:
228 if not self.simultimer.count(entry[1]) and (entry[2] == ConflictTunerType or entry[3] == ConflictTunerSlot):
229 self.simultimer.append(entry[1])
231 if len(self.simultimer) < 2:
232 print "Bug: unknown Conflict!"
234 return False # conflict detected!