Ñò „Pc @sçdZddkZddkZyddklZWn#ej oddklZnXddklZlZl Z l Z dZ dei i fd„ƒYZeƒad„Zd „Zd „Zeieƒd efd „ƒYZdS( s+ Runner.py: Task scheduling and execution iÿÿÿÿN(tQueue(tUtilstTasktErrorstLogsi t TaskConsumercBs)eZdZd„Zd„Zd„ZRS(st Task consumers belong to a pool of workers They wait for tasks in the queue and then use ``task.process(...)`` cCs:tiii|ƒtƒ|_|idƒ|iƒdS(Ni(Rt threadingtThreadt__init__Rtreadyt setDaemontstart(tself((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyRs  cCs(y|iƒWntj onXdS(s$ Loop over the tasks to execute N(tloopt Exception(R ((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytrun%scCsDx=|iiƒ}t|tiƒp||ƒq|iƒqdS(s  Obtain tasks from :py:attr:`waflib.Runner.TaskConsumer.ready` and call :py:meth:`waflib.Task.TaskBase.process`. If the object is a function, execute it. N(R tgett isinstanceRtTaskBasetprocess(R ttsk((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyR .s (t__name__t __module__t__doc__RRR (((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyRs cCs/ytitƒSWntj o tƒSXdS(sæ Obtain a task consumer from :py:attr:`waflib.Runner.pool`. Do not forget to put it back by using :py:func:`waflib.Runner.put_pool` and reset properly (original waiting queue). :rtype: :py:class:`waflib.Runner.TaskConsumer` N(tpoolRtFalseRR(((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytget_pool?scCsti|ƒdS(s Return a task consumer to the thread pool :py:attr:`waflib.Runner.pool` :param x: task consumer object :type x: :py:class:`waflib.Runner.TaskConsumer` N(Rtput(tx((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytput_poolLscCstg}x%tiƒo|itiƒƒq Wx|D]}|iidƒq5Wx|D]}|iƒqVWdadS(N(RtqsizetappendRR RtNonetjoin(tlstR((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyt_free_resourcesUs tParallelcBsteZdZdd„Zd„Zd„Zd„Zd„Zd„Zd„Z d „Z d „Z d „Z d „Z RS( sE Schedule the tasks obtained from the build context for execution. icCsm||_||_g|_g|_tdƒ|_d|_d|_t|_ g|_ d|_ t|_ dS(se The initialization requires a build context reference for computing the total number of jobs. iiN(tnumjobstbldt outstandingtfrozenRtouttcountt processedRtstopterrorR tbitertdirty(R R&tj((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyRes          cCs|ipdS|iidƒS(sR Obtain the next task to execute. :rtype: :py:class:`waflib.Task.TaskBase` iN(R'R tpop(R ((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyt get_next_tasks cCs>tiddƒo|iid|ƒn|ii|ƒdS(s­ A task cannot be executed at this point, put it in the list :py:attr:`waflib.Runner.Parallel.frozen`. :param tsk: task :type tsk: :py:class:`waflib.Task.TaskBase` iiN(trandomtrandintR(tinsertR(R R((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytpostponešscCs·x&|i|itjo|iƒqWx‡|ip||io|iƒnþ|ioóy|i|ij}Wntj on¹X|o°d}x&|iD]}|i p d}Pq›q›Wg}xR|iD]G}|i dt |ƒg}|i D]}|t |ƒqð~fƒqÊWt id|di|ƒfƒ‚n|i|_n|io|i|i7_g|_q,|ip0|iit|iƒƒ|iiƒ|_Pq,q,WdS(s^ Put the next group of tasks to execute in :py:attr:`waflib.Runner.Parallel.outstanding`. s#check the build order for the taskss!check the methods runnable_statuss%s -> %rsDeadlock detected: %s%stN(R*R%tGAPtget_outR'R(tdeadlockR+tAttributeErrort run_afterRtreprtidRtWafErrorR!textendtnextR.R&ttotal(R tcondtmsgRR"t_[1]R((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytrefill_task_list¦s@       E&   cCsEt|ddƒo.|i|i7_|it|iƒ7_ndS(s½ Tasks may be added dynamically during the build by binding them to the task :py:attr:`waflib.Task.TaskBase.more_tasks` :param tsk: task :type tsk: :py:attr:`waflib.Task.TaskBase` t more_tasksN(tgetattrR R'RGRBtlen(R R((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytadd_more_tasksÊscCsF|iiƒ}|ip|i|ƒn|id8_t|_|S(sÕ Obtain one task returned from the task consumers, and update the task count. Add more tasks if necessary through :py:attr:`waflib.Runner.Parallel.add_more_tasks`. :rtype: :py:attr:`waflib.Task.TaskBase` i(R)RR,RJR*tTrueR/(R R((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyR9Õs   cCs.|iip t|_n|ii|ƒdS(sÞ Called when a task cannot be executed. The flag :py:attr:`waflib.Runner.Parallel.stop` is set, unless the build is executed with:: $ waf build -k :param tsk: task :type tsk: :py:attr:`waflib.Task.TaskBase` N(R&tkeepRKR,R-R(R R((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyt error_handlerãs  cCs?y |iWntj o|iƒnX|ii|ƒdS(sa Pass a task to a consumer. :param tsk: task :type tsk: :py:attr:`waflib.Task.TaskBase` N(RR;tinit_task_poolR R(R R((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytadd_taskñs  cswg}tˆiƒD]}|tƒq~}ˆ_tdƒˆ_‡fd†}x|D]}|ii|ƒqYW|S(Nicsˆi|_dS(N(R (tconsumer(R (s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytsetqs(trangeR%RRRR R(R REtiRRQR((R s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyRNþs4c s–‡fd†}y ˆi}Wntj onbXx|D]}ˆii|ƒq9Wx|D]}ˆiƒqZWx|D]}t|ƒquWgˆ_dS(Ncs#tdƒ|_ˆiiˆƒdS(Ni(RR R)R(RP(R (s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyRQ s(RR;R RR9R(R RQRR((R s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pytfree_task_pools cCs|iiƒ|_x3|ip(|iƒ|iƒ}|p|ioqqRPn|io|id7_qn|ioPny|iƒ}Wnët j oß|id7_t i ƒ|_ |i o“|ii o†ti|_|ii djo<tidjp |i o|ii|ƒnt|_qtidjo|ii|ƒqqnti|_|i|ƒqnX|tijo|i|ƒq|tijo,|id7_ti|_|i|ƒq|i|if|_|id7_||_|id7_|idjo|iƒq|i|ƒqWx#|io|io|i ƒqKW|idjp|ipt!‚|i"ƒdS(sË Give tasks to :py:class:`waflib.Runner.TaskConsumer` instances until the build finishes or the ``stop`` flag is set. If only one job is used, then execute the tasks one by one, without consumers. iiN(#R&RBR,RFR2R*thasrunR+trunnable_statusRRtex_stackterr_msgRLRtSKIPPEDRtverboseR-RRKt EXCEPTIONRMt ASK_LATERR6tSKIP_MERJtpositiontmasterR%RROR9tAssertionErrorRT(R Rtst((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyR sb            !(RRRRR2R6RFRJR9RMRORNRTR (((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyR$as + $   (RR3tatexittqueueRt ImportErrortwaflibRRRRR8RRRRRRR#tregistertobjectR$(((s:/home/data/ftp/pub/unpacked/waf.tmpconfig/waflib/Runner.pyts"$