[bitbake-devel] [PATCH 2/3] cooker: send event when terminated by disk monitor
Kang Kai
Kai.Kang at windriver.com
Fri Jul 27 09:33:23 UTC 2012
On 2012年07月26日 18:32, Richard Purdie wrote:
> On Thu, 2012-07-26 at 17:39 +0800, Kang Kai wrote:
>> Part of [Yocto #2168]
>>
>> Add a event DiskFull to descript the termination by disk monitor.
>>
>> According to the return info from function diskMonitor.check, runqueue
>> pass it to cooker. The cooker check the info and send event DiskFull
>> when runqueue terminated by disk monitor.
>>
>> The UIs could get the infomation from the event DiskFull.
>>
>> Signed-off-by: Kang Kai<kai.kang at windriver.com>
>> ---
>> bitbake/lib/bb/cooker.py | 14 ++++++++++++--
>> bitbake/lib/bb/event.py | 8 ++++++++
>> bitbake/lib/bb/runqueue.py | 9 +++++----
>> 3 files changed, 25 insertions(+), 6 deletions(-)
Hi Richard,
> This is good and heading the right way but why can't self.dm.check fire
> the event itself? This appears to unnecessarily complicate code...
Thank you.
I have send the Version 3.
Regards,
Kai
>
> Cheers,
>
> Richard
>
>> diff --git a/bitbake/lib/bb/cooker.py b/bitbake/lib/bb/cooker.py
>> index 5d01af3..d8341b9 100644
>> --- a/bitbake/lib/bb/cooker.py
>> +++ b/bitbake/lib/bb/cooker.py
>> @@ -1095,7 +1095,7 @@ class BBCooker:
>> rq.finish_runqueue(False)
>> failures = 0
>> try:
>> - retval = rq.execute_runqueue()
>> + retval, dmdata = rq.execute_runqueue()
>> except runqueue.TaskFailure as exc:
>> failures += len(exc.args)
>> retval = False
>> @@ -1103,6 +1103,11 @@ class BBCooker:
>> self.command.finishAsyncCommand()
>> return False
>>
>> + if 'terminated' in dmdata and dmdata['terminated']:
>> + bb.event.fire(bb.event.DiskFull(dmdata['dev'], dmdata['type'], dmdata['freespace'], dmdata['mountpoint']), self.configuration.event_data)
>> + self.command.finishAsyncCommand()
>> + return False
>> +
>> if not retval:
>> bb.event.fire(bb.event.BuildCompleted(len(rq.rqdata.runq_fnid), buildname, item, failures), self.configuration.event_data)
>> self.command.finishAsyncCommand()
>> @@ -1135,7 +1140,7 @@ class BBCooker:
>> rq.finish_runqueue(False)
>> failures = 0
>> try:
>> - retval = rq.execute_runqueue()
>> + retval, dmdata = rq.execute_runqueue()
>> except runqueue.TaskFailure as exc:
>> failures += len(exc.args)
>> retval = False
>> @@ -1143,6 +1148,11 @@ class BBCooker:
>> self.command.finishAsyncCommand()
>> return False
>>
>> + if 'terminated' in dmdata and dmdata['terminated']:
>> + bb.event.fire(bb.event.DiskFull(dmdata['dev'], dmdata['type'], dmdata['freespace'], dmdata['mountpoint']), self.configuration.event_data)
>> + self.command.finishAsyncCommand()
>> + return False
>> +
>> if not retval:
>> bb.event.fire(bb.event.BuildCompleted(len(rq.rqdata.runq_fnid), buildname, targets, failures), self.configuration.data)
>> self.command.finishAsyncCommand()
>> diff --git a/bitbake/lib/bb/event.py b/bitbake/lib/bb/event.py
>> index 1116c0a..20923b5 100644
>> --- a/bitbake/lib/bb/event.py
>> +++ b/bitbake/lib/bb/event.py
>> @@ -312,6 +312,14 @@ class BuildCompleted(BuildBase, OperationCompleted):
>> OperationCompleted.__init__(self, total, "Building Failed")
>> BuildBase.__init__(self, n, p, failures)
>>
>> +class DiskFull(Event):
>> + """Disk full case build aborted"""
>> + def __init__(self, dev, type, freespace, mountpoint):
>> + Event.__init__(self)
>> + self._dev = dev
>> + self._type = type
>> + self._free = freespace
>> + self._mountpoint = mountpoint
>>
>> class NoProvider(Event):
>> """No Provider for an Event"""
>> diff --git a/bitbake/lib/bb/runqueue.py b/bitbake/lib/bb/runqueue.py
>> index 0a8c723..233e6a9 100644
>> --- a/bitbake/lib/bb/runqueue.py
>> +++ b/bitbake/lib/bb/runqueue.py
>> @@ -867,6 +867,7 @@ class RunQueue:
>> """
>>
>> retval = 0.5
>> + dmdata = {}
>>
>> if self.state is runQueuePrepare:
>> self.rqexe = RunQueueExecuteDummy(self)
>> @@ -882,7 +883,7 @@ class RunQueue:
>> self.rqexe = RunQueueExecuteScenequeue(self)
>>
>> if self.state in [runQueueSceneRun, runQueueRunning, runQueueCleanUp]:
>> - self.dm.check(self)
>> + dmdata = self.dm.check(self)
>>
>> if self.state is runQueueSceneRun:
>> retval = self.rqexe.execute()
>> @@ -914,14 +915,14 @@ class RunQueue:
>>
>> if self.state is runQueueComplete:
>> # All done
>> - return False
>> + return False, dmdata
>>
>> if self.state is runQueueChildProcess:
>> print("Child process, eeek, shouldn't happen!")
>> - return False
>> + return False, dmdata
>>
>> # Loop
>> - return retval
>> + return retval, dmdata
>>
>> def finish_runqueue(self, now = False):
>> if not self.rqexe:
>
>
More information about the bitbake-devel
mailing list