File: //opt/alt/python311/lib64/python3.11/__pycache__/socketserver.cpython-311.opt-2.pyc
hk t d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z g dZ
e ed re
g d e ed re
g d e ed
rej
Znej Z G d d Z G d
de Z G d de Z e ed r
G d d Z G d de Z G d d Z G d d Z e ed r G d dee Z G d d ee Z G d d ee Z G d d ee Z e ed r: G d! d"e Z G d# d$e Z G d% d&ee Z G d' d(ee Z G d) d* Z G d+ d,e Z! G d- d.e Z" G d/ d0e Z#dS )1z0.4 N)BufferedIOBase) monotonic)
BaseServer TCPServer UDPServerThreadingUDPServerThreadingTCPServerBaseRequestHandlerStreamRequestHandlerDatagramRequestHandlerThreadingMixInfork)ForkingUDPServerForkingTCPServer ForkingMixInAF_UNIX)UnixStreamServerUnixDatagramServerThreadingUnixStreamServerThreadingUnixDatagramServer PollSelectorc | e Zd Z dZd Zd ZddZd Zd Zd Z d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd ZdS )r Nc b || _ || _ t j | _ d| _ d S NF)server_addressRequestHandlerClass threadingEvent_BaseServer__is_shut_down _BaseServer__shutdown_request)selfr r s 3/opt/alt/python311/lib64/python3.11/socketserver.py__init__zBaseServer.__init__ s3 = ,#6 'o / /"' c d S N r! s r" server_activatezBaseServer.server_activate
r$ ?c | j t 5 }| | t j | j sN| | }| j rn1|r| | | j Nd d d n # 1 swxY w Y d| _ | j
d S # d| _ | j
w xY wr ) r clear_ServerSelectorregister selectors
EVENT_READr select_handle_request_noblockservice_actionsset)r!
poll_intervalselectorreadys r"
serve_foreverzBaseServer.serve_forever sJ
!!### &
!""
+h!!$ (<=== 1 + $OOM : :E. 7 44666((*** 1 +
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ',D # # # % % % % % ',D # # # % % % %s/ C A6B, C ,B00C 3B04C "C;c H d| _ | j d S NT)r r waitr( s r" shutdownzBaseServer.shutdown s, #' """""r$ c d S r& r' r( s r" r4 zBaseServer.service_actions r* r$ c | j }|| j }n | j t || j }|t |z }t 5 }| | t j | | }|r |
cd d d S |7|t z
}|dk r | cd d d S q# 1 swxY w Y d S )NTr ) socket
gettimeouttimeoutmintimer. r/ r0 r1 r2 r3 handle_timeout)r! rB deadliner7 r8 s r" handle_requestzBaseServer.handle_request sg +((** ?lGG
\
%'4<00G vv'H
9( dI$8 9 9 9
9 00 9 7799
9 9 9 9 9 9 9 9 *"*TVV"3"Q;;#'#6#6#8#8 9 9 9 9 9 9 9 9
9 9 9 9 9 9 9 9 9 9 9s "A C5;,C54C55C9<C9c | \ }}n# t $ r Y d S w xY w| || rk | || d S # t $ r/ | || | | Y d S | | xY w| | d S r& ) get_requestOSErrorverify_requestprocess_request Exception handle_errorshutdown_requestr! requestclient_addresss r" r3 z"BaseServer._handle_request_noblock0 s &*&6&6&8&8 #G^^ FF w 7 7
+
$$Wn=====
/
/
/!!'>:::%%g......
%%g... ! !' * * * * *s
))A 5B*B*c d S r& r' r( s r" rE zBaseServer.handle_timeoutG s
r$ c dS r; r' rP s r" rK zBaseServer.verify_requestN s
tr$ c ^ | || | | d S r& )finish_requestrO rP s r" rL zBaseServer.process_requestV s9
G^444 g&&&&&r$ c d S r& r' r( s r" server_closezBaseServer.server_close_ r* r$ c 6 | ||| d S r& )r rP s r" rV zBaseServer.finish_requestg s# F .$?????r$ c 2 | | d S r&
close_requestr! rQ s r" rO zBaseServer.shutdown_requestk s A 7#####r$ c d S r& r' r] s r" r\ zBaseServer.close_requesto s
7 r$ c t dt j t d|t j dd l}| t dt j d S )Nz(----------------------------------------)filez4Exception occurred during processing of request fromr )printsysstderr traceback print_exc)r! rQ rR rd s r" rN zBaseServer.handle_errors sx
f3:&&&&
D - - - -
f3:&&&&&&r$ c | S r& r' r( s r" __enter__zBaseServer.__enter__ s r$ c . | d S r& )rX )r! argss r" __exit__zBaseServer.__exit__ s r$ )r+ )__name__
__module__ __qualname__rB r# r) r9 r= r4 rG r3 rE rK rL rX rV rO r\ rN rg rj r' r$ r" r r s( *X G( ( (
& & & &:# # #
& 9 9 9<+ + +.
' ' '
@ @ @$ $ $
' ' ' r$ r c j e Zd Z ej Zej ZdZdZ dZ
d
dZ d Z d Z
d Zd Zd Zd
Zd Zd S )r FTc t | || t j | j | j | _ |rE | | d S # | xY wd S r& )r r# r@ address_family socket_type server_bindr) rX )r! r r bind_and_activates r" r# zTCPServer.__init__ s =D.2EFFF mD$7$($46 6
"""$$&&&&&
!!###
s (A/ /Bc | j rEt t d r0| j t j t j d | j rEt t d r0| j t j t j d | j | j | j
| _ d S )N SO_REUSEADDR SO_REUSEPORT) allow_reuse_addresshasattrr@
setsockopt
SOL_SOCKETrv allow_reuse_portrx bindr getsocknamer( s r" rs zTCPServer.server_bind s
# N(G(G N K " "6#4f6I1 M M M NWV^%D%D N K " "6#4f6I1 M M M ,--- "k 5 5 7 7r$ c F | j | j d S r& )r@ listenrequest_queue_sizer( s r" r) zTCPServer.server_activate s(
4233333r$ c : | j d S r& )r@ closer( s r" rX zTCPServer.server_close s#
r$ c 6 | j S r& )r@ filenor( s r" r zTCPServer.fileno
{!!###r$ c 6 | j S r& )r@ acceptr( s r" rI zTCPServer.get_request r r$ c | t j n# t $ r Y nw xY w| | d S r& )r= r@ SHUT_WRrJ r\ r] s r" rO zTCPServer.shutdown_request s_ A
V^ , , , , D 7#####s #
00c 0 | d S r& )r r] s r" r\ zTCPServer.close_request s 7
r$ N)T)rk rl rm r@ AF_INETrq SOCK_STREAMrr r ry r} r# rs r) rX r rI rO r\ r' r$ r" r r s ,\ ^N$K 8 8 84 4 4 $ $ $$ $ $$ $ $ r$ r c B e Zd Z dZdZej ZdZd Z d Z
d Z d Z dS )r Fi c \ | j | j \ }}|| j f|fS r& )r@ recvfrommax_packet_size)r! data client_addrs r" rI zUDPServer.get_request s1 K 0 01E F Fkdk"K//r$ c d S r& r' r( s r" r) zUDPServer.server_activate r$ c 0 | | d S r& r[ r] s r" rO zUDPServer.shutdown_request s 7#####r$ c d S r& r' r] s r" r\ zUDPServer.close_request" r r$ N)
rk rl rm ry r} r@
SOCK_DGRAMrr r rI r) rO r\ r' r$ r" r r
sl #KO0 0 0
$ $ $
r$ r c N e Zd Z dZdZdZdZdddZd Zd Z d
Z
fd Z xZ S ) r i, N( TFblockingc | j d S t | j | j k r t j dd \ }}| j | n4# t $ r | j Y nt $ r Y n!w xY wt | j | j k | j D ]z} |rdn t j
}t j || \ }}| j | F# t $ r | j | Y lt $ r Y ww xY wd S )Nr ) active_childrenlen max_childrenoswaitpiddiscardChildProcessErrorr- rJ copyWNOHANG)r! r pid_flagss r" collect_childrenz ForkingMixIn.collect_children0 s I#+ d*++t/@@@ ZA . .FC(005555( 1 1 1(..00000 E d*++t/@@@ +0022
!) 9AArzE ZU 3 3FC (005555( 6 6 6(0055555 D
s0 2A #B
B
B
AD $D>2 D>=D>c 0 | d S r& r r( s r" rE zForkingMixIn.handle_timeoutS !
! ! # # # # #r$ c 0 | d S r& r r( s r" r4 z ForkingMixIn.service_actionsZ r r$ c b t j }|rK| j t | _ | j | | | d S d} | || d}n&# t $ r | || Y nw xY w | | t j
| d S # t j
| w xY w# | | t j
| w # t j
| w xY wxY w)Nrw r ) r r r r5 addr\ rV rM rN rO _exit)r! rQ rR r statuss r" rL z ForkingMixIn.process_requesta sH ?'))C
)'/+.55D($((---""7+++ )'' @@@ FF ? ? ?%%g~>>>>>?) --g666((((((((() --g666((((((((sN %A> =C) > B! C) B!!C) %C C&)D.+D D.D++D.c ~ t | | j d S )Nr )superrX r block_on_closer! __class__s r" rX zForkingMixIn.server_closez s9 GG " " " ! !4+> ! ? ? ? ? ?r$ )
rk rl rm rB r r r r rE r4 rL rX
__classcell__r s @r" r r ' s C /4 ! ! ! ! ! F $ $ $ $ $ $ ) ) )2 @ @ @ @ @ @ @ @ @r$ r c 2 e Zd Z fdZd Zd Zd Z xZS )_Threadsc | |j rd S t | d S r& )reapdaemonr append)r! threadr s r" r z_Threads.append s; = F
v r$ c * g | d d c| d d < }|S r& r' )r! results r" pop_allz_Threads.pop_all s" d111gQQQ
r$ c \ | D ]}| d S r& )r joinr! r s r" r z
_Threads.join s2 llnn F KKMMMM r$ c ( d | D | d d < d S )Nc 3 B K | ]}| |V d S r& )is_alive).0r s r" <genexpr>z _Threads.reap.<locals>.<genexpr> s1 BBf0A0AB6BBBBBBr$ r' r( s r" r z
_Threads.reap s! BBBBBQQQr$ )rk rl rm r r r r r r s @r" r r sq C C C C C C Cr$ r c e Zd Z d Zd ZdS )
_NoThreadsc d S r& r' r s r" r z_NoThreads.append r$ c d S r& r' r( s r" r z_NoThreads.join r r$ N)rk rl rm r r r' r$ r" r r s7
r$ r c H e Zd Z dZdZ e Zd Zd Z fdZ xZ
S )r
FTc | || n&# t $ r | || Y nw xY w| | d S # | | w xY wr& )rV rM rN rO rP s r" process_request_threadz%ThreadingMixIn.process_request_thread s
+ 8 8 8 8 7 7 7 g~ 6 6 6 6 6 7
! !' * * * * *D ! !' * * * *s! A =A =A A.c " | j r/t | dt t j | j ||f }| j |_ | j
| | d S )N_threads)targetri ) r vars
setdefaultr r Threadr daemon_threadsr r r start)r! rQ rR ts r" rL z ThreadingMixIn.process_request s 8 : JJ ! !*hjj 9 9 9 d&A%,n$=
?
?
?&
Q r$ c z t | j d S r& )r rX r r r s r" rX zThreadingMixIn.server_close s3
r$ ) rk rl rm r r r r r rL rX r r s @r" r
r
sr > NN z||H + + + r$ r
c e Zd ZdS )r Nrk rl rm r' r$ r" r r r$ r c e Zd ZdS )r Nr r' r$ r" r r r r$ r c e Zd ZdS )r Nr r' r$ r" r r r r$ r c e Zd ZdS )r Nr r' r$ r" r r r r$ r c e Zd Zej ZdS )r Nrk rl rm r@ r rq r' r$ r" r r r$ r c e Zd Zej ZdS )r Nr r' r$ r" r r r r$ r c e Zd ZdS )r Nr r' r$ r" r r r r$ r c e Zd ZdS )r Nr r' r$ r" r r r r$ r c ( e Zd Z d Zd Zd Zd ZdS )r
c || _ || _ || _ | | | d S # | w xY wr& )rQ rR serversetuphandlefinish)r! rQ rR r s r" r# zBaseRequestHandler.__init__ sZ ,
KKMMM KKMMMMMDKKMMMMs A A+c d S r& r' r( s r" r zBaseRequestHandler.setup r r$ c d S r& r' r( s r" r zBaseRequestHandler.handle r r$ c d S r& r' r( s r" r zBaseRequestHandler.finish r r$ N)rk rl rm r# r r r r' r$ r" r
r
sU
r$ r
c , e Zd Z dZdZdZdZd Zd ZdS )r r r NFc | j | _ | j | j | j | j r0| j t j t j d | j d| j
| _ | j dk rt | j | _ d S | j d| j | _ d S )NTrbr wb)rQ
connectionrB
settimeoutdisable_nagle_algorithmr{ r@ IPPROTO_TCP TCP_NODELAYmakefilerbufsizerfilewbufsize
_SocketWriterwfiler( s r" r zStreamRequestHandler.setup s , < # O & &t| 4 4 4 ' A O & &v'9'-'94
A
A
A_--dDMBB
=A &t77DJJJ 11$
FFDJJJr$ c | j j s0 | j n# t j $ r Y nw xY w| j | j d S r& )r closedflushr@ errorr r r( s r" r zStreamRequestHandler.finish+ s z
""""<
s ( ::) rk rl rm r r rB r r r r' r$ r" r r sS > HH G $ G G G r$ r c ( e Zd Z d Zd Zd Zd ZdS )r c || _ d S r& )_sock)r! socks r" r# z_SocketWriter.__init__; s
r$ c dS r; r' r( s r" writablez_SocketWriter.writable> s tr$ c | j | t | 5 }|j cd d d S # 1 swxY w Y d S r& )r
sendall
memoryviewnbytes)r! bviews r" writez_SocketWriter.writeA s
1
]] d; s >AAc 4 | j S r& )r
r r( s r" r z_SocketWriter.filenoF s z """r$ N)rk rl rm r# r
r r r' r$ r" r r 6 sV J
# # # # #r$ r c e Zd Z d Zd ZdS )r c ddl m} | j \ | _ | _ || j | _ | | _ d S )Nr )BytesIO)ior rQ packetr@ r r )r! r s r" r z DatagramRequestHandler.setupM sH #'< T[ WT[))
WYY
r$ c t | j | j | j d S r& )r@ sendtor getvaluerR r( s r" r z DatagramRequestHandler.finishS s1 4:..00$2EFFFFFr$ N)rk rl rm r r r' r$ r" r r I s: @ G G G G Gr$ r )$ __version__r@ r0 r rb r r r rD r __all__rz extendr r. SelectSelectorr r r r listr r r
r r r r r r r r r
r r r r' r$ r" <module>r# sZ vt
" " " " " " 7 7 7 72v L NNJJJKKK
769 4 NN 3 3 3 4 4 4 79n%% / ,OO .Ok k k k k k k k \@ @ @ @ @
@ @ @F
8 72v V@U@ U@ U@ U@ U@ U@ U@ U@pC C C C Ct C C C,
% % % % % % % % P 72v :99999<99999999<999 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9
769
P( ( ( ( (9 ( ( (( ( ( ( (Y ( ( ( LKKKKN4DKKKOOOOOn6HOOO#
#
#
#
#
#
#
#
\+ + + + +- + + +Z# # # # #N # # #& G G G G G / G G G G Gr$