<|h336ddlZddlmZddlmZddlZddlmZmZddlm Z ddlm Z ddl m Z m Z ddlmZddlmZGd d eZGd d eZGd deZGddeZGddeZGddeZGddeeZGddeZGddeZGddeZGddeZGdd eZGd!d"eZGd#d$eZ Gd%d&eZ!Gd'd(eZ"e#e d)r Gd*d+eZ$[e%d,k(rejLyy)-N)TestCase)get_hubLoopExit)util)queue)EmptyFull) AsyncResult)AbstractGenericGetTestCasecNeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z y ) TestQueuecd|_tj}|jd|j |j d|j |j dy)NFhi)switch_expectedrQueueput assertEqualpeekgetselfqs W/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__queue.pytest_send_firstzTestQueue.test_send_firstsL$ KKM d  4( $'c"tj}jt5|j dddfd}t j ||}t jd|jy#1swYJxYw)NcJjt|jdy)N{Gz?timeout) assertRaisesrrrrs rwaiterz)TestQueue.test_peek_empty..waiters   eQVVT  :r皙?) rrr!rrgeventspawnsleepjoin)rrr#gs` rtest_peek_emptyzTestQueue.test_peek_emptysd KKM   x (  FFH  ; LL # S   s BBcptj}tj|j}|j tj d|jd|j|j|jdu|j|j dy)Nr) rrr%r&rstartr'rr( assertTrue exceptionr)rrr)s rtest_peek_multi_greenletz"TestQueue.test_peek_multi_greenlet$sr KKM LL    Q a   t+, 1%rctj}fd}tj||}tjd|j dtjd|j ddk(sJy)Nctjtjsdnd5j |j ddddy#1swYyxYw)Nr$g?hi2OK)r%Timeout greentestRUNNING_ON_APPVEYORrrr"s rr#z(TestQueue.test_send_last..waiter1sE9+H+HcR 1  %0 1 1s !AArr3rrr4)rrr%r&r'rr)rrr#ps` rtest_send_lastzTestQueue.test_send_last.sa KKM  LL # T e  TuuQu4'''rctjd}gfd}tj||}tjd|j ddg|j |j dtjd|j gd|j |j d|j |j d|j dd k(sJy) Nc|jdjd|jdjd|jdjdy)Nabcr4)rappend)rresultss rputterz'TestQueue.test_max_size..putter@sK EE#J NN3  EE#J NN3  EE#J NN3 rrr=r>)r=r>r?r?rr4)rrr%r&r'rr)rrrBr8rAs @r test_max_sizezTestQueue.test_max_size<s KKN  LL # Q 3*- #& Q /2 #& #&uuQu4'''rc(tj}d}d}t}t}tj|||}tj d|j |j tj|||}|j|jd|j|jdtjd5tj||gdddy#1swYyxYw)NcH|jd|jdy)Nrdone)rset)evtrs rsenderz,TestQueue.test_zero_max_size..senderVs EE$K GGFOrcF|j}|j|yN)rrG)rHrxs rreceiverz.TestQueue.test_zero_max_size..receiverZsA GGAJrMbP?rrFr) rChannelr r%r&r'r.readyrrr5joinall)rrrIrMe1e2p1p2s rtest_zero_max_sizezTestQueue.test_zero_max_sizeSs MMO  ] ] \\&"a ( U BHHJ' \\(B * 4( 6* ^^A  % NNB8 $ % % %s 'DDcF tj}d}gd}|Dcgc] }tc}t|D]\}}t j |||!t j dt  fd}|j|d|j|d|j|d|j|d|j|d|j|d|j|d ycc}w) NcB|j|jyrKrGrrrHs rr#z/TestQueue.test_multiple_waiters..waitern GGAEEG r)1234rcD]B}tjdd5|j}j|dddDt S#1swYYxYw)NrNF)r%r5raddlen)erLevtsrAs rcollect_pending_resultsz@TestQueue.test_multiple_waiters..collect_pending_resultszs\ #^^E51#AKKN## #w< ##s "AA rr,r;) rrr enumerater%r&r'rGrr) rrr#sendingsrLi_rerdrAs @@rtest_multiple_waiterszTestQueue.test_multiple_waitersjs KKM ('/0! 0h' -DAq LLDG , -  T%  hqk 02A6 hqk 02A6 hqk hqk 02A6+1sDctj}d}t}tj||||j |j d|jd|j |j dy)Nctjdt5 |j}|j |dddy#t$r|j dY%wxYw#1swYyxYwNr timed outr%r5 RuntimeErrorrrGrrHresults r do_receivez6TestQueue.test_waiters_that_cancel..do_received<>2 ))UUWFGGFO ) )$)GGK()  ) )(A+!A  A(%A+'A((A++A4rpr)rrr r%r&rrr)rrrurHs rtest_waiters_that_cancelz"TestQueue.test_waiters_that_cancelsb KKM )m ZC( K0 d  $'rctj}d}tj|||j |j dy)Nc&|jdy)Nsent)r)rs rdo_sendz0TestQueue.test_senders_that_die..do_sends EE&Mrr{)rrr%r&rr)rrr|s rtest_senders_that_diezTestQueue.test_senders_that_dies8 KKM   Wa  &)rcd}d}tj}t}t}tj|||tj|||tj d|j d|j|jd|j|jdy)NcB|j|jyrKrYrZs rr#z3TestQueue.test_two_waiters_one_dies..waiterr[rctjdt5 |j}|j |dddy#t$r|j dY%wxYw#1swYyxYwrorqrss rruz7TestQueue.test_two_waiters_one_dies..do_receivervrwr$rrp rrr r%r&r'rrr)rr#rur dying_evt waiting_evts rtest_two_waiters_one_diesz#TestQueue.test_two_waiters_one_diess  ) KKMM !m  ZI. VQ , S d  +6 *D1rcd}tj}t}t}tj|||tj|||tj d|j d|j|jd|j|jd|j|jdy)Nctjdt5 |j}|j |dddy#t$r|j dY%wxYw#1swYyxYwrorqrss rruz4TestQueue.test_two_bogus_waiters..do_receivervrwr$r{rpr)rrurrRrSs rtest_two_bogus_waitersz TestQueue.test_two_bogus_waiterss ) KKM ] ] ZB' ZB' S f  ;/ ;/ &)rN)__name__ __module__ __qualname__rr*r0r9rCrVrlrxr}rrrrr r s9( & ((.%.7>($*2.*rr ceZdZdZdZdZy) TestChannelc\tjgfd}tj|}j dj dj dj dj d|j gd|jy)NcjjjjyrK)r@rchanneleventssranother_greenletz/TestChannel.test_send..another_greenlets' MM'++- ( MM'++- (rsendinghello sent helloworld sent world)rrrrr)rrOr%r&r@rrrrrr)rrs @@r test_sendzTestChannel.test_sends--/ ) LL) * i  G l# G l# RTZ[ rctjgfd}tj|}j dj j j j |j gdtjd|j gd|j y)Ncjdjdjdjdjdy)N sending hellor sending worldrr)r@rrsrrz/TestChannel.test_wait..another_greenlets? MM/ * KK MM/ * KK MM, 'rwaiting)rrrrrr)rrrrrr)rrOr%r&r@rrr'rs @@r test_waitzTestChannel.test_waits--/ ( LL) * i  gkkm$ gkkm$ XZ`a Q fhno rctj}tj|jt t |}|j|gyrK)rrOr%r&r StopIterationlistr)rrrs r test_iterablezTestChannel.test_iterables8--/ W[[-0 M BrN)rrrrrrrrrrrs(, rrceZdZdZy)TestJoinableQueuecTtj}t}tj|j ||j }|j|||jd|j|j|jd|jy)Nr,r) r JoinableQueueobjectr%r&rrassertIsrunfinished_tasks task_done)rrXrts rtest_task_donez TestJoinableQueue.test_task_donesz%%' H W[[!$ fa  G445 G445rN)rrrrrrrrrs6rrc*eZdZdZdZdZdZdZy) TestNoWaitcgtjd}fd}tjj}||t j t|jd||t j t|jdtjdtdk(sJdJtdtjsJy)Nr,c.j||yrKr@funcargsrts r store_resultz7TestNoWait.test_put_nowait_simple..store_result MM$+ &rr;rfr) rrrloop run_callbackr wrap_errorsr put_nowaitr%r'rb isinstancerrrrrts @rtest_put_nowait_simplez!TestNoWait.test_put_nowait_simples KKN 'y~~22 \4#3#3D!,,#GK\4#3#3D!,,#GK Q6{a''ay (&( &)UZZ08&80rcgtjd}|jdfd}tjj }||t jt|j||t jt|jtjdtdk(sJddk(sJtdtjsJy)Nr,rgc.j||yrKrrs rrz7TestNoWait.test_get_nowait_simple..store_result&rrrr;)rrrrrrrrr get_nowaitr%r'rbrrs @rtest_get_nowait_simplez!TestNoWait.test_get_nowait_simple!s KKN a 'y~~22 \4#3#3E1<<#HI\4#3#3E1<<#HI Q6{a''ayA~%v%~&)U[[19691rcTgtjd}tj|jd}fd}|j sJ|tj d|jsJ|tjj||jtj d|j sJ|dgk(sJ|jsJ||jsJ||j sJ|y)Nr,c.j||yrKrrs rrz7TestNoWait.test_get_nowait_unlock..store_result8rrr)rrr%r&remptyr'fullrrrrrPdeadrrr8rrts @rtest_get_nowait_unlockz!TestNoWait.test_get_nowait_unlock3s KKN LL " 'wwy!y Qvvxx ##L!,,? Qwwy!y!}$f$}wwy!yvvqvwwy!yrcxgtj}tj|jd}fd}|j |j |j |jtjd|j |j |j |jtjj||jtjd|j |j |j |j|jdg|j |j|j |j|j |j y)Nrc.j||yrKrrs rrz?TestNoWait.test_get_nowait_unlock_channel..store_resultMrrrN)rrOr%r&rr.rrr'rrrrrrPrrs @rtest_get_nowait_unlock_channelz)TestNoWait.test_get_nowait_unlock_channelFs MMO LL " '  " ! U  " ! ##L!,,? U  " ! !%  "   "rcRgtj}tj|j}fd}|j |j ||j|j|tjd|j |j ||j|j|tjj||jd|j|j|tjd|jdg|j |j||j|j||j |j |y)Nc.j||yrKrrs rrz7TestNoWait.test_put_nowait_unlock..store_resultfrrrN )rrr%r&rr.r assertFalserr'rrrrrPrrs @rtest_put_nowait_unlockz!TestNoWait.test_put_nowait_unlockas KKM LL  '  1% 1% U  1% 1% ##L!,,C A& U $(  1% 1%  1%rN)rrrrrrrrrrrrrs9 :$&#6&rrceZdZdZy) TestJoinEmptycZd|_tj}|jy)zFTest that join() exits immediately if not jobs were put into the queueFN)rrrr(rs r test_issue_45zTestJoinEmpty.test_issue_45}s!$    ! rN)rrrrrrrrr{srrceZdZdZy)AbstractTestWeakRefMixinc|ddl}|j}|j|}|j||y)Nr)weakref_makeOnerefr)rroners rtest_weak_referencez,AbstractTestWeakRefMixin.test_weak_references.mmokk# c35!rN)rrrrrrrrrs"rrc4eZdZeZej ZdZdZ y)TestGetInterruptcB|jj|S)Nr)rrrr s rwaitzTestGetInterrupt.waits}}""7"33rc"|jSrKkindrs rrzTestGetInterrupt._makeOneyy{rN) rrrrr5rrrrrrrrrrsG ;;D4rrc$eZdZejZy)TestGetInterruptJoinableQueueNrrrrrrrrrrr   Drrc$eZdZejZy)TestGetInterruptLifoQueueNrrrr LifoQueuerrrrrr ??Drrc$eZdZejZy)TestGetInterruptPriorityQueueNrrrr PriorityQueuerrrrrrrrrc$eZdZejZy)TestGetInterruptChannelN)rrrrrOrrrrrrs ==DrrcFeZdZejZeZfdZdZ dZ xZ S)TestPutInterruptcTtt| |j|_yrK)superrsetUprr)r __class__s rrzTestPutInterrupt.setUps +-]]_ rc|jjs6|jjd|jjs6|jjd|S)Nr,r;r)rrrrs rrzTestPutInterrupt.waitsG**//# JJNN1 **//#zz~~a~11rc$|jdS)Nr,rrs rrzTestPutInterrupt._makeOnesyy|r) rrrrrrr r5rrr __classcell__)rs@rrrs ;;DG%2 rrc$eZdZejZy)TestPutInterruptJoinableQueueNrrrrrrrrrc$eZdZejZy)TestPutInterruptLifoQueueNrrrrrrrrrc$eZdZejZy)TestPutInterruptPriorityQueueNrrrrrrrrrc*eZdZejZdZy)TestPutInterruptChannelc"|jSrKrrs rrz TestPutInterruptChannel._makeOnerrN)rrrrrOrrrrrr r s ==Drr  SimpleQueuec2eZdZejZdZeZeZy)TestGetInterruptSimpleQueuec,tjd)Nz Not supported)unittestSkipTestrs rtest_raises_timeout_Timeoutz7TestGetInterruptSimpleQueue.test_raises_timeout_Timeouts##O4 4rN) rrrrr rr*test_raises_timeout_Timeout_exc_customizedtest_outer_timeout_is_not_lostrrrrrs!   56Q2)D&rr__main__)'rgevent.testingtestingr6rr% gevent.hubrrrr gevent.queuerr gevent.eventr gevent.testing.timingr r rrrrrrrrrrrrrrrr hasattrrrmainrrrrs2"# ($$<~*~*B0 (0 d 6 6i&i&XH"v" /1K $4 0$4.1"$4 0$4. 5- E&6E zINNr