*jm S r SSKrSSKrSSKrSSKrSSKrSSKJr SSKJ r / SQr
\ " \S5 ( a \
R / SQ5 \ " \S5 ( a4 \
R / S Q5 \ " \S5 ( a \
R S
S /5 \ " \S 5 ( a
\R rO \R r " S
S5 r " S S\5 r " S S\5 r\ " \S5 ( a
" S S5 r " S S\5 r " S S5 r " S S5 r\ " \S5 ( a " S S \\5 r " S S \\5 r " S S \\5 r " S! S"\\5 r\ " \S5 ( aT " S# S$\5 r " S% S&\5 r " S' S(\\ 5 r " S) S*\\ 5 r \ " \S5 ( a " S+ S
\\ 5 r " S, S \\ 5 r! " S- S.5 r" " S/ S0\"5 r# " S1 S2\5 r$ " S3 S4\"5 r%g)5z0.4 N)BufferedIOBase) monotonic)
BaseServer TCPServer UDPServerThreadingUDPServerThreadingTCPServerBaseRequestHandlerStreamRequestHandlerDatagramRequestHandlerThreadingMixInfork)ForkingUDPServerForkingTCPServer ForkingMixInAF_UNIX)UnixStreamServerUnixDatagramServerThreadingUnixStreamServerThreadingUnixDatagramServerForkingUnixStreamServerForkingUnixDatagramServer PollSelectorc \ rS rSrSrS rS rSS jrS rS r S r
S r S
r S r
S rS
rS rS rS rS rS rS rSrg)r Nc ^ Xl X l [ R " 5 U l SU l g NF)server_addressRequestHandlerClass threadingEvent_BaseServer__is_shut_down _BaseServer__shutdown_request)selfr r s 3/opt/alt/python313/lib64/python3.13/socketserver.py__init__BaseServer.__init__ s% ,#6 'oo /"' c g N r$ s r% server_activateBaseServer.server_activate
r( c , U R R 5 [ 5 nUR U [ R
5 U R ( d] UR U5 nU R ( a O:U( a U R 5 U R 5 U R ( d M] S S S 5 SU l U R R 5 g ! , ( d f N0= f! SU l U R R 5 f = fr ) r" clear_ServerSelectorregister selectors
EVENT_READr# select_handle_request_noblockservice_actionsset)r$
poll_intervalselectorreadys r%
serve_foreverBaseServer.serve_forever s
!!# &
!"h!!$ (<(<= 11 $OOM :E.. 446((* 111 # ',D # # # % #" ',D # # # %s#
C0 B
C 5C0
C-)C0 0#Dc F SU l U R R 5 g NT)r# r" waitr, s r% shutdownBaseServer.shutdown s #' "r( c g r* r+ r, s r% r8 BaseServer.service_actions r/ r( c U R R 5 nUc
U R nO"U R b [ XR 5 nUb
[ 5 U- n[ 5 nUR
U [ R 5 UR U5 ( a U R 5 sS S S 5 $ Ub, W[ 5 -
nUS: a U R 5 sS S S 5 $ M` ! , ( d f g = f)Nr ) socket
gettimeouttimeoutmintimer2 r3 r4 r5 r6 r7 handle_timeout)r$ rI deadliner; s r% handle_requestBaseServer.handle_request s ++((* ?llG
\\
%'<<0G v'H
( dI$8$8 9??7++ 779
*"*TV"3"Q;#'#6#6#8
s 'AC)8%C)'C))
C7c F U R 5 u pU R X5 ( a U R X5 g U R
U5 g ! [ a g f = f! [ a% U R X5 U R
U5 g U R
U5 e = fr* ) get_requestOSErrorverify_requestprocess_request Exception handle_errorshutdown_requestr$ requestclient_addresss r% r7 "BaseServer._handle_request_noblock1 s &*&6&6&8 #G w 7 7
$$W=
! !' *
/!!':%%g.
%%g.s" A A
A A ,B
B c g r* r+ r, s r% rL BaseServer.handle_timeoutH s
r( c gr@ r+ rX s r% rS BaseServer.verify_requestO s r( c H U R X5 U R U5 g r* )finish_requestrW rX s r% rT BaseServer.process_requestW s
G4 g&r( c g r* r+ r, s r% server_closeBaseServer.server_close` r/ r( c ( U R XU 5 g r* )r rX s r% ra BaseServer.finish_requesth s $?r( c & U R U5 g r*
close_requestr$ rY s r% rW BaseServer.shutdown_requestl 7#r( c g r* r+ rk s r% rj BaseServer.close_requestp r( c [ S[ R S9 [ SU[ R S9 SS KnUR 5 [ S[ R S9 g )Nz(----------------------------------------)filez4Exception occurred during processing of request fromr )printsysstderr traceback print_exc)r$ rY rZ rv s r% rV BaseServer.handle_errort sC f3::&
D -
f3::&r( c U $ r* r+ r, s r% __enter__BaseServer.__enter__ s r( c $ U R 5 g r* )rd )r$ argss r% __exit__BaseServer.__exit__ s r( )r __is_shut_down__shutdown_requestr )g ?)__name__
__module__ __qualname____firstlineno__rI r& r- r= rB r8 rN r7 rL rS rT rd ra rW rj rV rz r~ __static_attributes__r+ r( r% r r s` \ G(
&:#
&9:+.
'
@$
' r( r c \ rS rSr\R
r\R rSr Sr
Sr SS jr S r
S rS rS rS rS
rS rS rg
)r i Fc [ R XU5 [ R " U R U R 5 U l U( a" U R 5 U R
5 g g ! U R 5 e = fr* )r r& rG address_family socket_type server_bindr- rd )r$ r r bind_and_activates r% r& TCPServer.__init__ so D2EF mmD$7$7$($4$46
"$$&
!!#s A1 1Bc d U R ( aN [ [ S5 ( a9 U R R [ R [ R
S5 U R ( a| [ [ S5 ( ag U R [ R [ R 4; a9 U R R [ R [ R S5 U R R U R 5 U R R 5 U l g )N SO_REUSEADDR SO_REUSEPORT)allow_reuse_addresshasattrrG
setsockopt
SOL_SOCKETr allow_reuse_portr AF_INETAF_INET6r bindr getsocknamer, s r% r TCPServer.server_bind s # #(G(G KK " "6#4#4f6I6I1 M
! !gfn&E&E##'HH KK " "6#4#4f6I6I1 M ,,- "kk 5 5 7r( c N U R R U R 5 g r* )rG listenrequest_queue_sizer, s r% r- TCPServer.server_activate s
4223r( c 8 U R R 5 g r* )rG closer, s r% rd TCPServer.server_close s
r( c 6 U R R 5 $ r* )rG filenor, s r% r TCPServer.fileno {{!!##r( c 6 U R R 5 $ r* )rG acceptr, s r% rQ TCPServer.get_request r r( c UR [ R 5 U R U5 g ! [ a N f = fr* )rB rG SHUT_WRrR rj rk s r% rW TCPServer.shutdown_request s?
V^^ ,
7# s 3
A A c $ UR 5 g r* )r rk s r% rj TCPServer.close_request s
r( )r rG N)T)r r r r rG r r SOCK_STREAMr r r r r& r r- rd r rQ rW rj r r+ r( r% r r sS ` ^^N$$K 8$4 $$$r( r c P \ rS rSrSrSr\R rSr S r
S r S r S r
Srg )
r i Fi c n U R R U R 5 u pXR 4U4$ r* )rG recvfrommax_packet_size)r$ data client_addrs r% rQ UDPServer.get_request s1 KK 0 01E1E Fkk"K//r( c g r* r+ r, s r% r- UDPServer.server_activate rp r( c & U R U5 g r* ri rk s r% rW UDPServer.shutdown_request$ rm r( c g r* r+ rk s r% rj UDPServer.close_request( rp r( r+ N)r r r r r r rG
SOCK_DGRAMr r rQ r- rW rj r r+ r( r% r r s4 ##KO0
$
r( r c X ^ \ rS rSrSrSrSrSrSS.S jrS r S
r
S r U 4S jr S
r
U =r$ )r i- i, N( TFblockingc U R c g [ U R 5 U R : aZ [ R " SS5 u p#U R R U5 [ U R 5 U R : a MZ U R R 5 HP n U( a SO[ R n[ R " X$5 u p#U R R U5 MR g ! [ a U R R 5 N[ a M f = f! [ a U R R U5 M [ a M f = f)Nr ) active_childrenlen max_childrenoswaitpiddiscardChildProcessErrorr1 rR copyWNOHANG)r$ r pid_flagss r% collect_children ForkingMixIn.collect_children6 s" ##+ d**+t/@/@@ ZZA .FC((005 d**+t/@/@@ ++002
!)ArzzE ZZ 3FC ((005
3 ) 1((..0 ) 6((005 s0 4C; *A D1;$D.! D.-D.1%E& E&%E&c $ U R 5 g r* r r, s r% rL ForkingMixIn.handle_timeoutY
! ! #r( c $ U R 5 g r* r r, s r% r8 ForkingMixIn.service_actions` r r( c R [ R " 5 nU( aI U R c [ 5 U l U R R U5 U R U5 g Sn U R
X5 Sn U R U5 [ R " U5 g ! [ a U R X5 NFf = f! [ R " U5 f = f! U R U5 [ R " U5 f ! [ R " U5 f = f= f)Nr r ) r r r r9 addrj ra rU rV rW _exit)r$ rY rZ r statuss r% rT ForkingMixIn.process_requestg s '')C''/+.5D($$((-""7+ )''@ F) --g6(
! ?%%g>? () --g6((sH )B% =C %C C! CC! C !D&#D 4D& D##D&c T > [ TU ] 5 U R U R S9 g )Nr )superrd r block_on_closer$ __class__s r% rd ForkingMixIn.server_close s% G " ! !4+>+> ! ?r( )r )r r r r rI r r r r rL r8 rT rd r
__classcell__r s @r% r r - s= /4 ! F $ $ )2 @ @r( r c : ^ \ rS rSrU 4S jrS rS rS rSrU =r $ )_Threadsi c h > U R 5 UR ( a g [ TU ]
U5 g r* )reapdaemonr append)r$ threadr s r% r _Threads.append s" ==
v r( c / U S S sU S S & nU$ r* r+ )r$ results r% pop_all_Threads.pop_all s d1gQ
r( c R U R 5 H nUR 5 M g r* )r joinr$ r s r% r
_Threads.join s llnF KKM %r( c S U 5 U S S & g )Nc 3 R # U H oR 5 ( d M Uv M g 7fr* )is_alive).0r s r% _Threads.reap.. s Bf0A66s ' 'r+ r, s r% r
_Threads.reap s BBQr( r+ )
r r r r r r r r r r r s @r% r r s C Cr( r c \ rS rSrS rS rSrg)
_NoThreadsi c g r* r+ r s r% r _NoThreads.append r( c g r* r+ r, s r% r _NoThreads.join r r( r+ N)r r r r r r r r+ r( r% r r s
r( r c J ^ \ rS rSrSrSr\" 5 rS rS r U 4S jr
Sr U =r $ )r
i FTc U R X5 U R U5 g ! [ a U R X5 N/f = f! U R U5 f = fr* )ra rU rV rW rX s r% process_request_thread%ThreadingMixIn.process_request_thread sU + 8
! !' * 7 g 6 7
! !' *s! % A A AA Ac $ U R ( a# [ U 5 R S[ 5 5 [ R
" U R X4S9nU R Ul U R R U5 UR 5 g )N_threads)targetr} ) r vars
setdefaultr r Threadr daemon_threadsr r r start)r$ rY rZ ts r% rT ThreadingMixIn.process_request sg J ! !*hj 9 d&A&A%,$=
?&&
Q r( c V > [ TU ] 5 U R R 5 g r* )r rd r r r s r% rd ThreadingMixIn.server_close s
r( r+ )
r r r r r r r r r rT rd r r r s @r% r
r
s,
NN |H + r( r
c \ rS rSrSrg)r i r+ Nr r r r r r+ r( r% r r Tr( r c \ rS rSrSrg)r i r+ Nr r+ r( r% r r r r( r c \ rS rSrSrg)r i r+ Nr r+ r( r% r r r r( r c \ rS rSrSrg)r i r+ Nr r+ r( r% r r r r( r c , \ rS rSr\R
rSrg)r i r+ Nr r r r rG r r r r+ r( r% r r r( r c , \ rS rSr\R
rSrg)r i r+ Nr r+ r( r% r r r r( r c \ rS rSrSrg)r i r+ Nr r+ r( r% r r tr( r c \ rS rSrSrg)r i r+ Nr r+ r( r% r r 4r( r c \ rS rSrSrg)r i r+ Nr r+ r( r% r r r r( c \ rS rSrSrg)r i r+ Nr r+ r( r% r r r! r( c , \ rS rSrS rS rS rS rSrg)r
i c Xl X l X0l U R 5 U R 5 U R 5 g ! U R 5 f = fr* )rY rZ serversetuphandlefinish)r$ rY rZ r& s r% r& BaseRequestHandler.__init__ s< ,
KKM KKMDKKMs A Ac g r* r+ r, s r% r' BaseRequestHandler.setup r r( c g r* r+ r, s r% r( BaseRequestHandler.handle r r( c g r* r+ r, s r% r) BaseRequestHandler.finish r r( )rZ rY r& N) r r r r r& r' r( r) r r+ r( r% r
r
s $
r( r
c 0 \ rS rSrSrSrSrSrS rS r Sr
g) r i r r NFc U R U l U R b% U R R U R 5 U R ( a9 U R R [ R [ R S5 U R R SU R 5 U l U R S:X a [ U R 5 U l g U R R SU R 5 U l g )NTrbr wb)rY
connectionrI
settimeoutdisable_nagle_algorithmr rG IPPROTO_TCP TCP_NODELAYmakefilerbufsizerfilewbufsize
_SocketWriterwfiler, s r% r' StreamRequestHandler.setup) s ,, << # OO & &t|| 4 ' ' OO & &v'9'9'-'9'94
A__--dDMMB
==A &t7DJ 11$
FDJr( c U R R ( d U R R 5 U R R 5 U R R 5 g ! [ R a NKf = fr* )r? closedflushrG errorr r< r, s r% r) StreamRequestHandler.finish6 s` zz
"
<<
s A, ,BB)r5 r< r? ) r r r r r; r= rI r7 r' r) r r+ r( r% r r s( HH G $ G r( r c , \ rS rSrS rS rS rS rSrg)r> iA c Xl g r* _sock)r$ socks r% r& _SocketWriter.__init__F s
r( c gr@ r+ r, s r% writable_SocketWriter.writableI s r( c U R R U5 [ U5 nUR sS S S 5 $ ! , ( d f g = fr* )rI sendall
memoryviewnbytes)r$ bviews r% write_SocketWriter.writeL s.
1
]d;; ]]s =
A c 6 U R R 5 $ r* )rI r r, s r% r _SocketWriter.filenoQ s zz ""r( rH N) r r r r r& rM rU r r r+ r( r% r> r> A s
#r( r> c \ rS rSrS rS rSrg)r iT c SSK Jn U R u U l U l U" U R 5 U l U" 5 U l g )Nr )BytesIO)ior[ rY packetrG r< r? )r$ r[ s r% r' DatagramRequestHandler.setupX s0 #'<< T[ T[[)
Y
r( c U R R U R R 5 U R 5 g r* )rG sendtor? getvaluerZ r, s r% r) DatagramRequestHandler.finish^ s) 4::..0$2E2EFr( )r] r< rG r? N)r r r r r' r) r r+ r( r% r r T s
Gr( r )& __version__rG r4 r rt r r\ r rK r __all__r extendr r2 SelectSelectorr r r r listr r r
r r r r r r r r r r r
r r> r r+ r( r% rh s v
" 7 2v NNJK
69 NN 3 4 r613NOP 9n%% ,,O ..Oj j ZE
EP
8 2vU@ U@pCt C,
% % P 2v9<99<9 9 9 9 9
69 (9 ((Y ( LN4DKOn6HOr6Kl4DKO 6HO#
#
\+- +Z#N #& G / Gr(