python (3.12.0)
ϑ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 Zy)
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 Zy)FunctionalTestCaseMixinc * t j S N)asyncionew_event_loopselfs P/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_asyncio/functional.pynew_loopz FunctionalTestCaseMixin.new_loop s %%'' g{Gz?)delayc ` | j j t j | y r )looprun_until_completer sleep)r r s r run_loop_brieflyz(FunctionalTestCaseMixin.run_loop_briefly s $$W]]5%9:r c p | j j | | j j | y r )._FunctionalTestCaseMixin__unhandled_exceptionsappendr default_exception_handler)r r contexts r loop_exception_handlerz.FunctionalTestCaseMixin.loop_exception_handler s( ##**73 ++G4r c | j | _ t j d | j j | j
g | _ y r )r
r r set_event_loopset_exception_handlerr r r
s r setUpz FunctionalTestCaseMixin.setUp s= MMO t$ ''(C(CD&(#r c B | j j | j r;t d t j | j | j d t
j d d | _ y # 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 sv
IIOO **JK
d 9 9: MN
" "4 ( DI
" "4 ( DIs A!B B N
)familyaddrtimeoutbacklog max_clientsc f |Ot t d r=|t j k( r*t j 5 }|j
}d d d nd}t j ||| }| t d |dk r t d |j | t | |||| S # 1 sw Y ^xY w)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 002 $c 88D$ $ (##DI ? 45 5 a< DE E ! $ Wk; ;$ $s
B''B0c t j |t j }| t d |dk r t d |j | t | ||| S )Nr. r r/ )r1 SOCK_STREAMr6 r7 TestThreadedClient)r client_progr' r) r; s r
tcp_clientz"FunctionalTestCaseMixin.tcp_clientE s` }}VV%7%78 ? 45 5 a< DE E ! $ W. .r c r t t d st | j |dt j i|S Nr- r' )r0 r1 NotImplementedErrorr< r- r argskwargss r unix_serverz#FunctionalTestCaseMixin.unix_serverT 1 vy)% % tFV^^FvFFr c r 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 # F K t j 5 }t j j |d } | t j
| d d d y # t $ r Y w xY w# t j
| w # t $ r Y w w xY wxY w# 1 sw Y y xY ww)Nr; )r2 TemporaryDirectoryospathjoinunlinkOSError)r tdfns r unix_sock_namez&FunctionalTestCaseMixin.unix_sock_name^ s
(
(
* b b&)B
IIbM
IIbM sn B!!BA+A B! A(%B'A((B+B-BB B BB BBB B!c | j j | j | y # | j | w xY wr )r stopr# r exs r _abort_socket_testz*FunctionalTestCaseMixin._abort_socket_testj s, IINN IIbMDIIbMs . 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) !.. "33 ! ;2 !.."33
. G
G
r r c 2 e Zd Zd Zd ZddddZd Zd Zy) TestSocketWrapperc || _ y r )_TestSocketWrapper__sockr r; s r __init__zTestSocketWrapper.__init__x s r c d}t | |k r<| j |t | z
}|dk( rt ||z
}t | |k r<|S )Nr )lenrecvConnectionAbortedError)r nbufdatas r recv_allzTestSocketWrapper.recv_all{ sR #hl99QS\*Ds{,, 4KC #hl
r FN) server_sideserver_hostnamec |j | j ||d } |j | j j || _ y # |j xY w# | j j w xY w)NF)rq rr do_handshake_on_connect) wrap_socketrf do_handshaker )r ssl_contextrq rr ssl_socks r start_tlszTestSocketWrapper.start_tls sw ** KK[ +$) + +
! ! #
KK
NN KK s A A''A* * Bc . t | j | S r )getattrrf )r r4 s r __getattr__z TestSocketWrapper.__getattr__ s t{{D))r c ` dj t | j | j S )Nz <{} {!r}>)formattyper[ rf r
s r __repr__zTestSocketWrapper.__repr__ s# !!$t*"5"5t{{CCr )r[ r\ r] rh rp ry r| r rb r r rd rd v s$ $"& &*Dr rd c e Zd Zd Zd Zd Zy) SocketThreadc 2 d| _ | j y NF)_activerP r
s r rW zSocketThread.stop s r c & | j | S r )startr
s r __enter__zSocketThread.__enter__ s
r c $ | j y r )rW )r excs r __exit__zSocketThread.__exit__ s r N)r[ r\ r] rW r r rb r r r r s r r c e Zd Zd Zd Zy)r? c t j j | d d d d| _ || _ || _ d| _ || _ || _ y )Nz test-clientT) threadingThreadrh daemon_timeout_sockr _prog_test)r testr; progr) s r rh zTestThreadedClient.__init__ sF !!$dMB
r c | j t | j y # t $ r%}| j j | Y d }~y d }~ww xY wr )r rd r Exceptionr rZ rX s r runzTestThreadedClient.run sB . JJ(4 5 . JJ ) )" - - .s $' AAAN)r[ r\ r] rh r rb r r r? r? s .r r? c F e Zd Zd Z fdZd Zd Zd Zed Z xZ
S )r8 c > t j j | d d d d| _ d| _ d| _ || _ || _ || _ d| _ || _
t j \ | _
| _ | j j d || _ y )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 !!$dMB
!" '
# . . 0$( U#
r c | j r9| j j dk7 r | j j d t | y # t $ r Y w xY w# t | w xY w)Ns stop)r filenosendrR superrW )r __class__s r rW zTestThreadedServer.stop sa xxDHHOO - 3HHMM'*
GLN
GLNs( )A& A A# A& "A##A& &A6c x | j 5 | j j d | j d d d | j j | j
j y # 1 sw Y >xY w# | j j | j
j w xY wr )r r _runr r r r
s r r zTestThreadedServer.run s{
&&u-
HHNN HHNN
HHNN HHNN s! B ,A7B 7B <B 6B9c | j r| j | j k\ ry t j | j | j
gg g | j \ }}}| j
|v ry | j |v rk | j j \ }}| xj dz
c_ |j | j |5 | j | d d d | j ry y # 1 sw Y xY w# t $ r.}d| _ # | j j | w xY wd }~ww xY w# t $ r Y Kt $ r | j sY y w xY w)Nr% F)r r r selectr r r acceptr7 _handle_clientr r rZ BlockingIOError TimeoutError)r rwxconnr( rY s r r zTestThreadedServer._run s/ ll}} 1 11 mmTXX&B
?GAq! xx1}zzQ>!%!2!2!4JD$ MMQ&MOODMM2> ! 6 / / 561 ll06 6$ >', > ! JJ 9 9" = > ' # << sZ E D C:#D :D?D D=D8D D55D88D= E$ E$"E$c 8 | j t | y r )r rd rg s r r z!TestThreadedServer._handle_client s
$T*+r c 6 | j j S r )r getsocknamer
s r r( zTestThreadedServer.addr s zz%%''r ) r[ r\ r] rh rW r r r propertyr(
__classcell__)r s @r r8 r8 s1 $ >D, ( (r r8 )r asyncio.eventsr` rN r" r r1 r2 r r r r rd r r r? r8 rb r r <module>r si
a aR%D %DP 9## . .&N( N(r 
Browse
Usage
Versions