projects
/
vuplus_dvbapp
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Support duo4k.
[vuplus_dvbapp]
/
lib
/
python
/
Components
/
Task.py
diff --git
a/lib/python/Components/Task.py
b/lib/python/Components/Task.py
index
a1e04bc
..
8676923
100644
(file)
--- a/
lib/python/Components/Task.py
+++ b/
lib/python/Components/Task.py
@@
-16,6
+16,7
@@
class Job(object):
self.end = 100
self.__progress = 0
self.weightScale = 1
self.end = 100
self.__progress = 0
self.weightScale = 1
+ self.afterEvent = None
self.state_changed = CList()
self.state_changed = CList()
@@
-63,11
+64,10
@@
class Job(object):
def runNext(self):
if self.current_task == len(self.tasks):
if len(self.resident_tasks) == 0:
def runNext(self):
if self.current_task == len(self.tasks):
if len(self.resident_tasks) == 0:
- cb = self.callback
- self.callback = None
self.status = self.FINISHED
self.state_changed()
self.status = self.FINISHED
self.state_changed()
- cb(self, None, [])
+ self.callback(self, None, [])
+ self.callback = None
else:
print "still waiting for %d resident task(s) %s to finish" % (len(self.resident_tasks), str(self.resident_tasks))
else:
else:
print "still waiting for %d resident task(s) %s to finish" % (len(self.resident_tasks), str(self.resident_tasks))
else:
@@
-108,7
+108,6
@@
class Job(object):
self.tasks[i].abort()
def cancel(self):
self.tasks[i].abort()
def cancel(self):
- # some Jobs might have a better idea of how to cancel a job
self.abort()
class Task(object):
self.abort()
class Task(object):
@@
-305,6
+304,7
@@
class JobManager:
list.append(self.active_job)
list += self.active_jobs
return list
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):