관리-도구
편집 파일: worker.pyc
� Hq�Qc @ s� d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d � Z d � Z e j d k r� d Z n d Z d � Z d � Z d � Z d � Z e j d k r� e Z e Z n d � Z d S( i����( t _Nc C s� y) t t j d � � } | d k r( | SWn t t f k rB n Xy' t t j d � } | d k ri | SWn t t f k r� n Xd S( s- try to count the number of CPUs on the systemt SC_NPROCESSORS_ONLNi t NUMBER_OF_PROCESSORSi ( t intt ost sysconft AttributeErrort ValueErrort environt KeyError( t n( ( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt countcpus s c C s} | j d d � } | rd y t | � } | d k r7 | SWqd t k r` t j t d � � � qd Xn t t t � d � d � S( Nt workert numcpusi s! number of cpus must be an integeri i ( t configR R t utilt AbortR t mint maxR ( t uit sR ( ( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt _numworkers s t posixg{�G�z�?gꌠ9Y>)Fc C s6 | | } t | � } | t | | | } | d k S( se try to determine whether the benefit of multiple processes can outweigh the cost of starting themg333333�?( R t _startupcost( R t costperopt nopst lineart workerst benefit( ( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt worthwhile0 s c C s< t | | t | � � r+ t | | | | � S| | | f � S( sF run a function, possibly in parallel in multiple worker processes. returns a progress iterator costperarg - cost of a single task func - function to run staticargs - arguments to pass to every invocation of the function args - arguments to split into chunks, to pass to individual workers ( R t lent _platformworker( R t costperargt funct staticargst args( ( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyR 8 s c # s8 t j � \ } } t | � } t j t j � � t j t j t j � g d g � � x� t | | � D]� } t j � } | d k r<t j t j � � y\ t j | � x; | | | f � D]& \ } } t j | d | | f � q� Wt j d � Wq<t k rt j d � q<z | j � Wd t j d � Xq<Xn � j | � qf W� j � t j | � t j | d d � } � f d � � � � � f d � } t j d | � � � j � � � � f d � } yD x= | D]5 } | j d d � } t | d � | d d f Vq�WWn � � | � � n X| � d S( Ni s %d %s i� t rbc sZ xS � D]K } y t j | t j � Wq t k rQ } | j t j k rR � qR q Xq Wd S( N( R t killt signalt SIGTERMt OSErrort errnot ESRCH( t pt err( t pids( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt killworkerse s c sL xE � D]= } t t j � d � } | r � r | � d <� � q q Wd S( Ni i ( t _exitstatusR t wait( R t st( R. R- t problem( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt waitforworkersm s t targetc sg t j t j � � � j � � d } | rc | d k rS t j t j � | � n t j | � n d S( Ni ( R& t SIGINTt joinR R% t getpidt syst exit( t status( t oldhandlerR2 t t( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt cleanupu s t i i����( R t pipeR R& t getsignalR5 t SIG_IGNt partitiont forkt closet writet _exitt KeyboardInterruptt tracebackt appendt reverset fdopent threadingt Threadt startt splitR ( R R! R" R# t rfdt wfdR t pargst pidt it itemt fpR3 R= t linet l( ( R. R; R- R2 R< s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt _posixworkerK sL %c C s= t j | � r t j | � St j | � r9 t j | � Sd S( s� convert a posix exit status into the same form returned by os.spawnv returns None if the process was stopped instead of exitingN( R t WIFEXITEDt WEXITSTATUSt WIFSIGNALEDt WTERMSIG( t code( ( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt _posixexitstatus� s t ntc c s{ t | � } | | | | } } d } xM t | � D]? } | } | | } | rg | d 7} | d 8} n | | | !Vq4 Wd S( s, partition a list into N slices of equal sizei i N( R t xrange( t lstt nslicesR t chunkt slopt endRT RN ( ( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyRB � s ( t i18nR R) R R& R8 RL R R R t nameR R R RY R_ R R/ RB ( ( ( s6 /usr/lib64/python2.7/site-packages/mercurial/worker.pyt <module> s H <