+from enigma import quitMainloop, iRecordableService
+from Screens.MessageBox import MessageBox
+from time import time
+from Components.Task import job_manager
+
+inTryQuitMainloop = False
+
+class TryQuitMainloop(MessageBox):
+ def __init__(self, session, retvalue=1, timeout=-1, default_yes = True):
+ self.retval=retvalue
+ recordings = session.nav.getRecordings()
+ jobs = len(job_manager.getPendingJobs())
+ self.connected = False
+ reason = ""
+ next_rec_time = -1
+ if not recordings:
+ next_rec_time = session.nav.RecordTimer.getNextRecordingTime()
+ if recordings or (next_rec_time > 0 and (next_rec_time - time()) < 360):
+ reason = _("Recording(s) are in progress or coming up in few seconds!") + '\n'
+ if jobs:
+ if jobs == 1:
+ job = job_manager.getPendingJobs()[0]
+ reason += "%s: %s (%d%%)\n" % (job.getStatustext(), job.name, int(100*job.progress/float(job.end)))
+ else:
+ reason += (_("%d jobs are running in the background!") % jobs) + '\n'
+ if reason:
+ if retvalue == 1:
+ MessageBox.__init__(self, session, reason+_("Really shutdown now?"), type = MessageBox.TYPE_YESNO, timeout = timeout, default = default_yes)
+ elif retvalue == 2:
+ MessageBox.__init__(self, session, reason+_("Really reboot now?"), type = MessageBox.TYPE_YESNO, timeout = timeout, default = default_yes)
+ elif retvalue == 4:
+ pass
+ else:
+ MessageBox.__init__(self, session, reason+_("Really restart now?"), type = MessageBox.TYPE_YESNO, timeout = timeout, default = default_yes)
+ self.skinName = "MessageBox"
+ session.nav.record_event.append(self.getRecordEvent)
+ self.connected = True
+ self.onShow.append(self.__onShow)
+ self.onHide.append(self.__onHide)
+ else:
+ self.skin = """<screen position="0,0" size="0,0"/>"""
+ Screen.__init__(self, session)
+ self.close(True)
+
+ def getRecordEvent(self, recservice, event):
+ if event == iRecordableService.evEnd:
+ recordings = self.session.nav.getRecordings()
+ if not recordings: # no more recordings exist
+ rec_time = self.session.nav.RecordTimer.getNextRecordingTime()
+ if rec_time > 0 and (rec_time - time()) < 360:
+ self.initTimeout(360) # wait for next starting timer
+ self.startTimer()
+ else:
+ self.close(True) # immediate shutdown
+ elif event == iRecordableService.evStart:
+ self.stopTimer()
+
+ def close(self, value):
+ if self.connected:
+ self.conntected=False
+ self.session.nav.record_event.remove(self.getRecordEvent)
+ if value:
+ # hack .. we dont like to show any other screens when this screen has closed
+ self.onClose = [self.__closed]
+ self.session.dialog_stack = []
+ self.session.summary_stack = [None]
+ MessageBox.close(self, True)
+
+ def __closed(self):
+ quitMainloop(self.retval)
+
+ def __onShow(self):
+ global inTryQuitMainloop
+ inTryQuitMainloop = True
+
+ def __onHide(self):
+ global inTryQuitMainloop
+ inTryQuitMainloop = False