python (3.11.7)
e5 d dl Z d dlZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
G d d Z G d d Z G d dej
Z G d d
e Z G d d e ZdS )
N)supportc e Zd Zd ZdddZd Zd Zd Zej de
j d d
d d Z ej e
j fd
Z
d Zd Zej d Zd ZdS )FunctionalTestCaseMixinc ( t j S N)asyncionew_event_loopselfs P/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_asyncio/functional.pynew_loopz FunctionalTestCaseMixin.new_loop s %''' g{Gz?)delayc ^ | j t j | d S r )looprun_until_completer sleep)r r s r run_loop_brieflyz(FunctionalTestCaseMixin.run_loop_briefly s( $$W]5%9%9:::::r c n | j | | j | d S r )._FunctionalTestCaseMixin__unhandled_exceptionsappendr default_exception_handler)r r contexts r loop_exception_handlerz.FunctionalTestCaseMixin.loop_exception_handler s5 #**7333 ++G44444r c | | _ t j d | j | j g | _ d S r )r
r r set_event_loopset_exception_handlerr r r
s r setUpz FunctionalTestCaseMixin.setUp sI MMOO t$$$ ''(CDDD&(###r c 8 | j | j r=t d t j | j | d t
j d d | _ d S # t
j d d | _ w xY w)Nz2Unexpected calls to loop.call_exception_handler():z1unexpected calls to loop.call_exception_handler())r closer printpprintfailr r r
s r tearDownz FunctionalTestCaseMixin.tearDown s
IOO *
OJKKK
d 9::: MNNN
"4 ( ( ( DIII
"4 ( ( ( DI s A A< < BN
)familyaddrtimeoutbacklog max_clientsc |Zt t d rC|t j k r3t j 5 }|j }d d d n # 1 swxY w Y nd}t j ||| }|t d |dk rt d | | t | |||| S )NAF_UNIX)z 127.0.0.1r )r' r* timeout is requiredr #only blocking sockets are supported)
hasattrsocketr- tempfileNamedTemporaryFilename
create_server RuntimeError
settimeoutTestThreadedServer) r server_progr' r( r) r* r+ tmpsocks r
tcp_serverz"FunctionalTestCaseMixin.tcp_server- s <vy))
(f.F.F 022 $c 8D$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ (#DIII ? 455 5 a<< DEE E ! $ Wk; ; ;s AAAc t j |t j }|t d |dk rt d | | t | ||| S )Nr. r r/ )r1 SOCK_STREAMr6 r7 TestThreadedClient)r client_progr' r) r; s r
tcp_clientz"FunctionalTestCaseMixin.tcp_clientE sq }VV%788 ? 455 5 a<< DEE E ! $ W. . .r c l t t d st | j |dt j i|S Nr- r' )r0 r1 NotImplementedErrorr< r- r argskwargss r unix_serverz#FunctionalTestCaseMixin.unix_serverT 8 vy)) &% % tFV^FvFFFr c l t t d st | j |dt j i|S rC )r0 r1 rD rA r- rE s r unix_clientz#FunctionalTestCaseMixin.unix_clientY rI r c # L K t j 5 }t j |d } |V t j | n:# t $ r Y n.w xY w# t j | w # t $ r Y w w xY wxY wd d d d S # 1 swxY w Y d S )Nr; )r2 TemporaryDirectoryospathjoinunlinkOSError)r tdfns r unix_sock_namez&FunctionalTestCaseMixin.unix_sock_name^ s
(
*
* b b&))B
IbMMMM DIbMMMM D si !BA"AB
A B A B"B $A98B 9
B B B B BB B c | j | | d S # | | w xY wr )r stopr# r exs r _abort_socket_testz*FunctionalTestCaseMixin._abort_socket_testj s@ INN IIbMMMMMDIIbMMMMs 2 A )__name__
__module__ __qualname__r
r r r r$ r1 AF_INETr LOOPBACK_TIMEOUTr< rA rH rK
contextlibcontextmanagerrU rZ r r r r
s ( ( ( )- ; ; ; ; ;5 5 5) ) ) !. "3 ! ; ; ; ; ;2 !."3
.
.
.
. G G G
G G G
r r c 4 e Zd Zd Zd ZddddZd Zd ZdS ) TestSocketWrapperc || _ d S r )_TestSocketWrapper__sockr r; s r __init__zTestSocketWrapper.__init__x s
r c d}t | |k rJ| |t | z
}|dk rt ||z
}t | |k J|S )Nr )lenrecvConnectionAbortedError)r nbufdatas r recv_allzTestSocketWrapper.recv_all{ sa #hhll99QS\**Ds{{,, 4KC #hhll
r FN) server_sideserver_hostnamec " | | j ||d } | n# | xY w | j n # | j w xY w|| _ d S )NF)rq rr do_handshake_on_connect) wrap_socketrf do_handshaker )r ssl_contextrq rr ssl_socks r start_tlszTestSocketWrapper.start_tls s ** K[ +$) + + +
! ! # # # # NN
$
K DK s 5 A* A A* *Bc , t | j | S r )getattrrf )r r4 s r __getattr__z TestSocketWrapper.__getattr__ s t{D)))r c \ d t | j | j S )Nz <{} {!r}>)formattyper[ rf r
s r __repr__zTestSocketWrapper.__repr__ s# !!$t**"5t{CCCr )r[ r\ r] rh rp ry r| r rb r r rd rd v sv $"& &* * *D D D D Dr rd c e Zd Zd Zd Zd ZdS ) SocketThreadc < d| _ | d S NF)_activerP r
s r rW zSocketThread.stop s r c . | | S r )startr
s r __enter__zSocketThread.__enter__ s
r c . | d S r )rW )r excs r __exit__zSocketThread.__exit__ s r N)r[ r\ r] rW r r rb r r r r sA r r c e Zd Zd Zd ZdS )r? c t j | d d d d| _ || _ || _ d| _ || _ || _ d S )Nz test-clientT) threadingThreadrh daemon_timeout_sockr _prog_test)r testr; progr) s r rh zTestThreadedClient.__init__ sM !!$dMBBB
r c | t | j d S # t $ r%}| j | Y d }~d S d }~ww xY wr )r rd r Exceptionr rZ rX s r runzTestThreadedClient.run sq . JJ(44 5 5 5 5 5 . . . J ) )" - - - - - - - - - .s '+
AAAN)r[ r\ r] rh r rb r r r? r? s2 . . . . .r r? c L e Zd Zd Z fdZd Zd Zd Zed Z xZ
S )r8 c < t j | d d d d| _ d| _ d| _ || _ || _ || _ d| _ || _
t j \ | _
| _ | j
d || _ d S )Nz test-serverTr F)r r rh r _clients_finished_clients _max_clientsr r r r r1
socketpair_s1_s2 setblockingr )r r r; r r) r+ s r rh zTestThreadedServer.__init__ s !!$dMBBB
!" '
# . 0 0$( U###
r c 4 | j rI| j dk r, | j d n# t $ r Y nw xY wt d S # t w xY w)Ns stop)r filenosendrR superrW )r __class__s r rW zTestThreadedServer.stop s x
DHOO - - 3 3HMM'**** D
GGLLNNNNNEGGLLNNNNs. $A5 A A5
A
A5 AA5 5"Bc t | j 5 | j d | d d d n # 1 swxY w Y | j | j d S # | j | j w xY wr )r r _runr r r r
s r r zTestThreadedServer.run s
&&u---
HNN HNN
HNN HNN s- B /A B AB A B 4B7c | | j r3| j | j k rd S t j | j | j gg g | j \ }}}| j |v rd S | j |v r | j \ }}| xj dz
c_ | | j |5 | | d d d n # 1 swxY w Y n_# t $ r-}d| _ # | j | w xY wd }~ww xY w# t $ r Y t $ r | j sY d S w xY w| j 1d S d S )Nr% F)r r r selectr r r acceptr7 _handle_clientr r rZ BlockingIOError TimeoutError)r rwxconnr( rY s r r zTestThreadedServer._run s l >} 111 mTX&B
? ?GAq! x1}}zQ>!%!2!2!4!4JD$ MMQ&MMOODM222> ! 6 6 / / 5 5 56 6 6 6 6 6 6 6 6 6 6 6 6 6 6$ > > >', > ! J 9 9" = = = = > ' H# < l > > > > >sf D
#C %C; C C C C C
D
D%C&& DDD
D/D/-D/c J | t | d S r )r rd rg s r r z!TestThreadedServer._handle_client s#
$T**+++++r c 4 | j S r )r getsocknamer
s r r( zTestThreadedServer.addr s z%%'''r ) r[ r\ r] rh rW r r r propertyr(
__classcell__)r s @r r8 r8 s $ > > >D, , , ( ( X( ( ( ( (r r8 )r asyncio.eventsr` rN r" r r1 r2 r r r r rd r r r? r8 rb r r <module>r sh
a a a a a a a aR%D %D %D %D %D %D %D %DP 9# . . . . . . . .&N( N( N( N( N( N( N( N( N( N(r 
Browse
Usage
Versions