JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrJFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3Rbrў f-c@s8dddgZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl Z ddl m Z ddlmZmZmZmZddlmZmZmZmZdd lmZGd ddeZeZGd ddeZGd ddeZdS( uQueueu SimpleQueueu JoinableQueueiN(uEmptyuFull(uPipe(uLockuBoundedSemaphoreu Semaphoreu Condition(udebuguinfouFinalizeuregister_after_fork(uassert_spawningcBs |EeZdZdddZddZddZdd Zd'd&d d Z d'd&d d Z ddZ ddZ ddZ ddZddZddZddZddZddZed d!Zed"d#Zed$d%Zd&S((uQueueicCs|dkrtjj}n||_tdd\|_|_t|_ t j |_ t jdkrud|_n t|_t||_d|_|jt jdkrt|tjndS(Niuduplexuwin32F(u_multiprocessinguSemLocku SEM_VALUE_MAXu_maxsizeuPipeuFalseu_readeru_writeruLocku_rlockuosugetpidu_opidusysuplatformuNoneu_wlockuBoundedSemaphoreu_semu _ignore_epipeu _after_forkuregister_after_forkuQueue(uselfumaxsize((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu__init__!s       uQueue.__init__cCs>t||j|j|j|j|j|j|j|jfS(N( uassert_spawningu _ignore_epipeu_maxsizeu_readeru_writeru_rlocku_wlocku_semu_opid(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__5s uQueue.__getstate__c CsD|\|_|_|_|_|_|_|_|_|jdS(N( u _ignore_epipeu_maxsizeu_readeru_writeru_rlocku_wlocku_semu_opidu _after_fork(uselfustate((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__:s6uQueue.__setstate__cCstdtjtj|_tj|_d|_ d|_ d|_ d|_ d|_|jj|_|jj|_|jj|_dS(NuQueue._after_fork()F(udebugu threadingu ConditionuLocku _notemptyu collectionsudequeu_bufferuNoneu_threadu _jointhreaduFalseu_joincancelledu_closedu_closeu_writerusendu_sendu_readerurecvu_recvupollu_poll(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _after_fork?s      uQueue._after_forkc Cs|j st|jj||s.tn|jjz=|jdkrZ|jn|j j ||jj Wd|jj XdS(N( u_closeduAssertionErroru_semuacquireuFullu _notemptyu_threaduNoneu _start_threadu_bufferuappendunotifyurelease(uselfuobjublockutimeout((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyuputLs   u Queue.putc Cs|rT|dkrT|jjz!|j}|jj|SWd|jjXn|rmtj|}n|jj||stnzt|r|tj}|dks|j| rtqn|jstn|j}|jj|SWd|jjXdS(Ni( uNoneu_rlockuacquireu_recvu_semureleaseutimeuEmptyu_poll(uselfublockutimeouturesudeadline((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyugetZs,         u Queue.getcCs|j|jjjS(N(u_maxsizeu_semu_semlocku _get_value(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyuqsizevsu Queue.qsizecCs |j S(N(u_poll(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyuemptyzsu Queue.emptycCs|jjjS(N(u_semu_semlocku_is_zero(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyufull}su Queue.fullcCs |jdS(NF(ugetuFalse(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu get_nowaitsuQueue.get_nowaitcCs|j|dS(NF(uputuFalse(uselfuobj((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu put_nowaitsuQueue.put_nowaitcCs0d|_|jj|jr,|jndS(NT(uTrueu_closedu_readerucloseu_close(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyucloses   u Queue.closecCs3td|jst|jr/|jndS(NuQueue.join_thread()(udebugu_closeduAssertionErroru _jointhread(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu join_threads  uQueue.join_threadc Cs=tdd|_y|jjWntk r8YnXdS(NuQueue.cancel_join_thread()T(udebuguTrueu_joincancelledu _jointhreaducanceluAttributeError(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyucancel_join_threads    uQueue.cancel_join_threadc Cstd|jjtjdtjd|j|j|j|j |j j |j fdd|_ d |j _td|j jtd|jtjk}|j r| rt|j tjtj|j gdd |_nt|tj|j|jgdd |_dS( NuQueue._start_thread()utargetuargsunameuQueueFeederThreadudoing self._thread.start()u... done self._thread.start()u exitpriorityii Ti(udebugu_bufferuclearu threadinguThreaduQueueu_feedu _notemptyu_sendu_wlocku_writerucloseu _ignore_epipeu_threaduTrueudaemonustartu_opiduosugetpidu_joincancelleduFinalizeu_finalize_joinuweakrefurefu _jointhreadu_finalize_closeu_close(uselfucreated_by_this_process((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _start_threads*           uQueue._start_threadcCsDtd|}|dk r6|jtdn tddS(Nujoining queue threadu... queue thread joinedu... queue thread already dead(udebuguNoneujoin(utwruthread((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu_finalize_joins      uQueue._finalize_joinc CsAtd|jz|jt|jWd|jXdS(Nutelling queue thread to quit(udebuguacquireuappendu _sentinelunotifyurelease(ubufferunotempty((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu_finalize_closes    uQueue._finalize_closecCstdddlm}|j}|j}|j} |j} t} tj dkrh|j} |j} nd} yx|z|s| nWd|Xymxf| }|| krtd|dS| dkr||q| z||Wd| XqWqtt k rYqtXqtWnt k r}zr|rZt |ddtjkrZdSy3|rvtd|nddl}|jWnt k rYnXWYdd}~XnXdS( Nu$starting thread to feed data to pipei(u is_exitinguwin32u%feeder thread got sentinel -- exitinguerrnoiuerror in queue thread: %s(udebuguutilu is_exitinguacquireureleaseuwaitupopleftu _sentinelusysuplatformuNoneu IndexErroru ExceptionugetattruerrnouEPIPEuinfou tracebacku print_exc(ubufferunotemptyusendu writelockucloseu ignore_epipeu is_exitingunacquireunreleaseunwaitubpopleftusentineluwacquireuwreleaseuobjueu traceback((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu_feedsV              !   u Queue._feedNT(u__name__u __module__u __qualname__u__init__u __getstate__u __setstate__u _after_forkuTrueuNoneuputugetuqsizeuemptyufullu get_nowaitu put_nowaitucloseu join_threaducancel_join_threadu _start_threadu staticmethodu_finalize_joinu_finalize_closeu_feed(u __locals__((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyuQueues$            &  cBse|EeZdZdddZddZddZdddd Zd d Z d d Z dS(u JoinableQueueicCs/tj||td|_t|_dS(Ni(uQueueu__init__u Semaphoreu_unfinished_tasksu Conditionu_cond(uselfumaxsize((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu__init__suJoinableQueue.__init__cCstj||j|jfS(N(uQueueu __getstate__u_condu_unfinished_tasks(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__suJoinableQueue.__getstate__cCs:tj||dd|dd\|_|_dS(Niii(uQueueu __setstate__u_condu_unfinished_tasks(uselfustate((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__"suJoinableQueue.__setstate__c Cs|j st|jj||s.tn|jj|jjzJ|jdkrg|j n|j j ||j j |jjWd|jj |jj XdS(N(u_closeduAssertionErroru_semuacquireuFullu _notemptyu_condu_threaduNoneu _start_threadu_bufferuappendu_unfinished_tasksureleaseunotify(uselfuobjublockutimeout((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyuput&s      uJoinableQueue.putc Csi|jjzG|jjds1tdn|jjjrS|jjnWd|jjXdS(Nu!task_done() called too many timesF( u_conduacquireu_unfinished_tasksuFalseu ValueErroru_semlocku_is_zerou notify_allurelease(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu task_done7s uJoinableQueue.task_donec CsH|jjz&|jjjs2|jjnWd|jjXdS(N(u_conduacquireu_unfinished_tasksu_semlocku_is_zerouwaiturelease(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyujoinAs  uJoinableQueue.joinNT( u__name__u __module__u __qualname__u__init__u __getstate__u __setstate__uTrueuNoneuputu task_doneujoin(u __locals__((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu JoinableQueues    cBsP|EeZdZddZddZddZddZd d Zd S( u SimpleQueuecCsktdd\|_|_t|_|jj|_tj dkrQd|_ n t|_ |j dS(Nuduplexuwin32F( uPipeuFalseu_readeru_writeruLocku_rlockupollu_pollusysuplatformuNoneu_wlocku _make_methods(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu__init__Os   uSimpleQueue.__init__cCs |j S(N(u_poll(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyuemptyYsuSimpleQueue.emptycCs&t||j|j|j|jfS(N(uassert_spawningu_readeru_writeru_rlocku_wlock(uself((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__\s uSimpleQueue.__getstate__cCs,|\|_|_|_|_|jdS(N(u_readeru_writeru_rlocku_wlocku _make_methods(uselfustate((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__`suSimpleQueue.__setstate__cs|jj|jj|jjfdd}||_|jdkrg|jj |_ nF|jj |jj|jjfdd}||_ dS(Nc s!z SWdXdS(N(((uracquireurecvurrelease(u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyugetgs u&SimpleQueue._make_methods..getc s$z|SWdXdS(N((uobj(usenduwacquireuwrelease(u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyuputusu&SimpleQueue._make_methods..put( u_readerurecvu_rlockuacquireureleaseugetu_wlockuNoneu_writerusenduput(uselfugetuput((uracquireurecvurreleaseusenduwacquireuwreleaseu;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _make_methodsds   uSimpleQueue._make_methodsN(u__name__u __module__u __qualname__u__init__uemptyu __getstate__u __setstate__u _make_methods(u __locals__((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu SimpleQueueMs    (u__all__usysuosu threadingu collectionsutimeuweakrefuerrnouqueueuEmptyuFullu_multiprocessingumultiprocessing.connectionuPipeumultiprocessing.synchronizeuLockuBoundedSemaphoreu Semaphoreu Conditionumultiprocessing.utiludebuguinfouFinalizeuregister_after_forkumultiprocessing.forkinguassert_spawninguobjectuQueueu _sentinelu JoinableQueueu SimpleQueue(((u;/opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu s"        "" 5