<|h5hddlZddlZddlZddlmZddlZddlZddlmZddl m Z m Z ddl m Z ddl mZdZGddej ZGd d ej ZGd d ejj&j(ZGd dejj&j(ZGddej Zej0dGddej ZGddej ZGddej Zedk(rej:yy)N)socket)Waiterget_hub) NativeStrIO)get_this_psutil_process皙?ceZdZdZy)TestCloseSocketWhilePollingctj}|j|tjj d}|j |j |jtj5 |jd|j  dddtjdy#|j wxYw#1swY4xYw)Nr)z python.orgQ) r_close_on_teardownrlooptimerstartclose assertRaiseserrorconnectgeventsleep)selfsockts U/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__hub.pytestz TestCloseSocketWhilePolling.test(s}} % INN  #     v|| ,   /0    Q   s$CCCCCC#N__name__ __module__ __qualname__rrr r &s r!r ceZdZdZy)TestExceptionInMainloopctj}tjttj|z }tdz}|j |t|z t|zt j dfd}tjjd5}|j||jtj}tjttj|z }|j|j |t|z t|zdddy#1swYyxYw)Ng?z'TestExceptionInMainloop.test_sleep/failcNr )rsrfailz0TestExceptionInMainloop.test_sleep..failCsKr!gMbP?)value) timerrDELAYassertTimeWithinRange greentestExpectedExceptionrrrrexpect_one_error assert_error)rrdelay delay_ranger'rrs @r test_sleepz"TestExceptionInMainloop.test_sleep8s  U e#ck  ""5%+*=u{?RS++,UV Y^^ ! !% ( XA GGDM  ! ! #IIKE LL IIK%'E   E  *  & &uek.A5;CV W X X Xs -BEEN)rrrr2r r!rr#r#6sXr!r#ceZdZdZdZy) TestSleepc.tj|yr&rr)rtimeouts rwaitzTestSleep.waitVs Wr!c.tjdy)Nrr6rs r test_simplezTestSleep.test_simpleYs  Qr!N)rrrr8r;r r!rr4r4Ts r!r4c$eZdZfdZdZxZS) TestWaiterGetcHtt| t|_yr&)superr=setUprwaiter)r __class__s rr@zTestWaiterGet.setUp_s mT(*h r!ctjj|5}|j|jj d|jj cdddS#1swYyxYwr&)rrrrrAswitchget)rr7evts rr8zTestWaiterGet.waitcsS Y^^ ! !' * %c IIdkk(($ /;;??$ % % %s AA..A7)rrrr@r8 __classcell__rBs@rr=r=]s %r!r=ceZdZdZy) TestWaiterct}|jt|d|jd|jt|d|j|j dt}|j t tjdt|sJt||jt |jt}tj|j}d|_ tjdt|}|j|jd||j!y)Nzzz6^? b V&GH r* &'xxPRUV\R]^k`cdj`kk^ +VZZ8 LL $ Q[   --.QR" $ r!Nrr r!rrJrJisr!rJz Racy on CIceZdZdZfdZfdZdZdZd dZe jdZ e jdZ d Z e jd Ze jd Ze jd ZxZS)TestPeriodicMonitoringThreadct} |`|j7|jj |jj |`yy#t$rYOwxYwr&)rexception_streamAttributeError _threadpool threadpooljoinrXrhubs r _reset_hubz'TestPeriodicMonitoringThread._reset_hubs^i $ ?? & NN   ! NN   ! '   sA AActt| tjj |_dtj_ddlm}|dd|_d|_ t|_ |jy)NTr) get_original threadingLock) r?r\r@rconfigmonitor_thread gevent.monkeyrglock monitor_firedsetmonitored_hubsre)rrgrBs rr@z"TestPeriodicMonitoringThread.setUpsa *D79$mm::'+ $.5Lf57 !e r!ct}|js-|jr!|jjd|_|jtj _d|_|jtt|+yr&) rrkperiodic_monitoring_threadrXrrjrprer?r\tearDown)rrdrBs rrsz%TestPeriodicMonitoringThread.tearDownsgi""s'E'E  * * / / 1-1C *'+':': $"  *D:r!c|jjddlm}|j fd}j |dj jj |dy)Nr) Conditioncjjjrjyyr&)acquire notify_allreleaserX)_hubcondrXmonitors r monitor_condzJTestPeriodicMonitoringThread._run_monitoring_threads..monitor_conds2 LLN OO  LLN r!{Gz?)rV should_runrhr|r~add_monitoring_functionr8r)rrrXr|rrs `` @r_run_monitoring_threadsz4TestPeriodicMonitoringThread._run_monitoring_threadssa **+'{   '' d;  '' d;r!cddlm}t}|j|j ||j j |j|y)Nr)gettrace)greenletrr start_periodic_monitoring_threadassertIsNotNonerrrX assertIsNone)rrrds rtest_kill_removes_tracez4TestPeriodicMonitoringThread.test_kill_removes_tracesJ%i ,,. XZ( &&++- (*%r!c>t}tx}|_|j}|j |d}t |dz }|j |t|j|j|jd|j |dzt|j|j |j|jdj|j d|jdjtj|jj |j|usJ t#jd|j%||j|jd|j |t|j&|j|usJ|j)|`|j+|j,d|j/}|j1d||j1d|y#|j|jd|j |t|j&|j|usJ|j)|`wxYw)Nrur333333?appears to be blockedPeriodicMonitoringThread)rrr^rrrrNlenmonitoring_functionsrrwfunctionperiodrrrapprox_timer_resolutionr)r_monitoring_functionsrXassertGreaterEqualrngetvalueassertIn)rrdstreamrbasic_monitor_func_countdatas rtest_blocking_this_threadz6TestPeriodicMonitoringThread.test_blocking_this_threads5i(3 5%668 W%#$ " $ 0 $ ) $ 1W99;< >'' s; 1A5W99;< > (D(D(Fr(J(S(ST g::!>? A''61 11 LLN$  2 2A6  -t4 0$7  + +DMM4 @   5 !>!>? A''61 11 LLN$s &H77A%Jc t}|j}|jt}||usJtj |j fd}|j|}j |||fS)Nct_tjdtj}|j j d|S)Nrr)rr^rrrrrrw)monrrs rtaskz>TestPeriodicMonitoringThread._prep_worker_thread..task s?)/GI & LL )66C  ' ' s ;Jr!)rraapplyrrrrr)rrdra worker_hubrworker_monitorrs` @r_prep_worker_threadz0TestPeriodicMonitoringThread._prep_worker_threadsi^^ %%g. *$$$ *??@  $))$/ ^,6>11r!c(|j\}}}|j||j|j5|j ||j |j |jddddy#1swYyxYw)N)rrrXrmrrprNr)rrrrs r*test_blocking_threadpool_thread_task_queuezGTestPeriodicMonitoringThread.test_blocking_threadpool_thread_task_queues~.2-E-E-G* FN $$^4YY 4 MM*d&9&9 :   V__. 3 4 4 4s =BBct}|j}|j\}}}|jtj d}|j ||j|j|j5|j||j|j|jddddy#1swYyxYw)Nrr)rrarrTr)rrrErXrmrrprNr)rrdrarrrrs r,test_blocking_threadpool_thread_one_greenletzITestPeriodicMonitoringThread.test_blocking_threadpool_thread_one_greenlet(si^^ -1-E-E-G* FN C0 $$^4  YY 4 MM*d&9&9 :   V__. 3 4 4 4s =CCct}|j}|j\}}}d}|j|}|j |d|j |j |j||j|j}|jd||jd|y)Ncltjtjd}|j y)Ngffffff?)rrTr)rrb)rYs rrzYTestPeriodicMonitoringThread.test_blocking_threadpool_thread_multi_greenlet..taskJs TZZ-A FFHr!F)rXrr) rrarrTrrErXrrpr)rrdrarrrrrs r.test_blocking_threadpool_thread_multi_greenletzKTestPeriodicMonitoringThread.test_blocking_threadpool_thread_multi_greenletAs i^^ -1-E-E-G* FN % $$^%$@   j$"5"56  -t4 0$7r!)T)rrrrer@rsrwrzrr,ignores_leakcheckrrrrrrrGrHs@rr\r\s  =- ?<*  &!&  &8!&8P2>  4!4$  4!40  8!8r!r\ceZdZdZdZdZy)TestLoopInterfacechddlm}ddlm}t j }|j ||y)Nrverify)ILoop)gevent.testingrgevent._interfacesrrr verifyObject)rrrrs rtest_implemensts_ILoopz(TestLoopInterface.test_implemensts_ILoop_s#),y~~E4(r!cddlm}ddlm}t j }|j d}|j||y)Nrr ICallbackcyr&r r r!rzFTestLoopInterface.test_callback_implements_ICallback..mr!)rrrrrr run_callbackrrrrrcbs r"test_callback_implements_ICallbackz4TestLoopInterface.test_callback_implements_ICallbackgs3)0y~~   | ,Ir*r!cddlm}ddlm}t j }|j d}|j||y)Nrrrcyr&r r r!rrzITestLoopInterface.test_callback_ts_implements_ICallback..vrr!)rrrrrrrun_callback_threadsaferrs r%test_callback_ts_implements_ICallbackz7TestLoopInterface.test_callback_ts_implements_ICallbackps3)0y~~  ) ), 7Ir*r!N)rrrrrrr r!rrr]s)++r!rceZdZdZdZy)TestHandleErrorc8 t`y#t$rYywxYwr&)r handle_errorr_r:s rrszTestHandleError.tearDown|s!  &   s cd}|t_Gddtfd}|j5t j |j dddy#1swYyxYw)Nctr&)r_)argss rbad_handle_errorz^TestHandleError.test_exception_in_custom_handle_error_does_not_crash..bad_handle_errors r!c eZdZy)YTestHandleError.test_exception_in_custom_handle_error_does_not_crash..MyExceptionN)rrrr r!r MyExceptionrs r!rcr&r )rsrraiseszTTestHandleError.test_exception_in_custom_handle_error_does_not_crash..raisess  r!)rr ExceptionrrrTrE)rrrrs @r4test_exception_in_custom_handle_error_does_not_crashzDTestHandleError.test_exception_in_custom_handle_error_does_not_crashs_ !"2  )    { + ' LL $ $ & ' ' 's $A&&A/N)rrrrsrr r!rrrzs  'r!r__main__)rRr)unittestrtestingr,gevent.testing.timingrr gevent.hubrrgevent._compatrrr*TestCaser r#timingAbstractGenericWaitTestCaser4r=rJskipOnCIr\rrrmainr r!rrs , " &&2  )"4"4  Xi00X<%%AA %FNN))EE %##2L!W89#5#5W8"W8t+))+:'h'''2 zINNr!