python (3.11.7)
eF d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z d dl
m Z m
Z
d dl
mZ d dl
mZ d dl
mZ e j d e j d d Zej Z eed
Z ej ed Ze j j Z ej ed Z ej Z e j j fd
Z er4er2 G d de j e j! Z" G d de j e j# Z$e j% d Z& G d dej' Z( G d dej' Z) G d de j* Z+ G d de j, Z- G d d e j. e+ Z/er G d d e j e+ Z0 G d d ej' Z1 G d! d"ej' Z2e3d#k r ej4 dS dS )$ N)
reap_childrenverbose) os_helper)
socket_helper)threading_helpernetworkT)modules hello world
AF_UNIXzrequires Unix socketszrequires forkingc t | gg g | \ }}}| |v r| | S t d| )Nz
timed out on ) _real_selectrecv RuntimeError)sockntimeoutrwxs J/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_socketserver.pyreceiver ' sK D62r733GAq! qyyyy||l6777 c e Zd ZdS )ForkingUnixStreamServerN__name__
__module__ __qualname__ r r r r / r r c e Zd ZdS )ForkingUnixDatagramServerNr r r r r! r! 3 r r r! c # K t j }|dk rt j d d V n# xY w t j |d d S # t j |d w xY w)Nr H )exitcode)osfork_exittestsupport wait_process)testcasepids r simple_subprocessr- 8 s L
'))C
axx
4
!!#!33333 !!#!3333s 7 A! :A! !#Bc n e Zd Z d Zd Zd Zd Zej d Z d Z
d Z d Z d Z
ed
Zed Zed Zeed
Zd Zd Zed Zed Zed Zeed Zej d Zd Zd Z d Z dS )SocketServerTestc " d| _ g | _ d S Nr ) port_seed
test_filesselfs r setUpzSocketServerTest.setUpJ s r c t | j D ]'} t j | # t $ r Y $w xY wg | j d d < d S N)r r3 r% removeOSError)r5 fns r tearDownzSocketServerTest.tearDownN sf / B
"
s .
;;c |t j k r t dfS d }t j d| }| j | |S )Nr z unix_socket.)prefixdir)socketAF_INETHOSTtempfilemktempr3 append)r5 protor? r; s r pickaddrzSocketServerTest.pickaddrX sO FN " "!9 C C@@@B O " "2 & & &Ir c T G d d| } G d d| }t rt d ||| }n5# t $ r(}| d|d|d| Y d }~nd }~ww xY w| |j |j |S ) Nc e Zd Zd ZdS ).SocketServerTest.make_server.<locals>.MyServerc . | | r8 )
close_requestr5 requestclient_addresss r handle_errorz;SocketServerTest.make_server.<locals>.MyServer.handle_errore s ""7+++r N)r r r rP r r r MyServerrJ d s#
r rQ c e Zd Zd ZdS )/SocketServerTest.make_server.<locals>.MyHandlerc l | j }| j | d S r8 )rfilereadlinewfilewrite)r5 lines r handlez6SocketServerTest.make_server.<locals>.MyHandler.handlej s1 z**,,
&&&&&r Nr r r rZ r r r MyHandlerrS i s#
'
'
'
'
'r r\ zcreating serverzCannot create server (z, z): )r printPermissionErrorskipTest assertEqualserver_addressr@ getsockname)r5 addrsvrclshdlrbaserQ r\ serveres r make_serverz SocketServerTest.make_serverc s v
' ' ' ' ' ' ' '
,E+,,, - XdI..FF - - - MMM!66444,
-
-
-
-
-
-
-
- -
.
0I0I0K0KLLL
s A
A3 A..A3c | | | |j || }|j }t r t d| t d| t
j d|z |j ddi }d|_ |
t rt d t d D ]*}t rt d
| ||j | +t rt d | |
| | d |j t$ r4t' |t( j r| |j t rt d
d S d S )NzADDR =zCLASS =z
%s serving
poll_interval{Gz?nametargetkwargsTzserver running z test clientzwaiting for serverdone)rh rG address_familyra r r] threadingThread
serve_foreverdaemonstartrangeshutdownjoin server_closer` r@ fileno HAVE_FORKING
isinstance socketserver ForkingMixIn assertFalseactive_children)r5 rd re testfuncrf rc tis r
run_serverzSocketServerTest.run_serverx s !!$--0E"F"F"((4 4 $ % (D ! ! ! )V $ $ $ &' $D)
+
+
+ +E*+++q 2 2A /mQ/// HV*D 1 1 1 1 /E./// V] 1 1 3 3444 5Jv|/H I I 5
V 3 4 4 4 !E&MMMMM!!r c p t j |t j 5 }| | | t t |d x}}|r d|vrt |d }||z
}|rd|v| |t d d d d S # 1 swxY w Y d S Nd
)r@ SOCK_STREAMconnectsendallTEST_STRr r` r5 rF rc sbufdatas r stream_examinez SocketServerTest.stream_examine s
]5&"4
5
5 ,
IIdOOO
IIh C (C$
5++ q#t
5++
S( + + + , , , , , , , , , , , , , , , , , ,s A>B++B/2B/c t j |t j 5 }t r8|t j k r(| | | | t | t |d x}}|r d|vrt |d }||z
}|rd|v| |t d d d d S # 1 swxY w Y d S r )
r@
SOCK_DGRAMHAVE_UNIX_SOCKETSr
bindrG sendtor r r` r s r
dgram_examinez SocketServerTest.dgram_examine s$
]5&"3
4
4 ,
-Ufn%<%<t}}U++,,,
HHXt $ $ $ C (C$
5++ q#t
5++
S( + + + , , , , , , , , , , , , , , , , , ,s B)CC Cc f | t j t j | j d S r8 )r r TCPServerStreamRequestHandlerr r4 s r test_TCPServerz SocketServerTest.test_TCPServer s3 .$9 + - - - - -r c f | t j t j | j d S r8 )r r ThreadingTCPServerr r r4 s r test_ThreadingTCPServerz(SocketServerTest.test_ThreadingTCPServer s3 7$9 + - - - - -r c t | 5 | t j t j | j d d d d S # 1 swxY w Y d S r8 )r- r r ForkingTCPServerr r r4 s r test_ForkingTCPServerz&SocketServerTest.test_ForkingTCPServer s
t
$
$ 1 1 OOL 9 ( = /
1
1
1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1AAAc f | t j t j | j d S r8 )r r UnixStreamServerr r r4 s r test_UnixStreamServerz&SocketServerTest.test_UnixStreamServer s3 5$9 + - - - - -r c f | t j t j | j d S r8 )r r ThreadingUnixStreamServerr r r4 s r test_ThreadingUnixStreamServerz/SocketServerTest.test_ThreadingUnixStreamServer s3 >$9 + - - - - -r c t | 5 | t t j | j d d d d S # 1 swxY w Y d S r8 )r- r r r r r r4 s r test_ForkingUnixStreamServerz-SocketServerTest.test_ForkingUnixStreamServer s t
$
$ 1 1 OO 3 ( = /
1
1
1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1s ,A A
A
c f | t j t j | j d S r8 )r r UDPServerDatagramRequestHandlerr r4 s r test_UDPServerz SocketServerTest.test_UDPServer s3 .$; * , , , , ,r c f | t j t j | j d S r8 )r r ThreadingUDPServerr r r4 s r test_ThreadingUDPServerz(SocketServerTest.test_ThreadingUDPServer s3 7$; * , , , , ,r c t | 5 | t j t j | j d d d d S # 1 swxY w Y d S r8 )r- r r ForkingUDPServerr r r4 s r test_ForkingUDPServerz&SocketServerTest.test_ForkingUDPServer s
t
$
$ 0 0 OOL 9 ( ? .
0
0
0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0r c f | t j t j | j d S r8 )r r UnixDatagramServerr r r4 s r test_UnixDatagramServerz(SocketServerTest.test_UnixDatagramServer s3 7$; * , , , , ,r c f | t j t j | j d S r8 )r r ThreadingUnixDatagramServerr r r4 s r test_ThreadingUnixDatagramServerz1SocketServerTest.test_ThreadingUnixDatagramServer s3 @$; * , , , , ,r c \ | t t j | j d S r8 )r r! r r r r4 s r test_ForkingUnixDatagramServerz/SocketServerTest.test_ForkingUnixDatagramServer s3
1$; * , , , , ,r c G d dt j } G d dt j }g }t d D ]Q} |t df| }t j d|j dd i
}d |_ | ||f R|D ]-\ }}|
| .|D ]-\ }}| |
.d S ) Nc e Zd ZdS )0SocketServerTest.test_shutdown.<locals>.MyServerNr r r r rQ r Dr rQ c e Zd ZdS )1SocketServerTest.test_shutdown.<locals>.MyHandlerNr r r r r\ r r r r\ r zMyServer servingrj rk rl T)r r r ry rB rt ru rv rw rE rx rz r{ r| )r5 rQ r\ threadsr r r s r
test_shutdownz SocketServerTest.test_shutdown sB |- 9 r # #A$I..A ''-/ / /A AH NNAq6 " " " " DAq
GGIII
JJLLLL DAq
FFHHH
NN r c G d dt j t j } |t dfd }| d S )Nc e Zd ZdS )9SocketServerTest.test_close_immediately.<locals>.MyServerNr r r r rQ r r r rQ r c d S r8 r r r r <lambda>z9SocketServerTest.test_close_immediately.<locals>.<lambda> s T r )r ThreadingMixInr rB r| )r5 rQ rf s r test_close_immediatelyz'SocketServerTest.test_close_immediately se |2L4J 4)\\22 r c t d D ]Z}| t 5 t j t
dft j d d d n # 1 swxY w Y [d S )Ni rq )ry assertRaises
OverflowErrorr r rB r )r5 r s r test_tcpserver_bind_leakz)SocketServerTest.test_tcpserver_bind_leak s
t J JA""=11
J
J &bz'3'HJ J J
J
J
J
J
J
J
J
J
J
J
J
J
J
J
J J Js 'A A# &A# c t j t dft j 5 } d d d n # 1 swxY w Y | d|j d S )Nr rq )r r rB r r` r@ r} )r5 rf s r test_context_managerz%SocketServerTest.test_context_manager$ s
#T1I$0$EG G JP
V] 1 1 3 344444s 599N) r r r r6 r< rG rh r reap_threadsr r r r r requires_forkingr requires_unix_socketsr r r r r r r r r r r r r r r r r/ r/ G s " * " " " #" "D, , , , , ,- - -
- - -
1 1 1 - - -
- - -
1 1 1 , , ,
, , ,
0 0 0 , , ,
, , ,
, , ,
" #" 2 J J J5 5 5 5 5r r/ c ` e Zd Z d Zd Zd Zd Zd Zed Z ed Z
d Z d S )
ErrorHandlerTestc B t j t j d S r8 )r unlinkTESTFNr4 s r r< zErrorHandlerTest.tearDown0 s )*****r c Z t t | d d S NThandled)BaseErrorTestServer
ValueError check_resultr4 s r test_sync_handledz"ErrorHandlerTest.test_sync_handled3 s- J''' $'''''r c | t 5 t t d d d n # 1 swxY w Y | d d S NFr )r
SystemExitr r r4 s r test_sync_not_handledz&ErrorHandlerTest.test_sync_not_handled7 s
z
*
* , ,
+ + + , , , , , , , , , , , , , , , %(((((s <A A c Z t t | d d S r )ThreadingErrorTestServerr r r4 s r test_threading_handledz'ErrorHandlerTest.test_threading_handled< s- ,,, $'''''r c t j 5 }t t | d | |j t d d d d S # 1 swxY w Y d S r )r catch_threading_exceptionr r r assertIsexc_type)r5 cms r test_threading_not_handledz+ErrorHandlerTest.test_threading_not_handled@ s
7
9
9 3R $Z 0 0 0 e , , , MM"+z 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s A A,,A03A0c Z t t | d d S r )ForkingErrorTestServerr r r4 s r test_forking_handledz%ErrorHandlerTest.test_forking_handledG s- z*** $'''''r c Z t t | d d S r )r r r r4 s r test_forking_not_handledz)ErrorHandlerTest.test_forking_not_handledL s- z*** %(((((r c t t j 5 }dd|z z }| | | d d d d S # 1 swxY w Y d S )NHandler called
Error handled
)openr r r` read)r5 r logexpecteds r r z ErrorHandlerTest.check_resultQ s
)"
#
# 3s),=,GGH SXXZZ 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s 1AA A N) r r r r< r r r r r r r r r r r r r + s )+ + +( ( () ) )
( ( (3 3 3 ( ( ( ) ) )3 3 3 3 3r r c * e Zd Z fdZd Zd Z xZS )r c || _ t t dft t j | j 5 d d d n # 1 swxY w Y | | n# | w xY w|
d S r1 ) exceptionsuper__init__rB
BadHandlerr@ create_connectionra handle_requestr| wait_done)r5 r __class__s r r z BaseErrorTestServer.__init__X s "
$J///
%d&9
:
: ! ! ! D s A A"%A"*B B)c t t j d 5 }| d d d d d S # 1 swxY w Y d S )Nar )r r r rX )r5 rN rO r s r rP z BaseErrorTestServer.handle_errorc s
)"C
(
( )C II' ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s >AAc d S r8 r r4 s r r z BaseErrorTestServer.wait_doneg s r )r r r r rP r
__classcell__r s @r r r W sV ) ) )
r r c e Zd Zd ZdS )r c t t j d 5 }| d d d d n # 1 swxY w Y | j d )Nr
r z
Test error)r r r rX rf r )r5 r s r rZ zBadHandler.handlel s
)"C
(
( *C II( ) ) ) * * * * * * * * * * * * * * *k##L111s =AANr[ r r r r r k s# 2 2 2 2 2r r c . e Zd Z fdZ fdZd Z xZS )r c j t j | _ t j |i | d S r8 )rt Eventrr r r r5 poskwr s r r z!ThreadingErrorTestServer.__init__t s4 O%% #$$$$$$r c l t j |i | | j d S r8 )r shutdown_requestrr setr s r r z)ThreadingErrorTestServer.shutdown_requestx s2 #,,,,
r c 8 | j d S r8 )rr waitr4 s r r z"ThreadingErrorTestServer.wait_done| s r )r r r r r r r r
s @r r r r s` % % % % % r r c e Zd ZdS )r Nr r r r r r s r r c e Zd Zd Zd ZdS )SocketWriterTestc G d dt j }t j t df| }| |j t
j |j t j t j }|5 |
|j d d d n # 1 swxY w Y | |
|j t j | |j |j d S )Nc e Zd Zd ZdS )-SocketWriterTest.test_basics.<locals>.Handlerc | j | j _ | j | j _ | j | j _ d S r8 )rW rf r} wfile_filenorN request_filenor4 s r rZ z4SocketWriterTest.test_basics.<locals>.Handler.handle sD $(J !+/:+<+<+>+> (-1\-@-@-B-B ***r Nr[ r r r Handlerr s(
C
C
C
C
Cr r$ r )r r r rB
addCleanupr| r@ rs r IPPROTO_TCPr ra r assertIsInstancerW ioBufferedIOBaser` r" r# )r5 r$ rf r s r test_basicsz SocketWriterTest.test_basics sF C C C C Cl7 C C C 'q 7;; +,,, M !6#5v7I
K
K
- -
IIf+ , , , - - - - - - - - - - - - - - - flB,=>>> ,f.CDDDDDs B''B+.B+c
t j t d G d dt j }t j t df| | j t j fd}t j t j | }| t j t j | d
d t j
fd}t j | }| | | j t)
|
d | j d | j t j j | t j j d
z
d S ) N pthread_killc e Zd Zd ZdS ),SocketWriterTest.test_write.<locals>.Handlerc | j d | j _ | j | j _ dt j j z }| j | | j _
d S )N write data
) rW rX rf sent1rU rV receivedr( r)
SOCK_MAX_SIZEsent2)r5 big_chunks r rZ z3SocketWriterTest.test_write.<locals>.Handler.handle sc $(J$4$4_$E$E !'+z':':'<'< $ !DL$> > $(J$4$4Y$?$? !!!r Nr[ r r r r$ r. s(
@
@
@
@
@r r$ r c 0 d S r8 )r )signumframe interrupteds r signal_handlerz3SocketWriterTest.test_write.<locals>.signal_handler s OO r c ` t j j t j t j } | 5 | d 5 }| j | | d | d t j t d rn;t | d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S )Nrb client response
r T )r )r@ rs r r& makefiler ra rV r r signalSIGUSR1r floatlen)r readerr: main_threadr, received2 response1rf s r
run_clientz/SocketWriterTest.test_write.<locals>.run_client s
f 3V5G"$ $A
/
/AJJt$$
/ &/000 "OO - - ./// C Lfn==="''a'99
. . #
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/s6 D# B6D ? D# D D#D D##D'*D')rn r0 r> r )r( r)
get_attributerA r r r rB r% r| rt r rB get_identru rx r r{ r` r2 rD r3 r5 r4 ) r5 r$ r; originalrI
backgroundr: rF r, rG rH rf s @@@@@@r
test_writezSocketWriterTest.test_write s |11&.II @ @ @ @ @l7 @ @ @ 'q 7;; +,,, o'' = @@
v~x@@@ )++ / / / / / / / / / /, %Z888
s9~~666 O444 *>??? t|'ABBB DL$>$DEEEEEr N)r r r r* rN r r r r r s: E E E"8F 8F 8F 8F 8Fr r c e Zd Zd Zd Zd ZdS ) MiscTestCasec g }t t D ]V}| d s?t t | }t |dd dk r| | W| t j | d S )N_r r )r? r
startswithgetattrrE assertCountEqual__all__)r5 r rm
mod_objects r test_allzMiscTestCase.test_all s %% * *D??3''
* $\4 8 8
:|T::nLL OOD))) l 2H=====r c G d dt j } |t dft j }t j |j t j }| |j | |
| |j d |
d S )Nc e Zd Zd ZdZd ZdS )SMiscTestCase.test_shutdown_request_called_if_verify_request_false.<locals>.MyServerc dS )NFr rM s r verify_requestzbMiscTestCase.test_shutdown_request_called_if_verify_request_false.<locals>.MyServer.verify_request s ur r c f | xj dz
c_ t j | | d S )Nr? )shutdown_calledr r r )r5 rN s r r zdMiscTestCase.test_shutdown_request_called_if_verify_request_false.<locals>.MyServer.shutdown_request s5 $$)$$ &77gFFFFFr N)r r r r] r_ r r r r rQ r[ s>
O
G
G
G
G
Gr rQ r r? )r r rB r r@ rs r r ra closer r` r_ r| )r5 rQ rf r s r 4test_shutdown_request_called_if_verify_request_falsezAMiscTestCase.test_shutdown_request_called_if_verify_request_false s G G G G G|- G G G 4)\%FGG M&/1C D D &'((( /333 r c G d dt j t j } |t dft j }t d D ]G}t
j |j 5 | d d d n # 1 swxY w Y H|
t |j d |
d S )Nc e Zd ZdS )2MiscTestCase.test_threads_reaped.<locals>.MyServerNr r r r rQ rd r r rQ r
)r r r rB r ry r@ r ra r
assertLessrD _threadsr| )r5 rQ rf r s r test_threads_reapedz MiscTestCase.test_threads_reaped s
|2L4J 4)\%FGGr ( (A)&*?@@
(
(%%'''
(
(
(
(
(
(
(
(
(
(
(
(
(
(
( FO,,b111 s ,B
B B N)r r r rX ra rh r r r rP rP sA > > > * r rP __main__)5
contextlibr( r% selectrA r@ rC rt unittestr test.supportr( r r r r r r) requiresrequires_working_socketr rB hasattrr
skipUnlessr has_fork_supportr~ r r
SHORT_TIMEOUTr r r r r r! contextmanagerr- TestCaser/ r r r BaseRequestHandlerr r r r r rP r mainr r r <module>rx s
/ / / / / / / / " " " " " " & & & & & & ) ) ) ) ) ) i $ $D $ 1 1 1 GFI.. ++,=,CE E |, &8&|5GHH } !\ 7 8 8 8 8
,";"."?
L$=$0$C
4 4 4 a5 a5 a5 a5 a5x( a5 a5 a5H)3 )3 )3 )3 )3x( )3 )3 )3X
,0
(2 2 2 2 2 0 2 2 2 | :
!:<O
JF JF JF JF JFx( JF JF JFZ/ / / / / 8$ / / / d zHMOOOOO r 
Browse
Usage
Versions