git.cweiske.de
/
enigma2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
check for running jobs before shutting down/rebooting
[enigma2.git]
/
lib
/
python
/
Components
/
Task.py
diff --git
a/lib/python/Components/Task.py
b/lib/python/Components/Task.py
index a87f58d9e0be534702cc084668531a4c68e0a10e..659660e82c56a0b351033828226d7dc7898f2b1b 100644
(file)
--- a/
lib/python/Components/Task.py
+++ b/
lib/python/Components/Task.py
@@
-37,6
+37,9
@@
class Job(object):
progress = property(getProgress)
progress = property(getProgress)
+ def getStatustext(self):
+ return { self.NOT_STARTED: _("Waiting"), self.IN_PROGRESS: _("In Progress"), self.FINISHED: _("Finished"), self.FAILED: _("Failed") }[self.status]
+
def task_progress_changed_CB(self):
self.state_changed()
def task_progress_changed_CB(self):
self.state_changed()
@@
-244,6
+247,7
@@
class JobManager:
self.active_jobs = [ ]
self.failed_jobs = [ ]
self.job_classes = [ ]
self.active_jobs = [ ]
self.failed_jobs = [ ]
self.job_classes = [ ]
+ self.in_background = False
self.active_job = None
def AddJob(self, job):
self.active_job = None
def AddJob(self, job):
@@
-258,8
+262,11
@@
class JobManager:
def jobDone(self, job, task, problems):
print "job", job, "completed with", problems, "in", task
def jobDone(self, job, task, problems):
print "job", job, "completed with", problems, "in", task
+ from Tools import Notifications
+ if self.in_background:
+ from Screens.TaskView import JobView
+ Notifications.AddNotification(JobView, self.active_job)
if problems:
if problems:
- from Tools import Notifications
from Screens.MessageBox import MessageBox
if problems[0].RECOVERABLE:
Notifications.AddNotificationWithCallback(self.errorCB, MessageBox, _("Error: %s\nRetry?") % (problems[0].getErrorMessage(task)))
from Screens.MessageBox import MessageBox
if problems[0].RECOVERABLE:
Notifications.AddNotificationWithCallback(self.errorCB, MessageBox, _("Error: %s\nRetry?") % (problems[0].getErrorMessage(task)))
@@
-282,6
+289,12
@@
class JobManager:
self.active_job = None
self.kick()
self.active_job = None
self.kick()
+ def getPendingJobs(self):
+ list = [ ]
+ if self.active_job:
+ list.append(self.active_job)
+ list += self.active_jobs
+ return list
# some examples:
#class PartitionExistsPostcondition:
# def __init__(self, device):
# some examples:
#class PartitionExistsPostcondition:
# def __init__(self, device):