e=e;d-rGd.d/eZFGd?d@eFej8ZG ddlHZHGdAdBeFej8ZIn #e $rYnwxYwGdCdDej8ZJGdEdFej8ZKeLdGkrejMdSdS)HzTests for events.py.N)mock)win32vxworks) coroutines)events)proactor_events)selector_events)utils)support) socket_helper)threading_helper) ALWAYS_EQLARGESTSMALLESTc.tjddSN)asyncioset_event_loop_policy4/usr/lib/python3.11/test/test_asyncio/test_events.pytearDownModuler)s !$'''''rctjdrdStjdkrdStjd}t t t |d}|dkS)z4Return True if the platform is Mac OS 10.4 or older.aixTdarwinFr.) )sysplatform startswithmac_vertuplemapintsplit)versions rbroken_unix_getsocknamer(-sr |u%%t  ! !u  #GCW]]3//0011G W rcd}tj}tj|||S)Nc KdSNhellorrrrdoitz8_test_get_event_loop_new_process__sub_proc..doit9s wr)rnew_event_loopset_event_looprun_until_complete)r-loops r*_test_get_event_loop_new_process__sub_procr28sL  ! # #D 4    " "4466 * **rc&eZdZdZdZdZdZdS)CoroLikecdSrr)selfvs rsendz CoroLike.sendB rcdSrrr6excs rthrowzCoroLike.throwEr9rcdSrrr6s rclosezCoroLike.closeHr9rcdSrrr?s r __await__zCoroLike.__await__Kr9rN)__name__ __module__ __qualname__r8r=r@rBrrrr4r4AsP              rr4c<eZdZdZdZddZdZdZdZdZ dZ dS) MyBaseProtoNcd|_d|_d|_|4||_||_dSdSNINITIALr) transportstatenbytes create_future connecteddoner6r1s r__init__zMyBaseProto.__init__SsO   !//11DN**,,DIII  rcL|j|vrtd|jd|dSNzstate: z , expected: rLAssertionErrorr6expecteds r _assert_statezMyBaseProto._assert_state[s8 :X % % !Q4:!Q!QX!Q!QRR R & %rc||_|dd|_|jr|jddSdSNrJ CONNECTEDrKrYrLrO set_resultr6rKs rconnection_madezMyBaseProto.connection_made_sT" 9%%%  > , N % %d + + + + + , ,rcj|d|xjt|z c_dSNr\rYrMlenr6datas r data_receivedzMyBaseProto.data_receivedfs0 ;''' s4yy rc>|dd|_dS)Nr\EOF)rYrLr?s r eof_receivedzMyBaseProto.eof_receivedjs! ;''' rc|ddd|_|jr|jddSdS)Nr\riCLOSEDrYrLrPr^r;s rconnection_lostzMyBaseProto.connection_lostnsO ;... 9 ' I  & & & & & ' 'rr) rCrDrErOrPrRrYr`rgrjrnrrrrGrGOsI D----SSS,,,!!!'''''rrGceZdZfdZxZS)MyProtoctt||ddS)Ns%GET / HTTP/1.0 Host: example.com )superr`write)r6rK __class__s rr`zMyProto.connection_madevs4  ***FGGGGGrrCrDrEr` __classcell__rts@rrprpusAHHHHHHHHHrrpc8eZdZdZddZdZdZdZdZdZ dS) MyDatagramProtoNc\d|_d|_|||_dSdSrI)rLrMrNrPrQs rrRzMyDatagramProto.__init__~s5   **,,DIII  rcP|j|krtd|jd|dSrTrUrWs rrYzMyDatagramProto._assert_state8 : ! ! !Q4:!Q!QX!Q!QRR R " !rcL||_|dd|_dS)NrJ INITIALIZEDrKrYrLr_s rr`zMyDatagramProto.connection_mades(" 9%%%" rcj|d|xjt|z c_dSNr~rc)r6rfaddrs rdatagram_receivedz!MyDatagramProto.datagram_receiveds0 =))) s4yy rc0|ddSr)rYr;s rerror_receivedzMyDatagramProto.error_receiveds =)))))rc|dd|_|jr|jddSdS)Nr~rlrmr;s rrnzMyDatagramProto.connection_lostsM =))) 9 ' I  & & & & & ' 'rr) rCrDrErPrRrYr`rrrnrrrryry{s{ D---- SSS### !!!***'''''rryc8eZdZdZddZdZdZdZdZdZ dS) MyReadPipeProtoNcldg|_d|_d|_|||_dSdSrI)rLrMrKrNrPrQs rrRzMyReadPipeProto.__init__s>[    **,,DIII  rcP|j|krtd|jd|dSrTrUrWs rrYzMyReadPipeProto._assert_stater|rct||_|dg|jddSr[)rKrYrLappendr_s rr`zMyReadPipeProto.connection_mades;" I;''' +&&&&&rcn|ddg|xjt|z c_dSr[rcres rrgzMyReadPipeProto.data_receiveds5 I{3444 s4yy rch|ddg|jddS)NrJr\ri)rYrLrr?s rrjzMyReadPipeProto.eof_receiveds7 I{3444 %     rcd|jvr|jd|gd|jd|jr|jddSdS)Nri)rJr\rirl)rLrrYrPr^r;s rrnzMyReadPipeProto.connection_losts  " " J  e $ $ $ :::;;; (### 9 ' I  & & & & & ' 'rr) rCrDrErPrRrYr`rgrjrnrrrrrs{ D----SSS''' !!!!!!'''''rrc,eZdZdZddZdZdZdZdS)MyWritePipeProtoNc\d|_d|_|||_dSdS)NrJ)rLrKrNrPrQs rrRzMyWritePipeProto.__init__s5   **,,DIII  rcP|j|krtd|jd|dSrTrUrWs rrYzMyWritePipeProto._assert_stater|rcL||_|dd|_dSr[rr_s rr`z MyWritePipeProto.connection_mades(" 9%%%  rc|dd|_|jr|jddSdSNr\rlrmr;s rrnz MyWritePipeProto.connection_lostsM ;''' 9 ' I  & & & & & ' 'rr)rCrDrErPrRrYr`rnrrrrrs] D---- SSS!!! '''''rrc8eZdZdZdZdZdZdZdZdZ dS) MySubprocessProtocolcBd|_d|_|_|_fdt dD|_ddd|_d|_tj tj d|_ dS)NrJc:i|]}|Sr)rN).0fdr1s r z1MySubprocessProtocol.__init__..s'HHHB 2 2 4 4HHHrr) rLrKrNrO completedrange disconnectsrf returncoderEventgot_datarQs `rrRzMySubprocessProtocol.__init__s ++--++--HHHHuQxxHHH$$ #MOO#MOO-- rcP|j|krtd|jd|dSrTrUrWs rrYz"MySubprocessProtocol._assert_stater|rc||_|dd|_|jddSr[r]r_s rr`z$MySubprocessProtocol.connection_mades@" 9%%%   !!$'''''rcr|dd|_|jddSr)rYrLrr^r;s rrnz$MySubprocessProtocol.connection_losts9 ;'''  !!$'''''rc|d|j|xx|z cc<|j|dSrb)rYrfrset)r6rrfs rpipe_data_receivedz'MySubprocessProtocol.pipe_data_receivedsM ;''' "   brc|d|r"|j||dS|j||dSrb)rYr set_exceptionr^)r6rr<s rpipe_connection_lostz)MySubprocessProtocol.pipe_connection_lostsb ;'''  1  R . .s 3 3 3 3 3  R + +C 0 0 0 0 0rcl|d|j|_dSrb)rYrKget_returncoderr?s rprocess_exitedz#MySubprocessProtocol.process_exiteds/ ;'''.7799rN) rCrDrErRrYr`rnrrrrrrrrs - - -SSS((( (((    111:::::rrc eZdZfdZfdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZejeedddZejeeddejeedddZejeeddejeedddZd]dZdZejdZddifdZ d^dZ d^dZeje dudd Z!ejeje dudd!Z"d"Z#d#Z$d$Z%d%Z&d_d&Z'eje dudd'Z(d(Z)e*j+d)d*Z,d+Z-d,Z.d-Z/ejee0d.d/d0Z1d1Z2ejd2Z3ejee0d3d4d5Z4d`d6Z5d`d7Z6d`d8Z7eje dudd9Z8ejeje dudd:Z9eje dudd;Z:ejeje dudd<Z;eje dudd=ZZ=eje dudd?Z>d@Z?dAZ@ejejAdBdCZBdDZCdEZDdFZEejejAdBdGZFdHZGdIZHejeIjJdJkdKdLZKejeIjJdJkdKdMZLejeIjJdJkdKejeeMdNdOdPZNejeIjJdJkdKdQZOejeIjJdJkdKdRZPejeIjJdJkdKejeeMdNdOeQjRdSdTdUZSejeIjJdJkdKejeeMdNdOeQjRdSdTdVZTdWZUdXZVdYZWdZZXd[ZYd\ZZxZ[S)aEventLoopTestsMixinct||_||jdSr)rrsetUpcreate_event_loopr1r/r6rts rrzEventLoopTestsMixin.setUpsC  **,,  DI&&&&&rc|jstj|j|t jtdSr) r1 is_closed test_utils run_briefly doCleanupsr gc_collectrrtearDownrs rrzEventLoopTestsMixin.tearDown sgy""$$ .  "49 - - -  rcdfd}td5tjj|ddddS#1swxYwYdS)Nc>Ktjdd{VdSNr)rsleeprrrcoro1zBEventLoopTestsMixin.test_run_until_complete_nesting..coro1s.-"" " " " " " " " " "rcKjjdSr) assertTruer1 is_runningr0)rr6srcoro2zBEventLoopTestsMixin.test_run_until_complete_nesting..coro2sI OODI0022 3 3 3 I ( ( 1 1 1 1 1rzcoroutine \S+ was never awaited)assertWarnsRegexRuntimeWarning assertRaises RuntimeErrorr1r0)r6rrs` @rtest_run_until_complete_nestingz3EventLoopTestsMixin.test_run_until_complete_nestings # # # 2 2 2 2 2 2 " "  .   E E   di:EEGG E E E  E E E E E E E E E E E E E E E E E Es/A##A'*A'c|j}|jtjd|j}|d||z cxkodknc||z dS)N皙?g{Gz?g?)r1timer0rrr)r6t0t1s rtest_run_until_completez+EventLoopTestsMixin.test_run_until_complete's Y^^   $$W]3%7%7888 Y^^   2,,,,,,,,be44444rcrfd}|}tjj|dS)NcrKjtjdd{VdS)Nr)r1stoprrr?srcbz?EventLoopTestsMixin.test_run_until_complete_stopped..cb/sA INN   -$$ $ $ $ $ $ $ $ $ $r)rrr1r0)r6rtasks` rtest_run_until_complete_stoppedz3EventLoopTestsMixin.test_run_until_complete_stopped-sW % % % % %rtt ,)6 > > > > >rcgfd}jd|djdgdS)Ncd|jdSrrr1rargresultsr6s rcallbackz5EventLoopTestsMixin.test_call_later..callback9s- NN3    INN     rrz hello world)r1 call_later run_forever assertEqualr6rrs` @rtest_call_laterz#EventLoopTestsMixin.test_call_later6su       S(M:::  =/22222rcgfd}j|ddjdgdS)Nch||fjdSrr)arg1arg2rr6s rrz4EventLoopTestsMixin.test_call_soon..callbackDs1 NND$< ( ( ( INN     rr,world)r,r)r1 call_soonrrrs` @rtest_call_soonz"EventLoopTestsMixin.test_call_soonAsw       Hgw777  #5"677777rcgtjfdfd}tj|}|5jdjdddn #1swxYwY| ddgdS)Nc|tdkrjdSdSNrrrdr1rrs rrz?EventLoopTestsMixin.test_call_soon_threadsafe..callbackPF NN3   7||q        ! rcfjddSr+)r1call_soon_threadsaferelease)rlockr6sr run_in_threadzDEventLoopTestsMixin.test_call_soon_threadsafe..run_in_threadUs, I * *8W = = = LLNNNNNrtargetrr,) threadingLockacquireThreadstartr1rrjoinr)r6rtrrrs` @@@rtest_call_soon_threadsafez-EventLoopTestsMixin.test_call_soon_threadsafeLs?~ ! ! ! ! ! !           M 2 2 2   $ $ I  ' 2 2 2 I ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $  7G"455555s&5B''B+.B+cgfd}j|dj|djddgdS)Nc|tdkrjdSdSrrrs rrzKEventLoopTestsMixin.test_call_soon_threadsafe_same_thread..callbackfrrr,r)r1rrrrrs` @r%test_call_soon_threadsafe_same_threadz9EventLoopTestsMixin.test_call_soon_threadsafe_same_threadcs ! ! ! ! ! ! &&x999 Hg...  7G"455555rcd}|jd|d}|j|\}}||d||t jdS)Nc,|tjfSr)r get_ident)rs rrunz5EventLoopTestsMixin.test_run_in_executor..runqs,../ /ryo)r1run_in_executorr0rassertNotEqualrr)r6rf2res thread_ids rtest_run_in_executorz(EventLoopTestsMixin.test_run_in_executorps~ 0 0 0 Y & &tS$ 7 755b99Y d### Iy':'<'<=====rcdfd}d}|jd|}||j|j|j||j_||j_tj d| dS)NFc ddSNTr)argscalleds rpatched_call_soonzJEventLoopTestsMixin.test_run_in_executor_cancel..patched_call_soon{s FFFrc.tjddS)Ng?)rrrrrrz.runs Jt     rg?) r1r cancelr0shutdown_default_executorr@rrrr assertFalse)r6rrr rs @rtest_run_in_executor_cancelz/EventLoopTestsMixin.test_run_in_executor_cancelxs        Y & &tS 1 1  $$ 3355 7 7 7 / ): & 3      rctj\}dtfd}j|j|jdtj jfdj|jdtj jfdj|j jjj j ddS)NFc0 d}n#t$rYdSwxYw|r|dSjdSN)recvBlockingIOErrorextendrr1 remove_readerfilenor@)rf bytes_readrr6s rreaderz8EventLoopTestsMixin.test_reader_callback..readers vvd||"     !!$''''' 7 7 C CDDD s  ''sabcc*tdkS)Nrrdr$srz:EventLoopTestsMixin.test_reader_callback..J10Drsdefc*tdkS)Nr(r)srr*z:EventLoopTestsMixin.test_reader_callback..r+rsabcdef)socket socketpair setblocking bytearrayr1 add_readerr#rr8r run_untilr@rrr)r6wr&r$r%s` @@rtest_reader_callbackz(EventLoopTestsMixin.test_reader_callbacksK ""1 e[[         QXXZZ000 AFF+++TY(D(D(D(DEEE AFF+++TY(D(D(D(DEEE AG$$$ DIN+++  Y/////rctj\}dfd}d}j||jj j | t|dz}|  ||dS)NFcd|jdSr)r8r1r)rfr6r4s rwriterz8EventLoopTestsMixin.test_writer_callback..writers* FF4LLL INN     rsxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxr)r.r/r0r1 add_writerr#rr remove_writerrr@rrdr)r6r%r8rfreadr4s` @rtest_writer_callbackz(EventLoopTestsMixin.test_writer_callbacks* ""1 e       QXXZZ666   // ;;<<< 00<<===  vvc$ii!m$$   t$$$$$rSIGKILLz No SIGKILLcdfd}|t|jjd||t|jjd|t |jjt jdz||t |jjt jdz|t |jjd||t |jjd|t |jjd||t |jjd|t|jjt j || |jt j |jt j |tj tjt j tj|jfd||jt j |t jt j t j| |jt j dS)Nrcdz dSNrrcaughtsr my_handlerz?EventLoopTestsMixin.test_add_signal_handler..my_handlers aKFFFrboomrcSrrrAsrr*z=EventLoopTestsMixin.test_add_signal_handler..sr)r TypeErrorr1add_signal_handlerremove_signal_handler ValueErrorsignalNSIGrr=rSIGINToskillgetpidrr3rr getsignaldefault_int_handlerr6rCrBs @rtest_add_signal_handlerz+EventLoopTestsMixin.test_add_signal_handlers       ty3VZ I I I  ty6 @ @ @   4fk!m       7Q H H H   4a E E E   7 < < <   4b* F F F   7 = = =  $)6     88HHIII $$V]J???  V]+++TY777  77 FFGGG )&-883 5 5 5 88GGHHHHHrSIGALRMz No SIGALRM setitimerzneed signal.setitimer()cLdfd}jtj|tjtjddjdjjj ddS)NrcDdz jdSr@)r1r)rBr6srrCzLEventLoopTestsMixin.test_signal_handling_while_selecting..my_handlers$ aKF INN     r{Gz?<r r1rHrKrUrV ITIMER_REALrrrrrSs` @r$test_signal_handling_while_selectingz8EventLoopTestsMixin.test_signal_handling_while_selectings        $$V^Z@@@+T1555 R000  #####rcFddfd}jjtj|gRtjtjddjdjjj ddS)N)*rcpdz |jdSr@)rr1r)rrBr6 some_argss rrCzAEventLoopTestsMixin.test_signal_handling_args..my_handlers: aKF   T9 - - - INN     rrrZrr[)r6rCrBras` @@rtest_signal_handling_argsz-EventLoopTestsMixin.test_signal_handling_argss         % $V^ZL)LLLL+S!444 R000  #####rTc|j|\}}||tj||tj||j||r(|| d|j|j | |j d| dS)Nsocknamer)r1r0assertIsInstancer TransportProtocolassertIsrKassertIsNotNoneget_extra_inforP assertGreaterrMr@)r6connection_futcheck_socknametrprs r_basetest_create_connectionz/EventLoopTestsMixin._basetest_create_connections--n==B b'"3444 b'"2333 blB'''  @  !2!2:!>!> ? ? ? $$RW--- 29a(((  rctj5}jjfdg|jR}|ddddS#1swxYwYdS)Nc.tjSNr1rpr1r?srr*z.TY///r)rrun_test_serverr1create_connectionaddressrp)r6httpdconn_futs` rtest_create_connectionz*EventLoopTestsMixin.test_create_connections  ' ) ) 7U2ty2////A27-AAAH  , ,X 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7s1AAAct }tj5}jfd|j}||ddddS#1swxYwYdS)Nc.tjSrsrur?srr*zAEventLoopTestsMixin.test_create_unix_connection..(rvr)r(rrun_test_unix_serverr1create_unix_connectionryrp)r6rmrzr{s` rtest_create_unix_connectionz/EventLoopTestsMixin.test_create_unix_connection s5666  , . . G%y77////@@H  , ,X~ F F F G G G G G G G G G G G G G G G G G Gs:A++A/2A/Nc|r(||d|r*|||dn(||d|||d|d}||t|t |d|||dt ||dt ||dt|d }|||||d || |d|| |d|||d dS) Nrdpeernamepeercertcipherrrrr ssl_object compression) rirjrrer#rdstrr%rr getpeercert)r6clientrmrrrsslobjs rcheck_ssl_extra_infoz(EventLoopTestsMixin.check_ssl_extra_info+s[  D  !6!6z!B!B C C C  D   X#22:>> @ @ @ @  !6!6z!B!B C C C ..z:: < < <&&x00 fe,,, Va000 fQi--- fQi--- fQi---&&|44 V$$$ ++--..}== ? ? ? ..x88 : : : ++--..z:: < < < ++--..}== ? ? ? ? ?rc|j|\}}||tj||tj|d|jj v| ||||j|j | |j d|dS)Nsslr)r1r0rerrfrgrrtrClowerrrPrkrMr@)r6rlrmrrnros r_basetest_create_ssl_connectionz3EventLoopTestsMixin._basetest_create_ssl_connectionKs--n==B b'"3444 b'"2333 !6!!>>??? !!"nh??? $$RW--- 29a(((  rc|tj}|||ttdrtjjfddddfd }tjd|5}|d}||| |j ddddn #1swxYwY tj 5}|d}tj 5|||dddn #1swxYwYdddn #1swxYwY |jjd dS) NrPurpose)cafilecapathcadatact|tjjt jS)z A ssl.create_default_context() replacement that doesn't enable cert validation. )rrr SERVER_AUTHrdummy_ssl_context)purposerrrr6s r_dummy_ssl_create_contextzREventLoopTestsMixin._test_create_ssl_connection.._dummy_ssl_create_context_s/  #+*ABBB!3555rzssl.create_default_context) side_effectTrCERTIFICATE_VERIFY_FAILED)rrrhasattrrrrrpatchr call_countrSSLErrordisable_logger exceptionreason) r6rzrxrmrr{rmcms ` r_test_create_ssl_connectionz/EventLoopTestsMixin._test_create_ssl_connectionWsm$$)E)G)GHHH ,,X~-5 7 7 7 3 " " 225+2I 615d15 6 6 6 6 6 6 68(ACCC 2FG,,66644X~5=???  q111  2 2 2 2 2 2 2 2 2 2 2 2 2 2 2  s| , , ?((T222H*,, ? ?44X~5=??? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ,.IJJJJJsH.rvrr)rrw functoolspartialr1rxryr)r6rzrxs` rtest_create_ssl_connectionz.EventLoopTestsMixin.test_create_ssl_connection|s  ' 5 5 5 E ) 1 +////! ! ! !   , ,U4E6;m - E E E  E E E E E E E E E E E E E E E E E EsAA''A+.A+ct }tjd5}tjjjfd|jd}||||jddddS#1swxYwYdS)NTrc.tjSrsrur?srr*zEEventLoopTestsMixin.test_create_ssl_unix_connection..rvr 127.0.0.1)server_hostnamer) r(rrrrr1rryr)r6rmrzrxs` rtest_create_ssl_unix_connectionz3EventLoopTestsMixin.test_create_ssl_unix_connections 5666  ,T : : : Ee ) 1 0//// +!-!-!-   , ,U4E-;6;m - E E E  E E E E E E E E E E E E E E E E E EsA A<<BBctj5}tj}jjfdg|jRd|jd|fi}j|\}}|j dd} ||| ddddS#1swxYwYdS)Nc.tjSrsrur?srr*zGEventLoopTestsMixin.test_create_connection_local_addr..rvr local_addrrrdr) rrwr find_unused_portr1rxryr0rKrjrr@)r6rzportfrnrorXs` r!test_create_connection_local_addrz5EventLoopTestsMixin.test_create_connection_local_addrs)  ' ) ) U 133D+ +////EEEE,1M!,>qAH   T8 , , , HHJJJ                  sB&CC C cttj}tjjjfd}|j_jfdd|df}t 5j|ddddS#1swxYwYdS)NcK|kr6tjtjdddftjtjdddfgS||g|Ri|d{VS)Nr::1rrrrr)r.AF_INET6 SOCK_STREAMAF_INEThostrrkwargsgetaddrinfo_origport2s r getaddrinfoz`EventLoopTestsMixin.test_create_connection_local_addr_skip_different_family..getaddrinfosyu}}&*.G+++r localhostrr rr1rrxrOSErrorr0r6port1rrrrs` @@r7test_create_connection_local_addr_skip_different_familyzKEventLoopTestsMixin.test_create_connection_local_addr_skip_different_familys".00.0090 G G G G G G !,  I ' ' + + + + K+? ( A A  w ' ' , , I ( ( + + + , , , , , , , , , , , , , , , , , ,B--B14B1cttj}tjjjfd}|j_jfdd|df}t 5j|ddddS#1swxYwYdS)NcrK|krtjtjdddfgS||g|Ri|d{VS)Nrrr)r.rrrs rrzYEventLoopTestsMixin.test_create_connection_local_addr_nomatch_family..getaddrinfos_u}}&*.rrrrrrs` @@r0test_create_connection_local_addr_nomatch_familyzDEventLoopTestsMixin.test_create_connection_local_addr_nomatch_familys".00.0090 G G G G G G !,  I ' ' + + + + K+? ( A A  w ' ' , , I ( ( + + + , , , , , , , , , , , , , , , , , ,rctj5}jjfdg|jRd|ji}t 5}j|dddn #1swxYwY|j j tj  t|j|j jddddS#1swxYwYdS)Nc.tjSrsrur?srr*zNEventLoopTestsMixin.test_create_connection_local_addr_in_use..rvrr)rrwr1rxryrrr0rrerrno EADDRINUSEassertInrstrerror)r6rzrrs` r(test_create_connection_local_addr_in_usezC.A:. C.:A> >C.A> AC..C25C2cl |j G fddt}tjdd}| d dd  fd}t j|d }||\}}|  _ fd ||   j | tj|||| jd| jt+ | dS)Nc.eZdZfdZfdZxZS)AEventLoopTestsMixin.test_connect_accepted_socket..MyProtoc~t|jdSr)rrrnrr)r6r<rtr1s rrnzQEventLoopTestsMixin.test_connect_accepted_socket..MyProto.connection_losts5'',,,ty)))))rc~t||jdSr)rrrgrKrs)r6rfrtexpected_responses rrgzOEventLoopTestsMixin.test_connect_accepted_socket..MyProto.data_receiveds8%%d+++$$%677777r)rCrDrErnrgrv)rtrr1s@rrprs\ * * * * * * 8 8 8 8 8 8 8 8 8 8rrprr)backlogs test datasrogercT tj}|}|||d|dS#t $r}td|Yd}~dSd}~wwxYw)Ncz8Failure in client thread in test_connect_accepted_socket)r. wrap_socketconnectsendallrr@ Exceptionprint)csockr<r client_sslmessageresponses rrz@EventLoopTestsMixin.test_connect_accepted_socket..clients  )&22599E d### g&&& ::b>>    N sA=B B' B""B'T)rdaemonrtcSrrprotosrr*zBEventLoopTestsMixin.test_connect_accepted_socket..srrrl)r1rGr. create_server getsocknamerrracceptr0connect_accepted_socketrrKr@r join_threadris_aliverrLrMrd)r6 server_sslrrplsockrthreadconn_rrr1rrrs ` @@@@@@rtest_connect_accepted_socketz0EventLoopTestsMixin.test_connect_accepted_socketsy 8 8 8 8 8 8 8 8k 8 8 8$%5qAAA  ""$        !=== ,,..aT"""    ( (: ) 7 7 8 8 8   $V,,, **+++ h/// s7||444 #455555rc~tj}tj}|||dSr)rsimple_server_sslcontextsimple_client_sslcontextr)r6server_contextclient_contexts r test_ssl_connect_accepted_socketz4EventLoopTestsMixin.test_ssl_connect_accepted_socket s:#<>>#<>> ))..IIIIIrcTtj}||j|jt |t j}|td5|j |ddddS#1swxYwYdS)N)ssl_handshake_timeoutz1ssl_handshake_timeout is only meaningful with ssl) r. addCleanupr@r1rrpr LOOPBACK_TIMEOUTassertRaisesRegexrJr0)r6sockcoros r9test_connect_accepted_socket_ssl_timeout_for_plain_socketzMEventLoopTestsMixin.test_connect_accepted_socket_ssl_timeout_for_plain_sockets}  ###y00 T1I1KK  # #CEE / / I ( ( . . . / / / / / / / / / / / / / / / / / /s5BB!$B!zasyncio.base_events.socketc fd fd}t|}tjkr)d|D|j_n(d|D|j_|j_tjj_ tjj_ j fd|d}j |} |jd|jD}||dS)Nc|Ktjkrtjdd||ffgStjdd||ddffgS)Nr-rr)r.rr)rrrkwfamilys rrzEEventLoopTestsMixin.create_server_multiple_hosts..getaddrinfosO''!3QT4LIJJ!3QT4A.getaddrinfo_task$s(9((d)Cd)C)CDD Drcg|]}|dfS)Prrrs r zDEventLoopTestsMixin.create_server_multiple_hosts..*s)<5<5<5#r <5<5<5rcg|]}|dddf S)rrrrs rrzDEventLoopTestsMixin.create_server_multiple_hosts..-s.<;<;<;%)r1a <;<;<;rc,tjSrrur?srr*zBEventLoopTestsMixin.create_server_multiple_hosts..2sGDI,>,>rrcBh|]}|dS)r) getsockbyname)rr s r zCEventLoopTestsMixin.create_server_multiple_hosts..5s)KKKD**,,Q/KKKr)rr.rrrr1rrMock_start_serving _stop_servingrr0r r@socketsr) r6rhosts mock_sockr unique_hostsrserver server_hostsrs `` @rcreate_server_multiple_hostsz0EventLoopTestsMixin.create_server_multiple_hostssk Q Q Q Q Q  E E E E E E5zz V^ # #<5<5'3<5<5<5I     , 8 8<;<;-9<;<;<;I     , 8 0 #'9;;  "&)++  I # #$>$>$>$>r J J--a00  %%%KKFNKKK  |44444rcJ|tjgddS)N)1.2.3.4z5.6.7.8r,)r*r.rr?s r&test_create_server_multiple_hosts_ipv4z:EventLoopTestsMixin.test_create_server_multiple_hosts_ipv48s6 ))&.*K*K*K M M M M MrcJ|tjgddS)N)rz::2r)r*r.rr?s r&test_create_server_multiple_hosts_ipv6z:EventLoopTestsMixin.test_create_server_multiple_hosts_ipv6<s6 ))&/*?*?*? A A A A Arct|j|jfddd}|j|}|t |jd|jd}|\}}||dtj}| d|f| d|jj |dj tj|jfd|d j|jd |djd dj|jj|d j ||dS) NcSrrrsrr*z8EventLoopTestsMixin.test_create_server..BsEr0.0.0.0rrrxxxr\cjdkSrrMrsrr*z8EventLoopTestsMixin.test_create_server..O q0@rrrdrrl)rpr1rr0rrdr$rr.rrrOrLrr3rMrirKrjr@rP)r6rr(r rrrrs @rtest_create_serverz&EventLoopTestsMixin.test_create_server@s "" I # #MMMM9a @ @--a00 V^,,a000~a %%'' d y))) T*+++v $$U_555 ek222TY(@(@(@(@AAA EL))) U_;;JGGHHH 77 CCAF H H H  $$UZ000 5;///    r SO_REUSEPORTzNo SO_REUSEPORTct|j|jfddd}|j|}|t |jd|jd}||tj tj | tj|jt|j|jfdddd}|j|}|t |jd|jd}||tj tj | dS)NcSrrrsrr*zCEventLoopTestsMixin.test_create_server_reuse_port..hErr2rrcSrrrsrr*zCEventLoopTestsMixin.test_create_server_reuse_port..ur;rT) reuse_port)rpr1rr0rrdr$r getsockoptr. SOL_SOCKETr8r@rrr)r6rr(r rs @rtest_create_server_reuse_portz1EventLoopTestsMixin.test_create_server_reuse_portds "" I # # MMM9a ) )--a00 V^,,a000~a   OO!6#6 8 8 9 9 9  ty))) "" I # # MMM9aD $ : :--a00 V^,,a000~a   OO!6#6 8 8 9 9 9  rc tj|fd|jj|fi|}|j|}|fS)NcjtjotjSr)rNpathexistsunlink)rCsrr*z7EventLoopTestsMixin._make_unix_server..s"t 4 4 H4r)rgen_unix_socket_pathr r1create_unix_serverr0)r6factoryrrr(rCs @r_make_unix_serverz%EventLoopTestsMixin._make_unix_server~sj.00 HHHHIII (DI ($ A A& A A--a00t|rc"t|j|fd\}}|t |jdt jt j}||| d|j j |dj tj|jfd|djj|j j|dj ||dS) NrtcSrrrsrr*z=EventLoopTestsMixin.test_create_unix_server..serrr3r\cjdkSrr5rsrr*z=EventLoopTestsMixin.test_create_unix_server..r6rrrl)rpr1rIrrdr$r.AF_UNIXrrr0rOrLrr3rMrKr@rP)r6r(rCrrs @rtest_create_unix_serverz+EventLoopTestsMixin.test_create_unix_serversVTY'''--mmmm<<  V^,,a000v~..tv $$U_555 ek222TY(@(@(@(@AAA EL)))  $$UZ000 5;///    rrMzNo UNIX Socketscht|jtj}|5|jfdd|}|t d5|j|dddn #1swxYwYddddS#1swxYwYdS)NrtcSrrrsrr*zOEventLoopTestsMixin.test_create_unix_server_path_socket_error..sUrz/testr z3path and sock can not be specified at the same time)rpr1r.rGr rJr0)r6r rrs @r)test_create_unix_server_path_socket_errorz=EventLoopTestsMixin.test_create_unix_server_path_socket_errors6TY'''}  0 0 ,,]]]]G$,OOA'' );<< 0 0 ,,Q/// 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0s5>>rcnt|j|fdtjtj\}}}|jt||tj}|j |\}}| d|j j | dj tj|jfd| dj||||fj|j j| d j ||dS) NrtcSrrrsrr*z.r;rrr3r\cjdkSrr5rsrr*z.r6rrrrl)rpr1r^rONLYCERTONLYKEYrxrGrr0rsrOrrLr3rMrrKr@rP)r6r(rrf_crrors @rtest_create_server_sslz*EventLoopTestsMixin.test_create_server_sslsTY'''!22 MMM:. 0BDDdi))+tT.8.J.L.L*NNY11#66  V $$U_555 ek222TY(@(@(@(@AAA EL))) !!&D$<!@@@  $$UZ000 5;///    rc:t|j|fdtjtj\}}|jt|tjd}|j |\}}| d|j j | dj tj|jfd| djj|j j| d j ||dS) NrtcSrrrsrr*zAEventLoopTestsMixin.test_create_unix_server_ssl..r;rrrrr3r\cjdkSrr5rsrr*zAEventLoopTestsMixin.test_create_unix_server_ssl..r6rrrl)rpr1r`rrdrerrGrr0rsrOrrLr3rMrKr@rP)r6r(rCrfrrors @rtest_create_unix_server_sslz/EventLoopTestsMixin.test_create_unix_server_sslsrTY'''11 MMM:. 0BDD i.. :#?#A#A/  Y11#66  V $$U_555 ek222TY(@(@(@(@AAA EL)))  $$UZ000 5;///    rct|j|fdtj\}}}t jt j}|xjt j zc_t j |_ t|drd|_ |jt|||}tj|jd5tj5|t jd5|j|dddn #1swxYwYdddn #1swxYwYtj|jdddn #1swxYwY|j|dS)NrtcSrrrsrr*zJEventLoopTestsMixin.test_create_server_ssl_verify_failed..r;rcheck_hostnameTrcall_exception_handler(?i)certificate.verify.failed)rpr1r^rSIGNED_CERTFILErrTPROTOCOL_TLS_CLIENTrVrW CERT_REQUIRED verify_moderrorxrrobjectrr rr0r assertIsNonerKr@r6r(rrsslcontext_clientrfrs @r$test_create_server_ssl_verify_failedz8EventLoopTestsMixin.test_create_server_ssl_verify_failedsXTY'''!22 MMM:577d N3+BCC!!S_4!!(+(9% $&6 7 7 4/3  ,i))'4.?*AA Z  ty*B C C . .*,, 6 6++CL,KMM66I00555666666666666666 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6  "49 - - - . . . . . . . . . . . . . . . %/*** sZ&F :!EE6 EE E E E F E F  E !F  F F ct|j|fdtj\}}t jt j}|xjt j zc_t j |_ t|drd|_ |jt||d}tj|jd5tj5|t jd5|j|dddn #1swxYwYdddn #1swxYwYtj|jdddn #1swxYwY|j|dS) NrtcSrrrsrr*zOEventLoopTestsMixin.test_create_unix_server_ssl_verify_failed..$r;rroTinvalidrjrprq)rpr1r`rrrrrTrsrVrWrtrurrorrrrvrr rr0rrwrKr@)r6r(rCryrfrs @r)test_create_unix_server_ssl_verify_failedz=EventLoopTestsMixin.test_create_unix_server_ssl_verify_failedsZTY'''11 MMM:577  N3+BCC!!S_4!!(+(9% $&6 7 7 4/3  ,i..w3D?H/JJZ  ty*B C C . .*,, 6 6++CL,KMM66I00555666666666666666 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6  "49 - - - . . . . . . . . . . . . . . . %/*** sZ%F9!EE5 EE EE E FE FE FF F ct|j|fdtj\}}}t jt j}|xjt j zc_t j |_ | tj t|drd|_|jt|||}t"j|jd5tj5|t jd5|j|dddn #1swxYwYdddn #1swxYwYdddn #1swxYwY|j|dS) NrtcSrrrsrr*zIEventLoopTestsMixin.test_create_server_ssl_match_failed..Ar;rrroTrrpz=IP address mismatch, certificate is not valid for '127.0.0.1')rpr1r^rrrrrTrsrVrWrtruload_verify_locations SIGNING_CArrorxrrrvrr CertificateErrorr0rwrKr@rxs @r#test_create_server_ssl_match_failedz7EventLoopTestsMixin.test_create_server_ssl_match_failed=sjTY'''!22 MMM:577d N3+BCC!!S_4!!(+(9%//( 0 * * * $&6 7 7 4/3  ,i))'4.?*AA Z  ty*B C C 6 6*,, 6 6++,&''66I00555 666666666666666 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 %/*** sZF!E9;E" E9"E& &E9)E& *E9- F9E= =FE= FFFct|j|fdtj\}}t jt j}|xjt j zc_t j |_ | tj t|drd|_|jt||d}|j|\}}|jjj|||jjdS)NrtcSrrrsrr*zJEventLoopTestsMixin.test_create_unix_server_ssl_verified..`r;rrroTrrj)rpr1r`rrrrrTrsrVrWrtrurrrrorr0rOrKr@rP)r6r(rCryrfrrors @r$test_create_unix_server_ssl_verifiedz8EventLoopTestsMixin.test_create_unix_server_ssl_verified[sWTY'''11 MMM:577  N3+BCC!!S_4!!(+(9%//z7L/MMM $&6 7 7 4/3  ,i..w3D?J/LLY11#66  $$U_555    $$UZ00000rcHt|j|fdtj\}}}t jt j}|xjt j zc_t j |_ | tj t|drd|_|jt|||d}|j|\}}|jj||||ftjj|||jjdS) NrtcSrrrsrr*zEEventLoopTestsMixin.test_create_server_ssl_verified..zr;rrroTrrj)rr)rpr1r^rrrrrTrsrVrWrtrurrrrorxr0rOrPEERCERTrKr@rP) r6r(rrryrfrrors @rtest_create_server_ssl_verifiedz3EventLoopTestsMixin.test_create_server_ssl_verifiedvsTY'''!22 MMM:577d N3+BCC!!S_4!!(+(9%//z7L/MMM $&6 7 7 4/3  ,i))'4.?:E*GGY11#66  $$U_555 !!&D$<+5+> " @ @ @    $$UZ00000rc |j G fddt}tjd}|j||}|j|}|jd}|||| \}}||dtj}| d|f| d| | dS) Nc"eZdZfdZxZS)@EventLoopTestsMixin.test_create_server_sock..TestMyProtoctt||dSrrrr`r^)r6rKrtrs rr`zPEventLoopTestsMixin.test_create_server_sock..TestMyProto.connection_mades5'' 222  &&&&&rru)rtrs@r TestMyProtors> ' ' ' ' ' ' ' ' ' 'rrr2rrQrr2rr3) r1rNrpr.rr0r$rr#rrr8r@) r6rsock_obrr(r rrrrs @rtest_create_server_sockz+EventLoopTestsMixin.test_create_server_socks< '')) ' ' ' ' ' ' '' ' ' ' &~66 I # #Kg # > >--a00~a  (8(8999%%'' d y))) T*+++ F  rcDtjd}|jt|}|j|}|jd}|\}}|jt||}|t5}|j|dddn #1swxYwY| |j j tj | dS)NrrQrrr)r.rr1rpr0r$rrrrrrrr@)r6rrr(r rrrs rtest_create_server_addr_in_usez2EventLoopTestsMixin.test_create_server_addr_in_uses)&~66 I # #G' # : :--a00~a %%'' d I # #G$T # B B   w ' ' ,2 I ( ( + + + , , , , , , , , , , , , , , , +U-=>>> s0CCCzIPv6 not supported or enabledc |j G fddt}d} tj}|j|d|}|j|}nH#t$r;}|jtj kr |dz }| d|Yd}~d}~wwxYwtj }| d|f| d |j }|j||j tj tj}| d |f| d |j }|j||dS) Nc"eZdZfdZxZS)FEventLoopTestsMixin.test_create_server_dual_stack..TestMyProtoctt||dSrr)r6rKrtf_protos rr`zVEventLoopTestsMixin.test_create_server_dual_stack..TestMyProto.connection_mades5'' 222""4(((((rru)rtrs@rrrs> ) ) ) ) ) ) ) ) ) )rrrTrrrrr3r)r1rNrpr rrr0rrrassertGreaterEqualr.rr8rKr@r) r6r try_countrrr(exrrrs @rtest_create_server_dual_stackz1EventLoopTestsMixin.test_create_server_dual_stacks)))++ ) ) ) ) ) ) )' ) ) )    $577I++Kd+NN55a88   8u///NI++Ay999HHHH   T*+++ F ,,W55  )))++v//t}%%% F ,,W55   sA A?? C 0B?>B??Cc&|jtdd}|j|}|jd}|\}}t j}|d|f|d| | t j}| t|jd|f| dS)Nr2rrr3) r1rrpr0r$rr.rr8r@rConnectionRefusedError)r6rr(r rrrs rtest_server_closez%EventLoopTestsMixin.test_server_closes I # #GY : :--a00~a %%'' d T*+++ F    "FN[$4G I I I rc Gfddt}j|||}j|\} |d}t j|t jt jz\}} |tj  | d j  j|jfd||f}j|\} | tj  t d j  j| | dt#jj fd  d jt#jj fd  d j| d| j j d j  jdS)Nc,eZdZfdZfdZxZS)OEventLoopTestsMixin._test_create_datagram_endpoint..TestMyDatagramProtocVtjdSrs)rrrRr1) inner_selfrtr6s rrRzXEventLoopTestsMixin._test_create_datagram_endpoint..TestMyDatagramProto.__init__s&  di 00000rct|||jd|z|dS)Nsresp:)rrrrKsendto)r6rfrrts rrzaEventLoopTestsMixin._test_create_datagram_endpoint..TestMyDatagramProto.datagram_receiveds?))$555%%htmT:::::r)rCrDrErRrrv)rtr6s@rTestMyDatagramProtorsW 1 1 1 1 1 1 ; ; ; ; ; ; ; ; ;rr)rrrdr~c.tjSrsryr1r?srr*zDEventLoopTestsMixin._test_create_datagram_endpoint.. O333r) remote_addrr3cjSrr5)r(srr*zDEventLoopTestsMixin._test_create_datagram_endpoint..  rrcjSrr5)rsrr*zDEventLoopTestsMixin._test_create_datagram_endpoint..rrrl)ryr1create_datagram_endpointr0rjr. getnameinfoNI_NUMERICHOSTNI_NUMERICSERVrerrfrrLrhrKrrr3rMrir@rP) r6rrrr s_transportrdrrrKrr(s ` @@r_test_create_datagram_endpointz2EventLoopTestsMixin._test_create_datagram_endpoints ; ; ; ; ; ; ;/ ; ; ;y11 Jv2GG"i::4@@ V--j99' f+F,AACC d k7+<=== f&9:::  555 f& 444y11 3 3 3 3t 2&&!I88>> 6 i):;;; fo666  555 f& 222   TY(=(=(=(=>>> FM***TY(=(=(=(=>>> FM*** Y55jAABBB  $$V[111 6<000     rcF|dtjdS)Nr)rr.rr?s rtest_create_datagram_endpointz1EventLoopTestsMixin.test_create_datagram_endpoint%s! ++,.?rrrQ)r1r0rr. SOCK_DGRAMr0bindfailrrerrfryr@rP) r6r  local_addressinfosrrrcnameryrrnros ` r"test_create_datagram_endpoint_sockz6EventLoopTestsMixin.test_create_datagram_endpoint_sock,sl(  ,, !DI ! 8%+%6 8 89949 0 0 /FD% }FUKKK  ''' '"""  II. / / / I . . 3 3 3 3$ / @ @--a00B b'"3444 b/222   $$RW-----s ABB c|}t|tjs)||d|d|j||d|j||j ||j dS)Nz#loop is not a BaseSelectorEventLooprr) r isinstancer BaseSelectorEventLoopr@skipTestr _internal_fdsrw_csock_ssockrQs rtest_internal_fdsz%EventLoopTestsMixin.test_internal_fdsFs%%''$ EFF A JJLLL MM? @ @ @ D.///  D./// $+&&& $+&&&&&rrzDon't support pipes for WindowscHtjtj\}}t j|ddfd}j|tj|dtj jfd dj tj|dtj jfd  d d gj  d j tj |jj gd j jddS)Nrtrbrc,Kjfdd{V\}}||jddgjdjdS)NcSrrrsrr*zEEventLoopTestsMixin.test_read_pipe..connect..\srrJr\rr1connect_read_piperhrKrrLrM)rppipeobjrr6s rrz3EventLoopTestsMixin.test_read_pipe..connectZs44 w((((((((DAq MM!U # # # MM!U_ - - -   i5u{ C C C   Q - - - - -r1cjdkSr@r5rsrr*z4EventLoopTestsMixin.test_read_pipe..e 0Arr2345cjdkSNrr5rsrr*z4EventLoopTestsMixin.test_read_pipe..irrrJr\rrJr\rirlpipe)rr1rNrioopenr0rsrr3rrMrLr@rPrirKrj)r6rpipewpiperrrs` @@rtest_read_pipez"EventLoopTestsMixin.test_read_pipeRs TY///wyy u'%t,, . . . . . . . $$WWYY/// TY(A(A(A(ABBB EL)))    TY(A(A(A(ABBB )[15;??? EL)))  $$UZ000  5 5 5u{ D D D U_;;FCCDDDDDrcr |tt tj\}}t j|ddt j|ddd  fd}|\}}| dt|| dt| d|_ d|_ dS) Nrtrrr4zutf-8)encodingcKfdd{V\}}fdd{V\}}||fS)NcSrr read_protosrr*zSEventLoopTestsMixin.test_unclosed_pipe_transport..connect..s rcSrr write_protosrr*zSEventLoopTestsMixin.test_unclosed_pipe_transport..connect..s r)rconnect_write_pipe)read_transportrwrite_transportr1rrpipeobjwpipeobjrs rrzAEventLoopTestsMixin.test_unclosed_pipe_transport..connects&*&<&<""""H'.'.!.!.!.!.!.!. NA'+'>'>####X(/(/"/"/"/"/"/"/ OQ!?2 2rr) rrrrNrrrr0r@rrepr_pipe) r6rrrrrr1rrrrs @@@@@rtest_unclosed_pipe_transportz0EventLoopTestsMixin.test_unclosed_pipe_transportts@%%''$$/// &D111 wyy u75$--75#tg>>> 3 3 3 3 3 3 3 3 3+/*A*A''))*L*L'  fd>22333 fd?33444 # $ropenptyzneed os.openpty()cztjtj\}}t j|ddfd}j|tj|dtj jfd dj tj|dtj jfd  d d gj  d j tj |j jj gd j jddS)Nrtrrc,Kjfdd{V\}}||jddgjdjdS)NcSrrrsrr*zKEventLoopTestsMixin.test_read_pty_output..connect..sUrrJr\rr)rrmaster_read_objrr6s rrz9EventLoopTestsMixin.test_read_pty_output..connects44]]]]5DFFFFFFFFDAq MM!U # # # MM!U_ - - -   i5u{ C C C   Q - - - - -rrcjSrr5rsrr*z:EventLoopTestsMixin.test_read_pty_output..s  rrrcjdkSrr5rsrr*z:EventLoopTestsMixin.test_read_pty_output..rrrJr\rrr)rr1rNrrrr0rsrr3rrMrLr@rKrPrirj)r6masterslaverrrs` @@rtest_read_pty_outputz(EventLoopTestsMixin.test_read_pty_outputs TY/// '&$22 . . . . . . . $$WWYY/// TY(<(<(<(<=== EL)))    TY(A(A(A(ABBB )[15;??? EL)))   $$UZ000  5 5 5u{ D D D U_;;FCCDDDDDrcF tj\ }tj|dd}t |j|jfd|}|j|\}}||||j | dj | dt fdtj|jfd| d| d tj|jfd | d | dj tj |j d j |jj| d j dS)NwbrrtcSrrrsrr*z5EventLoopTestsMixin.test_write_pipe..urr\rcVtjd}||z }t|SrrNr;rd)rfchunkrs rr&z3EventLoopTestsMixin.test_write_pipe..readers)GE4((E EMDt99 rc"dkSr@rrfr&srr*z5EventLoopTestsMixin.test_write_pipe..t 0Arrc"dkSrrr srr*z5EventLoopTestsMixin.test_write_pipe..r r12345rrl)rNrrrrr1rr0rhrKrrLrsr1rr3r@rirjrP) r6rrrrKrrfrr&rs @@@@rtest_write_pipez#EventLoopTestsMixin.test_write_pipeswyy u'%t,, di000)..}}}}gFFy33G<< 1 a i111 ek222{{      TY(A(A(A(A(ABBB t$$$   TY(A(A(A(A(ABBB 4((( ek222  U_;;FCCDDD  $$UZ000 5;/////rc>tj\}}|dtj|dd}t |j|jfd|}|j |\}}| || |j | dj |d|j |j|d}| d|||j j| dj dS) NFrrrtcSrrrsrr*zIEventLoopTestsMixin.test_write_pipe_disconnect_on_close..rrr\rrl)r.r/r0rrdetachrr1rr0rhrKrrLrs sock_recvr@rP) r6rsockwsockrrrKrrfrs @r#test_write_pipe_disconnect_on_closez7EventLoopTestsMixin.test_write_pipe_disconnect_on_closesb(** u %   '%,,..$55 di000)..}}}}gFFy33G<< 1 a i111 ek222y++DI,?,?t,L,LMM t$$$  $$UZ000 5;/////rrr-cv tj\}tj|dd}t |j|jfd|}|j|\}}||||j | dj | dtfd tj|j fdt j | d| d tj|j fd t j | d | dj tj|j d j |jj| dj dS)NrrrtcSrrrsrr*z4EventLoopTestsMixin.test_write_pty..rrr\rcVtjd}||z }t|Srrrfrrs rr&z2EventLoopTestsMixin.test_write_pty..reader )GFD))E EMDt99 rc"dkSr@rr srr*z4EventLoopTestsMixin.test_write_pty..r rtimeoutrc"dkSrrr srr*z4EventLoopTestsMixin.test_write_pty..r rr rrl)rNrrrrr1rr0rhrKrrLrsr1rr3r SHORT_TIMEOUTr@rirjrP) r6rslave_write_objrrKrrfrrr&s @@@@rtest_write_ptyz"EventLoopTestsMixin.test_write_ptys( '%q11 di000)..}}}}oNNy33G<< 1 a i111 ek222{{      TY(A(A(A(A(A%,%: < < < < t$$$   TY(A(A(A(A(A%,%: < < < < 4((( ek222  U_;;FCCDDD  $$UZ000 5;/////rc tj\ }tj|}tj|t j|dd}t|j |j fd|}|j |\}}| | | | j | ddg j| d jt j|dd}t!|j|jfd|}|j |\} }| || | j | djt% fd  | d t)j|j fd t,j | d | ddg j| djtj d t)j|j fdt,j | ddg j| d j| dj| dt)j|j fdt,j | d | ddg j| djtj dt)j|j fdt,j | ddg j| d j| djtj ||j j| gd j| |j j| djdS)NrrrtcSrrrsrr*z.2s:rrJr\rcSrrrsrr*z.=s[rcVtjd}||z }t|Srrrs rr&z:EventLoopTestsMixin.test_bidirectional_pty..readerErrrc"dkSr@rr srr*z.Kr rracjdkSr@r5rsrr*z.R 0AQ0Frrrc"dkSrrr srr*z.Yr rr sbcdecjdkSrr5rsrr*z.`r(rrrrl)rNrdupttysetrawrrrr1rr0rhrKrrLrMrrr1rsrr3r rr@rP)r6 read_slave write_slaveslave_read_obj read_connectrrr write_connectrrfrrr&rs @@@@@rtest_bidirectional_ptyz*EventLoopTestsMixin.test_bidirectional_pty%s Z\\ fZ((  :T155$$)444 y223E3E3E3E3ACC  I88FF a$$$ nj&:;;; )[1:3CDDD J-...'+tQ77&DI666  445H5H5H5H5DFF !Y99-HH a%%% o{'<=== k&7888{{      d###TY(A(A(A(A(A%,%: < < < < t$$$ )[1:3CDDD k&7888 TY(F(F(F(F%,%: < < < < )[1:3CDDD J-... k&7888g&&&TY(A(A(A(A(A%,%: < < < < 4((( )[1:3CDDD k&7888 !!!TY(F(F(F(F%,%: < < < < )[1:3CDDD J-... k&7888  $$Z_555  5 5 5z7G I I I  $$[%5666 ;#455555rcvtj\}}|djj|dt dd}||jfd}tj }j|}j tj |z } |d |dt jj||jj|||dS)NFrovcK jjd{Vd}n#tj$rd}YnwxYwjn#jwxYw|S)N cancelled)r1rrrCancelledErrorr)r rr6s rmainz:EventLoopTestsMixin.test_prompt_cancellation..mainys ! ##AH---) " " "! "           Js&'/A AA AA A;rr7)r.r/r0r1rrgetattrrpendingr monotonicr assertLessrresultrrr8rr#r@) r6r%r4r5r9rrelapsedrs ` @rtest_prompt_cancellationz,EventLoopTestsMixin.test_prompt_cancellationqs ""1 e I ! !$)"5"5a";"; < < Qd # # > OOBJ ' ' '         I ! !$$&& ) ) .""U* %%% [111 '0!(;;; >   RZ ( ( ( """    rc0fd}jjdj_|j_fd}j|jjdjjjjjjddS)NcFjxjdz c_dSr@)r1_run_once_counter) orig_run_oncer6sr _run_oncez._run_onces( I ' '1 , ' ' MOOOOOrrcKj}tjdd{Vtjdd{Vtjdd{Vtjdd{Vtjdd{VdS)NrYg-C6?gư>g:0yE>g|=)r1rrr1r6s rwaitz7EventLoopTestsMixin.test_timeout_rounding..waits9D-%% % % % % % % %-%% % % % % % % %-%% % % % % % % %-%% % % % % % % %-&& & & & & & & & & &r)clock_resolutionselector) r1rErCr0assertLessEqual_clock_resolution _selectorrtrC)r6rErHrDs` @rtest_timeout_roundingz)EventLoopTestsMixin.test_timeout_roundings       + &' #'  ' ' ' ' ' $$TTVV,,, TY8"!%!<,6? A A B B B B Brc|}d}tj\}}||j||j|||||||||||| |dS)NcdSrrrrrr*zCEventLoopTestsMixin.test_remove_fds_after_closing..4r) rr.r/r r@r2r9rr"r:r6r1rr%r4s rtest_remove_fds_after_closingz1EventLoopTestsMixin.test_remove_fds_after_closings%%''< ""1         8$$$ 8$$$  ++A../// ++A../////rc|}d}tj\}}||j||j||t 5|||dddn #1swxYwY|t 5|||ddddS#1swxYwYdS)NcdSrrrrrr*z@EventLoopTestsMixin.test_add_fds_after_closing..rRr) rr.r/r r@rrr2r9rSs rtest_add_fds_after_closingz.EventLoopTestsMixin.test_add_fds_after_closingsj%%''< ""1           | , , ) ) OOAx ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )   | , , ) ) OOAx ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s$B33B7:B7C<<DDcfd}|j}t5j|ddddS#1swxYwYdS)Nc>KjdSr)r1r@rGs r close_loopzEEventLoopTestsMixin.test_close_running_event_loop..close_loops IOO     r)r1rrr0)r6rZrs` rtest_close_running_event_loopz1EventLoopTestsMixin.test_close_running_event_loops     z$)$$   | , , / / I ( ( . . . / / / / / / / / / / / / / / / / / /sAA Ac|jd}d}|}||j|t5|jdddn #1swxYwY|t5|j}|j|dddn #1swxYwY|t5|j|dddn #1swxYwY|t5|j |dddn #1swxYwY|t5|j d|dddn #1swxYwY|t5|j |j dz|dddn #1swxYwY|t5|j |dddn #1swxYwY|t5|jtj|dddn #1swxYwY|t5|jd|}t'|ddddS#1swxYwYdS)Nc KdSrrrrrtestz,EventLoopTestsMixin.test_close..tests DrcdSNFrrrrr*z0EventLoopTestsMixin.test_close..surg?g)r1r@r rrrrNr0rrrcall_atrrrHrKSIGTERMr rBnext)r6r^funcrfutits r test_closezEventLoopTestsMixin.test_closes    }tvv  ###  | , , $ $ I ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $   | , , . .)))++C I ( ( - - - . . . . . . . . . . . . . . .  | , , & & I   % % % & & & & & & & & & & & & & & &   | , , 1 1 I * *4 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1   | , , , , I d + + + , , , , , , , , , , , , , , ,   | , , ; ; I  dinn..3T : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;   | , , ( ( I ! !$ ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( (   | , , ? ? I ( ( > > > ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?   | , ,  **466@@BBB HHH                  sBB B)4C))C-0C-D55D9<D9FFF&GGG36H55H9<H9JJJ&&KKK==MM M )T)TN)NNr)\rCrDrErrrrrrrrrrrr5r<unittest skipUnlessrrKrTr]rbrpr|r skip_unless_bind_unix_socketrrrrskipIfrrrrrrrrrrrrr*r-r/r7r.r@rIrNrRr\r^r`rgrlrzr~rrrrr IPV6_ENABLEDrrrrrrrrr rrrNrr rr requires_mac_verr r3r@rOrTrWr[rgrvrws@rrrs '''''  E E E$555 >>> 3 3 3 8 8 8666. 6 6 6>>>!!!(0008%%%(X33\BB)I)ICB)IVX33\BBX55244$$44CB$ X33\BBX55244$$44CB$"    777 /GG0/G;?&*R????B8<15    CG#K#K#K#KJX_SD[/22EE32E/X_SD[/22 E E320/ E   ,,,*,,,(EEE46464646lX_SD[/22JJ32J ///TZ,--55.-56MMMAAA"""HX88:KLLML2/0/6X335FGG00HG0 " " " "????X_SD[/2232>/X_SD[/22320/:X_SD[/22328/X_SD[/22320/8X_SD[/2232:/X_SD[/2211320/12X_SD[/2211321:.   X35TUU&&VU&P$.!.!.!`NNNX35TUUIIVUI...4 ' ' 'X0:<<EE<<E@X0:<<%%<<%@X0:<<XY//1DEEEEFE<<EBX0:<<#0#0<<#0JX0:<<00<<0*X0:<<XY//1DEEWb!$$%0%0%$FE<< %0NX0:<<XY//1DEEWb!$$D6D6%$FE<< D6L!!!FBBB4 0 0 0 ) ) )///"""""""rrceZdZdZdZdZdZdZdZdZ dZ d Z e j ejd kd d Zd ZdZdZdZdZdZdS)SubprocessTestsMixinctjdkr||tdS|t j |dSNr)rr rer%rrKrbr6rs rcheck_terminatedz%SubprocessTestsMixin.check_terminatedM <7 " "  ! !*c 2 2 2 2 2   fn_j 9 9 9 9 9rctjdkr||tdS|t j |dSrq)rr rer%rrKr=rrs r check_killedz!SubprocessTestsMixin.check_killedrtrctjtjtd}|jtjt|jtj |}|j |\}}| |t|j |j|d|j|d}|d|j |jdt+j5|dddn #1swxYwY|j |j||j|d|jddS)Necho.pyr\rPython The Winnerr)rNrCrdirname__file__r1subprocess_execrrrr executabler0rerOrrLget_pipe_transportrsrrHrrr@rrvrrfr6progrtransprstdins rtest_subprocess_execz)SubprocessTestsMixin.test_subprocess_execsw||BGOOH55yAA)++!)*> JJ.. 44W==  e%9::: $$U_555 ek222))!,, ())) $$U^A%6%;%;%=%=>>>  & ( (   LLNNN                $$U_555 %*+++ -uz!}=====s,F  FFctjtjtd}|jtjt|jtj |}|j |\}}| |t|j |j|d|j|d}|d|j |jd|jd|d|jd|d|j |jd|d|jdt/j5|dddn #1swxYwY|j |j||jdS)Nrxr\rsPython rs The Winnerry)rNrCrrzr{r1r|rrrrr}r0rerOrrLr~rsrrHclearrfrrr@rrvrrs rtest_subprocess_interactivez0SubprocessTestsMixin.test_subprocess_interactives9w||BGOOH55yAA)++!)*> JJ.. 44W==  e%9::: $$U_555 ek222))!,, J $$U^A%6%;%;%=%=>>> q!!! UZ]333 M""" $$U^A%6%;%;%=%=>>> -uz!}===  & ( (   LLNNN                $$U_555 %*+++++sH::H>H>c>|jtjt|jd}|j|\}}||t|j|j|d |j|j | d|j | td|jD| |jddd| |jdd| dS) Nz echo Pythonrc3>K|]}|VdSr)rP)rrs r z=SubprocessTestsMixin.test_subprocess_shell..>s*IIAFFHHIIIIIIrrs sPythonrr)r1subprocess_shellrrrr0rerOr~r@rrrrallrvaluesrfrstripr6rrrs rtest_subprocess_shellz*SubprocessTestsMixin.test_subprocess_shell3sY),,!)*> JJ%'' 44W==  e%9::: $$U_555!!!$$**,,, $$U_555 E,--- IIe.?.F.F.H.HIIIIIJJJ A--g66 BBB A,,, rc|jtjt|jdddd}|j|\}}||t|j|j|d|j | dS)Nexit 7rstdoutstderr r1rrrrr0rerrrr@rs rtest_subprocess_exitcodez-SubprocessTestsMixin.test_subprocess_exitcodeCs),,!)*> JJ T$-HH 44W==  e%9::: $$U_555 E,--- rc|jtjt|jdddd}|j|\}}||t||d||d||d|j|j | d|j || dS)Nrrrrrr) r1rrrrr0rerwr~rrrr@rs r"test_subprocess_close_after_finishz7SubprocessTestsMixin.test_subprocess_close_after_finishNs'),,!)*> JJ T$-HH 44W==  e%9::: &33A66777 &33A66777 &33A66777 $$U_555 E,--- &,,..)))))rctjtjtd}|jtjt|jtj |}|j |\}}| |t|j |j||j |j||j|dSNrx)rNrCrrzr{r1r|rrrrr}r0rerOrOrrvrr@r6rrrrs rtest_subprocess_killz)SubprocessTestsMixin.test_subprocess_kill\sw||BGOOH55yAA)++!)*> JJ.. 44W==  e%9::: $$U_555  $$U_555 %*+++ rctjtjtd}|jtjt|jtj |}|j |\}}| |t|j |j||j |j||j|dSr)rNrCrrzr{r1r|rrrrr}r0rerO terminaterrsrr@rs rtest_subprocess_terminatez.SubprocessTestsMixin.test_subprocess_terminatelsw||BGOOH55yAA)++!)*> JJ.. 44W==  e%9::: $$U_555 $$U_555 e./// rrzDon't have SIGHUPctjtjtj} tjtjtd}|j tj t|jtj|}|j|\}}||t|j|j|tj|j|j|tj |j|tjtj|dS#tjtj|wxYwr)rKSIGHUPSIG_DFLrNrCrrzr{r1r|rrrrr}r0rerO send_signalrrrr@)r6 old_handlerrrrrs rtest_subprocess_send_signalz0SubprocessTestsMixin.test_subprocess_send_signal|sH mFM6>BB  67<< 9 99EEDi//%-.BDINNND22G !I88AAMFE  ! !%)= > > > I ( ( 9 9 9   v} - - - I ( ( 9 9 9   fm^U-= > > > LLNNN M&- 5 5 5 5 5FM&- 5 5 5 5s EF !Gcntjtjtd}|jtjt|jtj |}|j |\}}| |t|j |j|d}|d|j |j||d|jd||jdd|jd|d|jdS)Necho2.pyrtestOUT:testrrsERR:test)rNrCrrzr{r1r|rrrrr}r0rerOr~rsrr@rrfrr!rrs rtest_subprocess_stderrz+SubprocessTestsMixin.test_subprocess_stderrsSw||BGOOH55zBB)++!)*> JJ.. 44W==  e%9::: $$U_555))!,, G $$U_555  ejm444  1 00==uz!}MMM E,-----rc&tjtjtd}|jtjt|jtj |tj }|j|\}}||t|j|j|d}||d||d|d|j|j||jdd|jd|d|jd||d|jdS) Nr)rrrrrsOUT:testERR:testr)rNrCrrzr{r1r|rrrrr} subprocessSTDOUTr0rerOr~rirwrsrrrfr!rr@rrs r)test_subprocess_stderr_redirect_to_stdoutz>SubprocessTestsMixin.test_subprocess_stderr_redirect_to_stdoutsw||BGOOH55zBB)++!)*> JJZ5F,HH  44W==  e%9::: $$U_555))!,, V66q99::: &33A66777 G $$U_555  1 001DEE 1  ' ' ' ejm,,,  E,-----rctjtjtd}|jtjt|jtj |}|j |\}}| |t|j |j|d}|d}|d|j |jd|d|jd||j |jd|d|j |jdtjdkr"|d |jdn!|d |jdt1j5|dddn #1swxYwY|j |j||jdS) Nzecho3.pyrrrrr3rrsERR:BrokenPipeErrors ERR:OSError)rNrCrrzr{r1r|rrrrr}r0rerOr~rsrrHrrfr@rr rrrrvr)r6rrrrrrs r#test_subprocess_close_client_streamz8SubprocessTestsMixin.test_subprocess_close_client_streamstw||BGOOH55zBB)++!)*> JJ.. 44W==  e%9::: $$U_555))!,,**1-- G $$U^A%6%;%;%=%=>>> ejm444  $$U%6q%9::: F $$U^A%6%;%;%=%=>>> <7 " "   3UZ] C C C C   ^UZ] ; ; ;  & ( (   LLNNN                $$U_555 %*+++++sJJJc|jtjt|jddddd}|j|\}}||t|j|j|d|j | dS)NrT)rrrstart_new_sessionrrrs r"test_subprocess_wait_no_same_groupz7SubprocessTestsMixin.test_subprocess_wait_no_same_groups),,!)*> JJ T$*.-00 44W==  e%9::: $$U_555 E,--- rcfd}t5j|ddddn #1swxYwYt5j|ddddn #1swxYwYt5j|dddddS#1swxYwYdS)NcTKjjtjdfi|d{VdSNpwd)r1r|rSubprocessProtocol)rr6s rrzGSubprocessTestsMixin.test_subprocess_exec_invalid_args..connects^+$)+*         rTuniversal_newlinesbufsizeshellrrJr1r0r6rs` r!test_subprocess_exec_invalid_argsz6SubprocessTestsMixin.test_subprocess_exec_invalid_argss        z * * K K I ( (D)I)I)I J J J K K K K K K K K K K K K K K K   z * * @ @ I ( ()>)>)> ? ? ? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @   z * * > > I ( (t)<)<)< = = = > > > > > > > > > > > > > > > > > >s5%AAA7%B((B,/B, %C??DDcd fd }t5j|ddgdddn #1swxYwYt5j|ddddn #1swxYwYt5j|ddddn #1swxYwYt5j|d ddddS#1swxYwYdS) Nc\K|sd}jjtj|fi|d{VdSr)r1rrr)cmdrr6s rrzHSubprocessTestsMixin.test_subprocess_shell_invalid_args..connectsk ,$),*         rlsz-lTrrrFrrrrs` r"test_subprocess_shell_invalid_argsz7SubprocessTestsMixin.test_subprocess_shell_invalid_argss        z * * @ @ I ( ($)>)> ? ? ? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @   z * * K K I ( (D)I)I)I J J J K K K K K K K K K K K K K K K   z * * @ @ I ( ()>)>)> ? ? ? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @   z * * ? ? I ( (u)=)=)= > > > ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?sG&AAA9%B**B.1B.%DDD%%EEEN)rCrDrErsrvrrrrrrrrhrkrr rrrrrrrrrrroros)::::::>>>*,,,6    * * *  X_S\W,.ABB66CB60...*...2 , , ,D    > > >?????rrorceZdZdZdS)SelectEventLoopTestsc(tjSr)rSelectorEventLoopr?s rrz&SelectEventLoopTests.create_event_loop,.. .rNrCrDrErrrrrrs# / / / / /rrc2eZdZdZdZdZdZdZdZdS)ProactorEventLoopTestsc(tjSr)rProactorEventLoopr?s rrz(ProactorEventLoopTests.create_event_looprrc*tjdNz(IocpEventLoop does not have add_reader()rhSkipTestr?s rr5z+ProactorEventLoopTests.test_reader_callback #$NOO Orc*tjdrrr?s rtest_reader_callback_cancelz2ProactorEventLoopTests.test_reader_callback_cancel#rrc*tjdNz(IocpEventLoop does not have add_writer()rr?s rr<z+ProactorEventLoopTests.test_writer_callback&rrc*tjdrrr?s rtest_writer_callback_cancelz2ProactorEventLoopTests.test_writer_callback_cancel)rrc*tjdrrr?s rrTz4ProactorEventLoopTests.test_remove_fds_after_closing,rrN) rCrDrErr5rr<rrTrrrrrs / / / P P P P P P P P P P P P P P P P Prrc(eZdZfdZfdZxZS)UnixEventLoopTestsMixincttj}||jtj|dSr)rrrrSafeChildWatcher attach_loopr1set_child_watcherr6watcherrts rrzUnixEventLoopTestsMixin.setUp2sO GGMMOOO.00G    * * *  %g . . . . .rcptjdtdSr)rrrrrrs rrz UnixEventLoopTestsMixin.tearDown8s0  %d + + + GG       r)rCrDrErrrvrws@rrr1sQ / / / / /          rrKqueueSelectorceZdZdZejddejej ddfdZ ejddfdZ xZ S)KqueueEventLoopTestscLtjtjSr)rr selectorsrr?s rrz&KqueueEventLoopTests.create_event_loopBs#0,..000rr openbsdztest hangs on OpenBSDcHtdSr)rrrrs rrz)KqueueEventLoopTests.test_read_pty_outputHs! ,,.....rcHtdSr)rrr rs rr z#KqueueEventLoopTests.test_write_ptyRs&&(((((r)rCrDrErr rmrhrkrr r!rr rvrws@rrr>s 0 0 0 &W %b! , ,X_S\44Y??466 / / / /66- ,  / &W %b! , , ) ) ) )- , ) ) ) ) )rr EpollSelectorceZdZdZdS)EPollEventLoopTestscLtjtjSr)rrrrr?s rrz%EPollEventLoopTests.create_event_loop[s01H1J1JKKKrNrrrrrrWs( L L L L Lrr PollSelectorceZdZdZdS)PollEventLoopTestscLtjtjSr)rrrrr?s rrz$PollEventLoopTests.create_event_loopcs01G1I1IJJJrNrrrrrr_s( K K K K KrrceZdZdZdS)rcLtjtjSr)rrrSelectSelectorr?s rrz&SelectEventLoopTests.create_event_loopks,Y-E-G-GHH HrNrrrrrrgs( I I I I IrcdSrr)rrs rnooprosDrceZdZfdZdZdZdZdZdZdZ e j e e jdd d ZxZS) HandleTestscttj|_d|jj_dSr)rrrrr!r1 get_debug return_valuers rrzHandleTests.setUpus4  IKK +/ (((rcvd}d}tj|||j}||j|||j||||| |dS)Nc|Srrrs rrz)HandleTests.test_handle..callback{Krr) rHandler1rh _callback_argsrr7rr)r6rrhs r test_handlezHandleTests.test_handlezs    N8T49 5 5 ak8,,, agt$$$ '''    &&&&&rc^d}tj|_tj|j_t j|d|j}||jjtj dtj ||j ddS)Nctr)rJrrrrz:HandleTests.test_callback_with_exception..callbacks ,, rrzException in callback.*)rrhandlesource_traceback) rr!r1rprr_runassert_called_withr MockPatternANY_source_traceback)r6rr s rtest_callback_with_exceptionz(HandleTests.test_callback_with_exceptions   IKK +/9;; ( N8R 3 3  (;;!-.GHH ! 3 = =      rcntj}tjdd|j}||d<dS)NcdSrrrrrr*z1HandleTests.test_handle_weakref..s4rrr )weakrefWeakValueDictionaryrrr1)r6wdr s rtest_handle_weakrefzHandleTests.test_handle_weakrefs4  ( * * N<<TY 7 73rc$d|jj_tjt d|j}t jt \}}|t|d|d|d| |t|dtj t }tj|d|j}|t|d|d|dtjt d d }tj|d |j}d tj|d|d }|t||tjt d }tj|d|j}dtj|d|d }|t||t$j}tj|}t j|\}}tj|d|j}d}d|d}d|dtj|d|d }|t||dS)NFrzrz$)x)rrz ^zfunctools.partialmethod\(z , , \)\(\)z ^+>KKKKK a%(((((rc Td|jj_t}t jjdz}tjtd|j}tj t\}}| t|d|d|d|d|d || t|d|d|d|d|d || t|d|d|d|d|d dS) NTrrrr created at rz .check_source_tracebacksv]1%%.2F  ! !!"5t < < <   Q04RaR8&$<> ? ? ? ? ?rr) rget_event_loop_policyr. set_debugr/rrrr)r6r1r:r s` rr8z(HandleTests.test_handle_source_tracebacks,..==?? t D!!! ? ? ? ? ? NN4 q!!!  % %d + +q!!! OOAt $ $q!!! OOAt $ $q!!!!!r CoroutinezNo collections.abc.Coroutinect}d|_|tj||t j|dd|_|t j|dd|_ |t j|ddx|_|_|t j|dt}d|_|t j|d t}d|_d|_ |t j|ddS) NAAAzAAA()BBBzBBB()Tz BBB() runningz%() runningr4z CoroLike()) r4rCrr iscoroutinerr_format_coroutinerE cr_runningcr_code)r6rs r+test_coroutine_like_object_debug_formattingz7HandleTests.test_coroutine_like_object_debug_formatting sRzz  +D11222 5d;;WEEE! 5d;;WEEE 5d;;_MMM,00 ) 5d;;@ B B Bzz& 5d;;\JJJzz!  5d;;WEEEEEr)rCrDrErr rrr'r5r8rhrir collectionsabcrErvrws@rrrss00000 ' ' '   " -)-)-)^BBB4""":X+>>799FF99FFFFFrrcBeZdZfdZdZdZdZdZdZdZ xZ S) TimerTestscxttj|_dSr)rrrrr!r1rs rrzTimerTests.setUp' s%  IKK rctj}tj|ddt j}|t|t|dS)NcdSr`rrrrr*z&TimerTests.test_hash..- err)rr<r TimerHandlerr!rhashr6whenr s r test_hashzTimerTests.test_hash+ sZ~  mmR $  - - a$t**-----rctj}tj|ddt j}|||dS)NcdSr`rrrrr*z&TimerTests.test_when..3 rMrr)rr<rrNrr!rrQrPs r test_whenzTimerTests.test_when1 sV~  mmR $  - - qvvxx(((((rcd}d}tj}tj|||t j}||j|||j|| | | | | | |j| |jdS)Nc|Srrrs rrz'TimerTests.test_timer..callback8 rr)rrr)rr<rrNrr!rhrr rr7rrrw)r6rrrQr s r test_timerzTimerTests.test_timer7 s   ~  hdikk B B ak8,,, agt$$$ '''    &&& !+&&& !'"""""rcVd|jj_tjdt d|j}t jt }|t|d|z| |t|ddS)NF{rz&z ) r1rrrrNrrr!rrr)r6r srcs rtest_timer_reprzTimerTests.test_timer_reprI s+0 (  T2ty 9 9,T22 a@3F H H H   a: < < < < .callbackm rrrg$@)rr<rrNr1rrrrrhNotImplemented__eq____ne__rrGrrr)r6rrQh1h2h3s rtest_timer_comparisonz TimerTests.test_timer_comparisonl s   ~  xTY ? ?  xTY ? ? b!!! b!!! b!!! b!!! b!!! b!!! b!!! b!!! b!!! r"""  r"""  xTY ? ?  hDI F F R    b!!! b!!! r""" b!!! R    r""" b!!! r""" b!!! ^Hb$) 4 4 nbiimm444 nbiimm444   y ) )   GG                  y ) )   GG                  y ) )   "HH                  y ) )   "HH                r""" b!!! i((( y))) W %%% g&&& g &&& w''' h''' X &&& x((( h'''''sH<MMM4NN N ,N??OO$O77O;>O;) rCrDrErrRrUrXr\r^rgrvrws@rrIrI% s     ... ))) ###$ < < <NNN*<(<(<(<(<(<(<(rrIceZdZdZdZdS)AbstractEventLoopTestsctj}tj}|t |j|t |jd|t |j|t |j |t |j |t |j |t |j d|t |j dd|t |j|||t |jd|t |j|t |jd|t |j||t |jd||t |jd|t |jd||t |jd|t |jd||t |jd|t |jd|t |j||t |j||t |j||t |j|t |j|dSr@)rr!rAbstractEventLooprNotImplementedErrorrr0rrrr@rrrarrrset_default_executorr2r"r9r:rHrIset_exception_handlerdefault_exception_handlerrprr<)r6rr1s rtest_not_implementedz+AbstractEventLoopTests.test_not_implemented s IKK(**  !1 3 3 3  !8$ @ @ @   , , ,   2 2 2   1 1 1   - - -  !14 9 9 9  $ > > >  q! 5 5 5   7 7 7   , , ,  !:D B B B  !:A ? ? ?  !Q 8 8 8  !3Q 8 8 8  !Q 8 8 8  !3Q 8 8 8  !8!Q @ @ @  !;Q @ @ @  !;Q @ @ @  !;Q @ @ @  !? D D D  !.inner s  A,..D""#677 1 1**1a000000000 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1""#677 : :&&{D999999999 : : : : : : : : : : : : : : :""#677 < <&&':;;;;;;;;; < < < < < < < < < < < < < < <""#677 0 0,,Q///////// 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0""#677 , ,((+++++++++ , , , , , , , , , , , , , , ,""#677 7 733A666666666 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7""#677 , ,nnQ+++++++++ , , , , , , , , , , , , , , ,""#677 1 1))!R000000000 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1""#677 / /''2......... / / / / / / / / / / / / / / /""#677 . .''1--------- . . . . . . . . . . . . . . .""#677 * *&&q))))))))) * * * * * * * * * * * * * * *""#677 / /((A......... / / / / / / / / / / / / / / /""#677 * *mmAq))))))))) * * * * * * * * * * * * * * *""#677 D D,,Q 0BCCCCCCCCC D D D D D D D D D D D D D D D""#677 E E--a1CDDDDDDDDD E E E E E E E E E E E E E E E""#677 > >++At}========= > > > > > > > > > > > > > > >""#677 . .**1--------- . . . . . . . . . . . . . . . . . .s2A--A14A1B;;B?B? DD D -EEE:F""F&)F&G//G36G3H==II"J  JJ0KK K>L''L+.L+ M44M8;M8OO O'PPP5,Q--Q14Q1,S  SS/'T""T&)T&U00U47U4)rr.r0r@)r6r{r1s` rtest_not_implemented_asyncz1AbstractEventLoopTests.test_not_implemented_async sX% .% .% .% .% .N%'' ((( rN)rCrDrErpr|rrrriri s3444444l+++++rricpeZdZdZdZdZdZejddZ dZ dZ d Z d Z d S) PolicyTestsctj}|t|j|t|jt |t|j|t|j|t|j t dSr) rAbstractEventLoopPolicyrrlget_event_loopr/rvr.get_child_watcherrr6policys rtest_event_loop_policyz"PolicyTests.test_event_loop_policy s022 -v/DEEE -v/DfhhOOO -v/DEEE -v/GHHH -v/G (( $ $ $ $ $rctj}||jj|}||tj||jj||||| dSr) rDefaultEventLoopPolicyrw_local_looprrerkrhr@r6rr1s rtest_get_event_loopzPolicyTests.test_get_event_loop s/11 &--...$$&& dG$=>>> fm)4000 dF1133444 rcXtj}tj|d|j5}|}||j| |dddn #1swxYwY|dS)Nr/)wraps) rrrrrvr/rr r@r)r6rm_set_event_loopr1s r(test_get_event_loop_calls_set_event_loopz4PolicyTests.test_get_event_loop_calls_set_event_loop& s/11 Z  (+-- 60@((**D OODJ ' ' '  / / 5 5 5 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 sAB  BBctj}|d|t|jdSr)rrr/rrrrs r"test_get_event_loop_after_set_nonez.PolicyTests.test_get_event_loop_after_set_none7 sC/11d### ,(=>>>>>rz'asyncio.events.threading.current_threadcfd}tj|}||dS)Ncntj}t|jdSr)rrrrr)rr6s rrz1PolicyTests.test_get_event_loop_thread..f? s0355F   lF,A B B B B Brr)rrrr)r6m_current_threadrths` rtest_get_event_loop_threadz&PolicyTests.test_get_event_loop_thread< sT C C C C C Q ' ' '    rctj}|}||tj|dSr)rrr.rerkr@rs rtest_new_event_loopzPolicyTests.test_new_event_loopG sK/11$$&& dG$=>>> rctj}|}|||t |jt |}|||||| ||| | dSr) rrr.r/rrGrvrhr assertIsNotr@)r6rold_loopr1s rtest_set_event_loopzPolicyTests.test_set_event_loopN s/11((**h''' )V%:FHHEEE$$&&d### dF1133444 6#8#8#:#:;;; rctj}||tj||tjdSr)rr;rerrhrs rtest_get_event_loop_policyz&PolicyTests.test_get_event_loop_policy\ sL.00 fg&EFFF fg;==>>>>>rcX|ttjt tj}tj}tj|||tj|||dSr) rrGrrrvr;rrhr)r6 old_policyrs rtest_set_event_loop_policyz&PolicyTests.test_set_event_loop_policya s  w4fhh @ @ @244 /11%f--- fg;==>>> ,,,,,rN)rCrDrErrrrrrrrrrrrrrr~r~ s$$$"??? TZ9::;:   ??? - - - - -rr~c`eZdZdZdZdZdZfdZfdZe j dkrdZ dZ dZ xZS)GetEventLoopTestsMixinNctj|_tj|_tj|_tj|_t|j t_t|j t_t|j t_t|j t_t|j t_t|j t_t|j t_t|j t_ttj|_tj|jt(jdkrCtj}||jtj|dSdSrq)r_get_running_loop_get_running_loop_saved_set_running_loop_set_running_loop_savedget_running_loopget_running_loop_savedrget_event_loop_savedr_get_running_loop_impl_set_running_loop_implget_running_loop_implget_event_loop_implrrrrr.r1r/rr rrrrs rrzGetEventLoopTestsMixin.setUpt s;'-'?$'-'?$&,&=#$*$9!#'::#D #'::#D "&t**"B $T >$(JJ$E!$(JJ$E!#'::#C !%d!?  *,, ty))) <7 " ".00G    * * *  %g . . . . . # "rcp tjdkrtjdt |jtjd|j t_ |j t_ |jt_|jt_|j t_ |j t_ |jt_|jt_dS#|jtjd|j t_ |j t_ |jt_|jt_|j t_ |j t_ |jt_|jt_wxYwrq)rr rrrrrr1r@r/rrrrrrrrrrs rrzGetEventLoopTestsMixin.tearDown sG ?|w&&)$/// GG      IOO     "4 ( ( ('+'CF $'+'CF $&*&AF #$($=F !(,(DG %(,(DG %'+'BG $%)%>G " " " IOO     "4 ( ( ('+'CF $'+'CF $&*&AF #$($=F !(,(DG %(,(DG %'+'BG $%)%>G " > > > >s AC>>B7F5rctjfd}j|ddS)NcKtj}j|t d{V}||Sr) concurrentfuturesProcessPoolExecutorr1r r2shutdown)poolr>r6s rr9zDGetEventLoopTestsMixin.test_get_event_loop_new_process..main sp!)==??#y88D F FFFFFFF  rr,)r *skip_if_broken_multiprocessing_synchronizerr1r0)r6r9s` rtest_get_event_loop_new_processz6GetEventLoopTestsMixin.test_get_event_loop_new_process sm  > @ @ @         ,,TTVV44     rcGddtGfddtj}tj} tj|tj5tjdddn #1swxYwYtjd5tjdddn #1swxYwY td5tj dddn #1swxYwY tj dfd}|tj5tjdddn #1swxYwYtjd5tjdddn #1swxYwYtj|n0#tj|wwxYw td5tj dddn #1swxYwY tj ddS)NceZdZdS)RGetEventLoopTestsMixin.test_get_event_loop_returns_running_loop..TestErrorN)rCrDrErrr TestErrorr s DrrceZdZfdZdS)OGetEventLoopTestsMixin.test_get_event_loop_returns_running_loop..Policycrr)r6rs rrz^GetEventLoopTestsMixin.test_get_event_loop_returns_running_loop..Policy.get_event_loop srN)rCrDrEr)rsrPolicyr s.       rr no runningcKtjtjtjdSrrhrrrrrGsrrdzMGetEventLoopTestsMixin.test_get_event_loop_returns_running_loop..func d g466=== g688$??? g7994@@@@@r)rrrr;rr.rrr/r rrrhrr0r@)r6rrrdrr1s` @@r(test_get_event_loop_returns_running_loopz?GetEventLoopTestsMixin.test_get_event_loop_returns_running_loop s                W3   244    )&&(( 3 3 3)++D""9-- ) )&((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  "4 ( ( (""9-- ) )&((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )'' lCC + +(*** + + + + + + + + + + + + + + + MM'355t < < < A A A A A A  # #DDFF + + +  "4 ( ( (""9-- ) )&((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  "4 ( ( (""9-- ) )&((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  )* 5 5 5   )* 5 5 5   # #L, ? ? ' '  $ & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' g/11488888sAI+ B) I+)B--I+0B-1,I+C=1 I+=DI+DI+#E7 I+EI+ E A6I+G! I+!G%%I+(G%),I+H5) I+5H99I+<H9=I++-J6KKKctj} tjtjtjjtj}|jtjd td5tjdddn #1swxYwY td5tj dddn #1swxYwY tj dfd}|tj tjtjd td5tjdddn #1swxYwYtj|n0#tj|wwxYw td5tj dddn #1swxYwY tj ddS)Nz no currentrcKtjtjtjdSrrrGsrrdzNGetEventLoopTestsMixin.test_get_event_loop_returns_running_loop2..func rr)rr;rrr.r r@rr/r rrrhrr0)r6rloop2rdr1s` @r)test_get_event_loop_returns_running_loop2z@GetEventLoopTestsMixin.test_get_event_loop_returns_running_loop2 s244    )'*H*J*J K K K)++D OODJ ' ' '*,,E OOEK ( ( (  "4 ( ( ('' lCC ) )&((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )'' lCC + +(*** + + + + + + + + + + + + + + + MM'355t < < < A A A A A A  # #DDFF + + +  "4 ( ( ( MM'022D 9 9 9  "4 ( ( ('' lCC ) )&((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  )* 5 5 5   )* 5 5 5   # #L, ? ? ' '  $ & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' g/11488888sB.IC% I%C))I,C)-I D+ I+D//I2D/3B7I*H > I HIHI-I- J++J/2J/)rCrDrErrrrrrrr rrrrvrws@rrrm s!! /////4?????( |w   "-9-9-9^'9'9'9'9'9'9'9rrcFeZdZejZejZejZ ej Z dS)TestPyGetEventLoopN) rCrDrEr_py__get_running_loopr_py__set_running_loopr_py_get_running_loopr_py_get_event_looprrrrrr s4#9#9"7 3rrcFeZdZejZejZejZ ej Z dS)TestCGetEventLoopN) rCrDrEr_c__get_running_loopr_c__set_running_loopr_c_get_running_loopr_c_get_event_looprrrrrr s4!'!<!'!< & :$6rrceZdZdZdS) TestServerctj}||jt |||fddd}|||||| dS)NcSrrrsrr*z*TestServer.test_get_loop..* sErr2r) rr.r r@rpr0rrget_loop wait_closed)r6r1r(rs @r test_get_loopzTestServer.test_get_loop& s%''  ### ((););MMMM9VW)X)XYY **D111   2 2 4 455555rN)rCrDrErrrrrr$ s#66666rrc eZdZdZdZdZdS)TestAbstractServerc|t5tjddddS#1swxYwYdSr)rrlrAbstractServerr@r?s rrgzTestAbstractServer.test_close2 s   2 3 3 , ,  ! # # ) ) + + + , , , , , , , , , , , , , , , , , ,&AAAc6tj}||j|t 5|tj ddddS#1swxYwYdSr) rr.r r@rrlr0rrrrQs rtest_wait_closedz#TestAbstractServer.test_wait_closed6 s%''  ###   2 3 3 K K  # #F$9$;$;$G$G$I$I J J J K K K K K K K K K K K K K K K K K Ks9BBBc|t5tjddddS#1swxYwYdSr)rrlrrrr?s rrz TestAbstractServer.test_get_loop= s   2 3 3 / /  ! # # , , . . . / / / / / / / / / / / / / / / / / /rN)rCrDrErgrrrrrrr0 sD,,,KKK/////rr__main__)N__doc__collections.abcrFconcurrent.futuresrrrrNr r$rKr.r ImportErrorrrrrr"rrhrrr,rrrrr test.test_asyncior rr^r test.supportr r rrrrr(r2r4rgrGrpDatagramProtocolryr BaseProtocolrrrrroTestCaserrrrrrrrrrrIrir~rr_asynciorrrrCr9rrrrs  JJJJ CCC  <+++JJJ############111111&&&&&&))))))5555555555(((+++         #'#'#'#'#''"#'#'#'LHHHHHkHHH '''''g.'''@!'!'!'!'!'g&!'!'!'H'''''w+'''2*:*:*:*:*:75*:*:*:Zkkkkkkkk\/[?[?[?[?[?[?[?[?|<7/////2)2/// PPPPP!4!5!+!4PPPP,     "5   wy*++) ) ) ) ) )#:#7#-#6 ) ) )0wy/**L L L L L L"9"6","5 L L Lwy.))K K K K K K!8!5!+!4 K K KIIIII63)2III   oFoFoFoFoF*%oFoFoFdC(C(C(C(C("C(C(C(LcccccX.cccLY-Y-Y-Y-Y-(#Y-Y-Y-x^9^9^9^9^9^9^9^9B44444/1B444 7OOO 777772H4E7777    D  6 6 6 6 6" 6 6 6/////*///$ zHMOOOOOs-778JJJ